diff --git a/kafka/consumer.py b/kafka/consumer.py index 7761811..5099855 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -25,5 +25,5 @@ except KeyboardInterrupt: dt[dts] = 1 else: dt[dts] +=1 - for key, value in dt: - print(key,",",value) + for key in dt: + print(key,",",dt[key]) diff --git a/rabbit/consumer.py b/rabbit/consumer.py index fe8a530..f9ca60f 100644 --- a/rabbit/consumer.py +++ b/rabbit/consumer.py @@ -31,5 +31,5 @@ except KeyboardInterrupt: dt[dts] = 1 else: dt[dts] +=1 - for key, value in dt: - print(key,",",value) + for key in dt: + print(key,",",dt[key]) diff --git a/zmq/consumer.py b/zmq/consumer.py index 085deb1..280d461 100644 --- a/zmq/consumer.py +++ b/zmq/consumer.py @@ -25,5 +25,5 @@ except KeyboardInterrupt: dt[dts] = 1 else: dt[dts] +=1 - for key, value in dt: - print(key,",",value) + for key in dt: + print(key,",",dt[key])