From af9596c2f63275eba9c5aa998f098b472df028cc Mon Sep 17 00:00:00 2001
From: Erik Reid <erik.reid@geant.org>
Date: Tue, 19 Jan 2021 13:16:53 +0100
Subject: [PATCH] save peerings per router
---
inventory_provider/tasks/worker.py | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py
index e01c824d..9c877975 100644
--- a/inventory_provider/tasks/worker.py
+++ b/inventory_provider/tasks/worker.py
@@ -96,7 +96,7 @@ def snmp_refresh_peerings(self, hostname, community, logical_systems):
logger.exception(msg)
self.log_warning(msg)
r = get_current_redis(InventoryTask.config)
- peerings = r.get(f'snmp-peerings:{hostname}')
+ peerings = r.get(f'snmp-peerings:{hostname}:all')
if peerings is None:
raise InventoryTaskError(
f'snmp error with {peerings}'
@@ -108,10 +108,12 @@ def snmp_refresh_peerings(self, hostname, community, logical_systems):
r = get_next_redis(InventoryTask.config)
rp = r.pipeline()
- rp.set(f'snmp-peerings:{hostname}', json.dumps(peerings))
+ rp.set(f'snmp-peerings:{hostname}:all', json.dumps(peerings))
for session in peerings:
- rp.set(f'snmp-peerings:{session["remote"]}', json.dumps(session))
+ rp.set(
+ f'snmp-peerings:{hostname}:{session["remote"]}',
+ json.dumps(session))
rp.execute()
--
GitLab