udpate

app.py

@@ -40,17 +40,17 @@ def title_generate_main():
     # 若实例有命名空间，则实例ID必须传入；若实例无命名空间，则实例ID传入空字符串。实例的命名空间可以在消息队列RocketMQ版控制台的实例详情页面查看。
     instance_id = config_.MQ_CONFIG['INSTANCE_ID']
     # 监听消息所属的Topic
-    todo_topic_name = config_.MQ_TOPIC_CONFIG['asr_title_todo']['topic_name']
+    consumer_topic_name = config_.MQ_TOPIC_CONFIG['asr_title_todo']['topic_name']
     # 您在消息队列RocketMQ版控制台创建的Group ID。
     group_id = config_.MQ_TOPIC_CONFIG['asr_title_todo']['group_id']
-    consumer = mq_client.get_consumer(instance_id, todo_topic_name, group_id)
+    consumer = mq_client.get_consumer(instance_id, consumer_topic_name, group_id)
     # 长轮询表示如果Topic没有消息，则客户端请求会在服务端挂起3秒，3秒内如果有消息可以消费则立即返回响应。
     # 长轮询时间3秒（最多可设置为30秒）。
     wait_seconds = 3
     # 一次最多消费1条（最多可设置为16条）。
     batch = 1
     print(("%sConsume And Ak Message From Topic%s\nTopicName:%s\nMQConsumer:%s\nWaitSeconds:%s\n" \
-           % (10 * "=", 10 * "=", todo_topic_name, group_id, wait_seconds)))
+           % (10 * "=", 10 * "=", consumer_topic_name, group_id, wait_seconds)))
     while True:
         receipt_handle_list = []
         try:
@@ -94,6 +94,9 @@ def title_generate_main():
                     log_.info(traceback.format_exc())
                 else:
                     # 1. 发送结果至done消息队列
+                    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)
+                    ????
                     print(title)
                     # 2. 确认消息消费成功
                     receipt_handle_list.append(msg.receipt_handle)