@@ -129,7 +129,7 @@ def main(log_type, crawler, topic_name, group_id, env):
)
AliyunLogger.logging(
- code="1004", platform=crawler, mode=log_type, message="结束一轮抓取"
+ code="1004", platform=crawler, mode=log_type, env=env,message="结束一轮抓取"
except MQExceptionBase as err: