add keepalive and fix missing edges for unnammed pipe obj

code/infrastructure/streaming/clients/sub/postgres/sub_pg_cdm.py

@@ -160,11 +160,11 @@ def parse_json_to_sql_query(json,node_type):
         add_edge(key, keys, rel, dest, edge_type,json)  
 
         rel = 'affects'
-        key = f"{key_header}_sourceUUID"
+        key = f"{key_header}_sourceUUID{key_postfix}"
         add_edge(key, keys, rel, dest, edge_type,json)  
 
         rel = 'affects2'
-        key = f"{key_header}_sinkUUID"
+        key = f"{key_header}_sinkUUID{key_postfix}"
         add_edge(key, keys, rel, dest, edge_type,json)  
 
     edge_values = [source,dest,edge_type]
@@ -261,7 +261,7 @@ client.on_connect = on_connect
 client.on_message = on_message
 client.failed_connect = False
 
-client.connect(broker_hostname,broker_port,60)
+client.connect(broker_hostname,broker_port,keepalive=3600*4)
 client.loop_start()
 
 # this try-finally block ensures that whenever we terminate the program earlier by hitting ctrl+c, it still gracefully exits