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