save peerings per router

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()