liqian 2 年之前
父节点
当前提交
41a5a21f7d
共有 1 个文件被更改,包括 6 次插入2 次删除
  1. 6 2
      app.py

+ 6 - 2
app.py

@@ -94,8 +94,9 @@ def title_generate_main():
                 }
                 log_.info(receive_info)
                 log_.info(f"debug: {receive_info}")
-                video_id = msg.message_body['videoId']
-                video_path = msg.message_body['videoPath']
+                message_body = json.loads(msg.message_body)
+                video_id = message_body['videoId']
+                video_path = message_body['videoPath']
                 try:
                     ppp = {'videoId': video_id, 'videoPath': video_path}
                     log_.info(f"debug: {ppp}")
@@ -185,6 +186,9 @@ def title_generate_main():
             time.sleep(2)
             continue
 
+        except Exception as e:
+            log_.error("Consume Message Fail! Exception:%s\n" % e)
+
 
 if __name__ == '__main__':
     # title_generate_main()