|
|
@@ -19,24 +19,27 @@ def update_bottom_videos():
|
|
|
now_date = datetime.datetime.today()
|
|
|
delta_date = now_date - datetime.timedelta(days=1)
|
|
|
|
|
|
- sql = "SELECT video_playcount.videoid, video_playcount.play_count " \
|
|
|
- "FROM (" \
|
|
|
- "SELECT videoid, COUNT(*) play_count " \
|
|
|
- "FROM loghubods.video_action_log_applet " \
|
|
|
- "WHERE dt = {} " \
|
|
|
- "AND business = 'videoPlay' " \
|
|
|
- "GROUP BY videoid" \
|
|
|
+ sql = "SELECT video_playcount.videoid " \
|
|
|
+ ",video_playcount.play_count " \
|
|
|
+ "FROM ( " \
|
|
|
+ "SELECT videoid " \
|
|
|
+ ",COUNT(*) play_count " \
|
|
|
+ "FROM loghubods.video_action_log_applet " \
|
|
|
+ "WHERE dt = {} " \
|
|
|
+ "AND business = 'videoPlay' " \
|
|
|
+ "GROUP BY videoid " \
|
|
|
") video_playcount INNER " \
|
|
|
- "JOIN ( " \
|
|
|
- "SELECT id " \
|
|
|
- "FROM videoods.wx_video " \
|
|
|
- "WHERE transcode_status = 3 " \
|
|
|
- "AND status = 1 " \
|
|
|
- "AND recommend_status IN ( - 6, 1)" \
|
|
|
+ "JOIN ( " \
|
|
|
+ "SELECT id " \
|
|
|
+ "FROM videoods.wx_video " \
|
|
|
+ "WHERE transcode_status = 3 " \
|
|
|
+ "AND status = 1 " \
|
|
|
+ "AND recommend_status IN ( - 6, 1) " \
|
|
|
") video_status " \
|
|
|
- "ON video_playcount.videoid = video_status.id " \
|
|
|
+ "ON video_playcount.videoid = video_status.id " \
|
|
|
"ORDER BY video_playcount.play_count DESC " \
|
|
|
- "LIMIT 1000;".format(delta_date.strftime('%Y%m%d'))
|
|
|
+ "LIMIT 1000 " \
|
|
|
+ ";".format(delta_date.strftime('%Y%m%d'))
|
|
|
|
|
|
records = execute_sql_from_odps(project='loghubods', sql=sql)
|
|
|
|
