update

toolbox/porter/tasks/douyin_live_record_task.py

@@ -158,15 +158,24 @@ class DouyinLiveRecordTask(BaseTask):
         title = data["title"]
 
         if status == 4:
+            paid_live_data = {}
             stream_data = {}
         else:
-            stream_data = json.loads(data["stream_url"]["live_core_sdk_data"]["pull_data"]["stream_data"])
+            try:
+                paid_live_data = data["paid_live_data"]
+                stream_data = data["stream_url"]["live_core_sdk_data"]["pull_data"]["stream_data"]
+            except KeyError as error:
+                logger.info(f"data.keys: {data.keys()}, error type: {type(error)}, error text: {error}, traceback: {traceback.format_exc()}")
+                self.success_rate_of_get_live_info_by_web_enter.append(0)
+                return None
+            stream_data = json.loads(stream_data)
             stream_data = stream_data["data"]
 
         result = {
             "status": status,
             "title": title,
             "stream_data": stream_data,
+            "paid_live_data": paid_live_data,
         }
         self.success_rate_of_get_live_info_by_web_enter.append(1)
         return result