diff --git a/kafka/consumer.py b/kafka/consumer.py index 483a5ec..7761811 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -22,8 +22,8 @@ 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 + dt[dts] +=1 for key, value in dt: print(key,",",value) diff --git a/rabbit/consumer.py b/rabbit/consumer.py index e414fab..fe8a530 100644 --- a/rabbit/consumer.py +++ b/rabbit/consumer.py @@ -28,8 +28,8 @@ 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 + dt[dts] +=1 for key, value in dt: print(key,",",value) diff --git a/zmq/consumer.py b/zmq/consumer.py index fe584e2..085deb1 100644 --- a/zmq/consumer.py +++ b/zmq/consumer.py @@ -22,8 +22,8 @@ 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 + dt[dts] +=1 for key, value in dt: print(key,",",value)