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

Compare commits

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

No commits in common. "77490bae605551f76500e8167faa7ea0d67d91cf" and "0a17d98781f6fea2928e05881da12ecfaa286281" have entirely different histories.
77490bae60 ... 0a17d98781

3 changed files with 3 additions and 27 deletions
Show Stats Expand all files Collapse all files

10
kafka/consumer.py
View File

@ -18,12 +18,4 @@ try:
consumer.close()
except KeyboardInterrupt:
consumer.close()
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)
print(DATETIMES)

10
rabbit/consumer.py
View File

@ -24,12 +24,4 @@ try:
channel.start_consuming()
except KeyboardInterrupt:
connection.close()
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)
print(DATETIMES)

10
zmq/consumer.py
View File

@ -18,12 +18,4 @@ try:
DATETIMES.append(datetime.now())
except KeyboardInterrupt:
socket.close()
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)
print(DATETIMES)