| 1234567891011121314151617181920212223242526272829 |
- import json
- from mq_http_sdk.mq_exception import MQExceptionBase
- from mq_http_sdk.mq_producer import TopicMessage
- from mq_http_sdk.mq_client import MQClient
- from common.common import Common
- class MQ:
- instance_id = "MQ_INST_1894469520484605_BXhXuzkZ"
- def __init__(self, topic_name) -> None:
- self.mq_client = MQClient(
- "http://1894469520484605.mqrest.cn-qingdao-public.aliyuncs.com",
- "LTAI4G7puhXtLyHzHQpD6H7A", "nEbq3xWNQd1qLpdy2u71qFweHkZjSG")
- self.producer = self.mq_client.get_producer(self.instance_id,
- topic_name)
- def send_msg(self, video_dict):
- try:
- msg = TopicMessage(json.dumps(video_dict))
- msg.set_message_key(video_dict["strategy"] + "-" +
- video_dict["out_video_id"])
- re_msg = self.producer.publish_message(msg)
- Common.logger(video_dict["strategy"], video_dict["platform"]).info(
- "Publish Message Succeed. MessageID:%s, BodyMD5:%s" %
- (re_msg.message_id, re_msg.message_body_md5))
- except MQExceptionBase as e:
- Common.logger(video_dict["strategy"], video_dict["platform"]).error(
- "Publish Message Fail. Exception:%s" % e)
|
