update

workers/consumption_work.py

@@ -6,7 +6,7 @@ from datetime import datetime
 
 import orjson
 from apscheduler.schedulers.asyncio import AsyncIOScheduler
-from apscheduler.triggers.cron import CronTrigger
+from apscheduler.triggers.interval import IntervalTrigger
 from loguru import logger
 sys.path.append('/app')
 from utils.feishu_utils import Feishu
@@ -75,7 +75,7 @@ async def run():
     scheduler = AsyncIOScheduler()
     try:
         logger.info(f"[处理] 开始启动")
-        scheduler.add_job(ConsumptionRecommend.run, trigger=CronTrigger(minute=2, second=0))  # 每小时获取一次
+        scheduler.add_job(ConsumptionRecommend.run, trigger=IntervalTrigger(minutes=2))  # 每2分钟启动一次
         scheduler.start()
         await asyncio.Event().wait()
     except KeyboardInterrupt:

workers/select_work.py

@@ -16,7 +16,7 @@ from utils.redis import RedisHelper
 class StartGetRecommend(object):
     @classmethod
     async def run(cls):
-        dt = (datetime.datetime.now() - datetime.timedelta(hours=2)).strftime('%Y%m%d%H') # 获取前一小时
+        dt = (datetime.datetime.now() - datetime.timedelta(hours=1)).strftime('%Y%m%d%H') # 获取前一小时
         tasks = OdpsDataCount.get_data_count(dt)
         logger.info(f"[获取] {dt}时间，共获取到{len(tasks)} 条")
         if len(tasks) > 0:
@@ -39,7 +39,7 @@ class StartGetRecommend(object):
 async def run():
     scheduler = AsyncIOScheduler()
     try:
-        scheduler.add_job(StartGetRecommend.run, trigger=CronTrigger(hour=1, second=0))  # 每小时获取一次
+        scheduler.add_job(StartGetRecommend.run, trigger=CronTrigger(minute=50, second=0))  # 每小时获取一次
         scheduler.start()
         await asyncio.Event().wait()
     except KeyboardInterrupt: