|
|
@@ -113,6 +113,8 @@ def title_generate_main():
|
|
|
producer_topic_name = config_.MQ_TOPIC_CONFIG['asr_title_done']['topic_name']
|
|
|
producer = mq_client.get_producer(instance_id=instance_id, topic_name=producer_topic_name)
|
|
|
produce_msg = TopicMessage(message_body=message_body)
|
|
|
+ # 设置消息的Key。
|
|
|
+ produce_msg.set_message_key(f"videoId{video_id}")
|
|
|
re_msg = producer.publish_message(produce_msg)
|
|
|
log_.info({
|
|
|
'publish': {
|
