tormakris/bigchungusdata
1
0
Fork 0
Code Pull Requests Releases Activity

ups

Browse Source
This commit is contained in:
Torma Kristóf 2021-04-25 13:07:10 +02:00
parent 77490bae60
commit b0d2c66f09
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kafka/consumer.py
View File

@ -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)

4
rabbit/consumer.py
View File

@ -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)

4
zmq/consumer.py
View File

@ -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)