From 77490bae605551f76500e8167faa7ea0d67d91cf Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Torma=20Krist=C3=B3f?= Date: Sun, 25 Apr 2021 13:03:26 +0200 Subject: [PATCH] print results --- kafka/consumer.py | 2 ++ rabbit/consumer.py | 2 ++ zmq/consumer.py | 2 ++ 3 files changed, 6 insertions(+) diff --git a/kafka/consumer.py b/kafka/consumer.py index e589c23..483a5ec 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -25,3 +25,5 @@ except KeyboardInterrupt: dt[strftime("%m/%d/%Y, %H:%M:%S")] = 1 else: dt[strftime("%m/%d/%Y, %H:%M:%S")] +=1 + for key, value in dt: + print(key,",",value) diff --git a/rabbit/consumer.py b/rabbit/consumer.py index fb0c61a..e414fab 100644 --- a/rabbit/consumer.py +++ b/rabbit/consumer.py @@ -31,3 +31,5 @@ except KeyboardInterrupt: dt[strftime("%m/%d/%Y, %H:%M:%S")] = 1 else: dt[strftime("%m/%d/%Y, %H:%M:%S")] +=1 + for key, value in dt: + print(key,",",value) diff --git a/zmq/consumer.py b/zmq/consumer.py index 6a18d68..fe584e2 100644 --- a/zmq/consumer.py +++ b/zmq/consumer.py @@ -25,3 +25,5 @@ except KeyboardInterrupt: dt[strftime("%m/%d/%Y, %H:%M:%S")] = 1 else: dt[strftime("%m/%d/%Y, %H:%M:%S")] +=1 + for key, value in dt: + print(key,",",value)