|
@@ -93,12 +93,12 @@ async def consume_single_message(spider):
|
|
except MQExceptionBase as err:
|
|
except MQExceptionBase as err:
|
|
tb = traceback.format_exc()
|
|
tb = traceback.format_exc()
|
|
# Topic中没有消息可消费。
|
|
# Topic中没有消息可消费。
|
|
- if err.type == "MessageNotExist":
|
|
|
|
- message = "No new message! RequestId:{}\n{}".format(err.req_id,tb)
|
|
|
|
- logger.logging(code="5004", message=message)
|
|
|
|
- else:
|
|
|
|
- message = "Consume Message Fail! Exception:{}\n{}".format(err,tb)
|
|
|
|
- logger.logging(code="5004", message=message)
|
|
|
|
|
|
+ # if err.type == "MessageNotExist":
|
|
|
|
+ # message = "No new message! RequestId:{}\n{}".format(err.req_id,tb)
|
|
|
|
+ # logger.logging(code="5004", message=message)
|
|
|
|
+ # else:
|
|
|
|
+ message = f"Consume Message Fail! Exception:{err}\n{tb}"
|
|
|
|
+ logger.logging(code="5004", message=message)
|
|
|
|
|
|
|
|
|
|
async def main():
|
|
async def main():
|