新系统-发布之后获取 video_id,

再重新获取 share_img_path

todo: 批量修改已有数据

tasks/history_task.py

@@ -7,7 +7,7 @@ import asyncio
 
 from applications.config import Config
 from applications.log import logging
-from applications.functions.pqFunctions import publish_to_pq
+from applications.functions.pqFunctions import publish_to_pq, get_pq_video_detail
 from applications.functions.common import shuffle_list
 
 
@@ -172,7 +172,9 @@ class historyContentIdTask(object):
                 "uid": video_obj['uid'],
                 "title": kimi_title
             }
-            response = await publish_to_pq(params)
+            publish_response = await publish_to_pq(params)
+            video_id = publish_response['data']['id']
+            response = await get_pq_video_detail(video_id)
             # time.sleep(2)
             obj = {
                 "uid": video_obj['uid'],

tasks/newContentIdTask.py

@@ -8,7 +8,7 @@ import asyncio
 
 from applications.config import Config
 from applications.log import logging
-from applications.functions.pqFunctions import publish_to_pq
+from applications.functions.pqFunctions import publish_to_pq, get_pq_video_detail
 from applications.functions.common import shuffle_list
 from applications.functions.kimi import KimiServer
 from applications.spider import search_videos_from_web
@@ -614,8 +614,9 @@ class NewContentIdTask(object):
                     "uid": video_obj['uid'],
                     "title": kimi_title
                 }
-                response = await publish_to_pq(params)
-                # time.sleep(2)
+                publish_response = await publish_to_pq(params)
+                video_id = publish_response['data']['id']
+                response = await get_pq_video_detail(video_id)
                 obj = {
                     "uid": video_obj['uid'],
                     "source": video_obj['platform'],