|
|
@@ -16,6 +16,7 @@ class MQ(object):
|
|
|
self.mq_client = MQClient("http://1894469520484605.mqrest.cn-qingdao-public.aliyuncs.com",
|
|
|
"LTAI4G7puhXtLyHzHQpD6H7A",
|
|
|
"nEbq3xWNQd1qLpdy2u71qFweHkZjSG")
|
|
|
+ topic_name = topic_name+"_v2"
|
|
|
self.producer = self.mq_client.get_producer(self.instance_id, topic_name)
|
|
|
|
|
|
def send_msg(self, video_dict):
|
