|
|
@@ -20,7 +20,7 @@ def requirement_insight():
|
|
|
logger.info(f"视频需求点洞察")
|
|
|
# redis_task = "task:video_insight"
|
|
|
redis_trigger_task = "task:video_trigger_insight"
|
|
|
- sql =f'select clickobjectid as video_id from loghubods.user_share_log where dt = {dt} and topic = "click" group by clickobjectid order by count(distinct machinecode) desc limit 600'
|
|
|
+ sql =f'select clickobjectid as video_id from loghubods.user_share_log where dt = {dt} and topic = "click" group by clickobjectid order by count(distinct machinecode) desc limit 900'
|
|
|
data = OdpsDataCount.main(sql)
|
|
|
if not data:
|
|
|
return
|
|
|
@@ -31,7 +31,7 @@ def requirement_insight():
|
|
|
logger.error(f"[R] 写入Redis写入失败，失败信息{e}")
|
|
|
|
|
|
def schedule_tasks():
|
|
|
- schedule.every().day.at("15:15").do(requirement_insight)
|
|
|
+ schedule.every().day.at("01:00").do(requirement_insight)
|
|
|
|
|
|
|
|
|
if __name__ == "__main__":
|
