改为先处理老数据

workers/consumption_work.py

@@ -22,7 +22,8 @@ class ConsumptionRecommend(object):
     async def run(cls):
         logger.info(f"[处理] 开始获取redis数据")
 
-        task = RedisHelper().get_client().rpop(name = 'task:video_ai_pq')
+        # task = RedisHelper().get_client().rpop(name = 'task:video_ai_pq')
+        task = RedisHelper().get_client().lpop(name = 'task:video_ai_pq')
 
         if not task:
             logger.info('[处理] 无待执行的扫描任务')