@@ -37,6 +37,7 @@ def main(log_type, crawler, topic_name, group_id, env):
code="1000",
platform=crawler,
mode=log_type,
+ env=env,
message=f"Receive\n"
f"MessageId:{msg.message_id}\n"
f"MessageBodyMD5:{msg.message_body_md5}\n"