From 402def67345f7b038ab84cfb1871ec3486eb61e5 Mon Sep 17 00:00:00 2001 From: wuaho Date: Thu, 9 Sep 2021 21:10:07 +0800 Subject: [PATCH] 1 --- single_process.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/single_process.py b/single_process.py index 32b47ff..bd081b4 100644 --- a/single_process.py +++ b/single_process.py @@ -31,9 +31,9 @@ def run(): for topic, msg in consumer(): # print(msg) type_ = msg['#type'] - if msg['#event_name'] != 'pay': - continue - print(msg) + # if msg['#event_name'] != 'pay': + # continue + # print(msg) del msg['#type'] ts = int(time.time())