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

better processing

Browse Source
This commit is contained in:
Torma Kristóf 2021-04-25 13:02:15 +02:00
parent 0a17d98781
commit 625b7926eb
3 changed files with 21 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
kafka/consumer.py
View File

@ -18,4 +18,10 @@ try:
consumer.close() consumer.close()
except KeyboardInterrupt: except KeyboardInterrupt:
consumer.close() consumer.close()
print(DATETIMES) dt = {}
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
else:
dt[strftime("%m/%d/%Y, %H:%M:%S")] +=1

8
rabbit/consumer.py
View File

@ -24,4 +24,10 @@ try:
channel.start_consuming() channel.start_consuming()
except KeyboardInterrupt: except KeyboardInterrupt:
connection.close() connection.close()
print(DATETIMES) dt = {}
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
else:
dt[strftime("%m/%d/%Y, %H:%M:%S")] +=1

8
zmq/consumer.py
View File

@ -18,4 +18,10 @@ try:
DATETIMES.append(datetime.now()) DATETIMES.append(datetime.now())
except KeyboardInterrupt: except KeyboardInterrupt:
socket.close() socket.close()
print(DATETIMES) dt = {}
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
else:
dt[strftime("%m/%d/%Y, %H:%M:%S")] +=1