zuoyc

class RocketMQ(): def __init__(self): logging.basicConfig(level=logging.CRITICAL, format='%(asctime)s - %(name)s - %(levelname)s - %(message)s') self.logger = logging.getLogger(__name__) self.consumer = PushConsumer("CID_test") self.consumer.set_namesrv_addr("XXXX：XX") self.topic_name = "XXXXXX" self.timeHash=[] #减少日志输出 dll.SetPushConsumerLogLevel(namesrv_addr.encode('utf-8'), 1) def callback(self,msg): test_body =...