|
|
@@ -1,6 +1,7 @@
|
|
|
import time
|
|
|
import json
|
|
|
import traceback
|
|
|
+import ast
|
|
|
from datetime import date, timedelta, datetime
|
|
|
|
|
|
from utils import filter_video_status, send_msg_to_feishu
|
|
|
@@ -27,11 +28,11 @@ def filter_position_videos():
|
|
|
continue
|
|
|
else:
|
|
|
# 过滤
|
|
|
- position_video_ids = [int(video_id) for video_id in json.loads(position_videos)]
|
|
|
+ position_video_ids = [int(video_id) for video_id in ast.literal_eval(position_videos)]
|
|
|
filter_video_ids = filter_video_status(video_ids=position_video_ids)
|
|
|
# 重新写入redis
|
|
|
redis_helper.set_data_to_redis(key_name=key_name,
|
|
|
- value=json.dumps(filter_video_ids),
|
|
|
+ value=str(filter_video_ids),
|
|
|
expire_time=30 * 3600)
|
|
|
log_.info('position {} videos filter end!'.format(position))
|
|
|
log_.info("position videos filter end!")
|
