close at the end

kafka/consumer.py

@@ -22,8 +22,9 @@ except KeyboardInterrupt:
     for datetime in DATETIMES:
         dts = datetime.strftime("%m/%d/%Y, %H:%M:%S")
         if dts not in dt:
-            dt[strftime("%m/%d/%Y, %H:%M:%S")] = 1
+            dt[dts] = 1
         else:
-            dt[strftime("%m/%d/%Y, %H:%M:%S")] +=1
-    for key, value in dt:
-        print(key,",",value)
+            dt[dts] +=1
+    for key in dt:
+        print(key,",",dt[key])
+    consumer.close()

rabbit/consumer.py

@@ -23,13 +23,13 @@ try:
     channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)
     channel.start_consuming()
 except KeyboardInterrupt:
-    connection.close()
     dt = {}
     for datetime in DATETIMES:
         dts = datetime.strftime("%m/%d/%Y, %H:%M:%S")
         if dts not in dt:
-            dt[strftime("%m/%d/%Y, %H:%M:%S")] = 1
+            dt[dts] = 1
         else:
-            dt[strftime("%m/%d/%Y, %H:%M:%S")] +=1
-    for key, value in dt:
-        print(key,",",value)
+            dt[dts] +=1
+    for key in dt:
+        print(key,",",dt[key])
+    connection.close()

zmq/consumer.py

@@ -17,13 +17,13 @@ try:
         m = socket.recv_string()
         DATETIMES.append(datetime.now())
 except KeyboardInterrupt:
-    socket.close()
     dt = {}
     for datetime in DATETIMES:
         dts = datetime.strftime("%m/%d/%Y, %H:%M:%S")
         if dts not in dt:
-            dt[strftime("%m/%d/%Y, %H:%M:%S")] = 1
+            dt[dts] = 1
         else:
-            dt[strftime("%m/%d/%Y, %H:%M:%S")] +=1
-    for key, value in dt:
-        print(key,",",value)
+            dt[dts] +=1
+    for key in dt:
+        print(key,",",dt[key])
+    socket.close()