close at the end

kafka/consumer.py

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

rabbit/consumer.py

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

zmq/consumer.py

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