This commit is contained in:
wuaho 2021-09-09 21:10:07 +08:00
parent c81abb3006
commit 402def6734

View File

@ -31,9 +31,9 @@ def run():
for topic, msg in consumer(): for topic, msg in consumer():
# print(msg) # print(msg)
type_ = msg['#type'] type_ = msg['#type']
if msg['#event_name'] != 'pay': # if msg['#event_name'] != 'pay':
continue # continue
print(msg) # print(msg)
del msg['#type'] del msg['#type']
ts = int(time.time()) ts = int(time.time())