Skip to content
Snippets Groups Projects
Commit 402c2449 authored by Erik Reid's avatar Erik Reid
Browse files

save all peerings in a single doc

parent 6d6ce1ee
Branches
Tags
No related merge requests found
...@@ -294,6 +294,7 @@ def _build_juniper_peering_db(update_callback=lambda s: None): ...@@ -294,6 +294,7 @@ def _build_juniper_peering_db(update_callback=lambda s: None):
peerings_per_logical_system = {} peerings_per_logical_system = {}
peerings_per_group = {} peerings_per_group = {}
peerings_per_routing_instance = {} peerings_per_routing_instance = {}
all_peerings = []
# scan with bigger batches, to mitigate network latency effects # scan with bigger batches, to mitigate network latency effects
key_prefix = 'juniper-peerings:hosts:' key_prefix = 'juniper-peerings:hosts:'
...@@ -321,6 +322,7 @@ def _build_juniper_peering_db(update_callback=lambda s: None): ...@@ -321,6 +322,7 @@ def _build_juniper_peering_db(update_callback=lambda s: None):
if routing_instance: if routing_instance:
peerings_per_routing_instance.setdefault( peerings_per_routing_instance.setdefault(
routing_instance, []).append(p) routing_instance, []).append(p)
all_peerings.append(p)
# sort ix peerings by group # sort ix peerings by group
ix_groups = {} ix_groups = {}
...@@ -331,6 +333,8 @@ def _build_juniper_peering_db(update_callback=lambda s: None): ...@@ -331,6 +333,8 @@ def _build_juniper_peering_db(update_callback=lambda s: None):
rp = r.pipeline() rp = r.pipeline()
rp.set(f'juniper-peerings:all', json.dumps(all_peerings))
# create peering entries, keyed by remote addresses # create peering entries, keyed by remote addresses
update_callback(f'saving {len(peerings_per_address)} remote peers') update_callback(f'saving {len(peerings_per_address)} remote peers')
for k, v in peerings_per_address.items(): for k, v in peerings_per_address.items():
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment