罗俊辉 1 anno fa
parent
commit
a8b572fc92
1 ha cambiato i file con 3 aggiunte e 1 eliminazioni
  1. 3 1
      common/mq.py

+ 3 - 1
common/mq.py

@@ -18,7 +18,9 @@ class MQ:
         platform = video_dict["platform"]
         try:
             msg = TopicMessage(json.dumps(video_dict))
-            msg.set_message_key(platform + "-" + strategy + "-" + video_dict["out_video_id"])
+            message_key = "{}-{}-{}".format(platform, strategy, video_dict['out_video_id'])
+            # msg.set_message_key(platform + "-" + strategy + "-" + video_dict["out_video_id"])
+            msg.set_message_key(message_key)
             re_msg = self.producer.publish_message(msg)
             Common.logger(strategy, platform).info("Publish Message Succeed. MessageID:%s, BodyMD5:%s\n" %
                                                    (re_msg.message_id, re_msg.message_body_md5))