|
|
@@ -19,7 +19,7 @@ def reset_videos_to_radies(day=3):
|
|
|
dt = (datetime.datetime.now() - datetime.timedelta(days=day)).strftime('%Y%m%d')
|
|
|
logger.info(f"重置视频到Redis")
|
|
|
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 1300'
|
|
|
+ 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 700 offset 1299'
|
|
|
data = OdpsDataCount.main(sql)
|
|
|
if not data:
|
|
|
return
|
