flowpool

flowpool_data_update_with_level_score_v2.py

@@ -1,6 +1,7 @@
 import time
 import traceback
 import json
+import uuid
 
 from my_config import set_config
 from my_utils import request_post, filter_video_status, send_msg_to_feishu, filter_video_status_app, \
@@ -21,7 +22,9 @@ def get_videos_from_flow_pool(app_type, size=1000):
     :return: videos  [{'videoId': 1111, 'flowPool': ''}, ...]
     """
     # 获取批次标识，利用首次获取数据时间戳为标记
-    batch_flag = int(time.time_ns())
+    batch_flag = uuid.uuid4()
+    log_.info(f"batch_flag: {batch_flag}")
+
     request_data = {'appType': app_type, 'batchFlag': batch_flag, 'size': size}
     videos = []
     retry = 0

flowpool_data_update_with_level_supply_v2.py

@@ -1,6 +1,7 @@
 import time
 import traceback
 import json
+import uuid
 
 from my_config import set_config
 from my_utils import request_post, filter_video_status, send_msg_to_feishu, filter_video_status_app, \
@@ -22,7 +23,9 @@ def get_videos_from_flow_pool(app_type, size=1000):
     :return: videos  [{'videoId': 1111, 'flowPool': ''}, ...]
     """
     # 获取批次标识，利用首次获取数据时间戳为标记
-    batch_flag = int(time.time_ns())
+    batch_flag = uuid.uuid4()
+    log_.info(f"batch_flag: {batch_flag}")
+
     request_data = {'appType': app_type, 'batchFlag': batch_flag, 'size': size, 'isSupply': 1}
     videos = []
     retry = 0

flowpool_data_update_with_level_v2.py

@@ -1,6 +1,7 @@
 import time
 import traceback
 import json
+import uuid
 
 from my_config import set_config
 from my_utils import request_post, filter_video_status, send_msg_to_feishu, filter_video_status_app, \
@@ -21,7 +22,8 @@ def get_videos_from_flow_pool(app_type, size=1000):
     :return: videos  [{'videoId': 1111, 'flowPool': ''}, ...]
     """
     # 获取批次标识，利用首次获取数据时间戳为标记
-    batch_flag = int(time.time_ns())
+    batch_flag = uuid.uuid4()
+    log_.info(f"batch_flag: {batch_flag}")
     request_data = {'appType': app_type, 'batchFlag': batch_flag, 'size': size}
     videos = []
     retry = 0