|
@@ -19,7 +19,7 @@ def requirement_insight():
|
|
dt = (datetime.datetime.now() - datetime.timedelta(days=1)).strftime('%Y%m%d')
|
|
dt = (datetime.datetime.now() - datetime.timedelta(days=1)).strftime('%Y%m%d')
|
|
logger.info(f"视频需求点洞察")
|
|
logger.info(f"视频需求点洞察")
|
|
redis_task = "task:video_insight"
|
|
redis_task = "task:video_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 100'
|
|
|
|
|
|
+ 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 1000'
|
|
data = OdpsDataCount.main(sql)
|
|
data = OdpsDataCount.main(sql)
|
|
if not data:
|
|
if not data:
|
|
return
|
|
return
|