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

Compare commits

base: tormakris:0a17d98781f6fea2928e05881da12ecfaa286281
Branches Tags
tormakris:master
..
compare: tormakris:77490bae605551f76500e8167faa7ea0d67d91cf
Branches Tags
tormakris:master

2 Commits
0a17d98781 ... 77490bae60

Author SHA1 Message Date
Torma Kristóf
77490bae60 print results 2021-04-25 13:03:26 +02:00
Torma Kristóf
625b7926eb better processing 2021-04-25 13:02:15 +02:00
3 changed files with 27 additions and 3 deletions
Show Stats Expand all files Collapse all files

10
kafka/consumer.py
View File

@ -18,4 +18,12 @@ 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
for key, value in dt:
print(key,",",value)

10
rabbit/consumer.py
View File

@ -24,4 +24,12 @@ 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
for key, value in dt:
print(key,",",value)

10
zmq/consumer.py
View File

@ -18,4 +18,12 @@ 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
for key, value in dt:
print(key,",",value)