liqian преди 3 години
родител
ревизия
e1ffadf684
променени са 1 файла, в които са добавени 2 реда и са изтрити 6 реда
  1. 2 6
      pool_predict.py

+ 2 - 6
pool_predict.py

@@ -212,12 +212,8 @@ def predict_19(app_type):
     sql_create_time = datetime.datetime.strftime(now - datetime.timedelta(days=30), '%Y-%m-%d %H:%M:%S')
     if sql_create_time < '2022-04-22 16:40:00':
         sql_create_time = '2022-04-22 16:40:00'
-    sql = f"SELECT video_id, create_time FROM videoods.movie_store_video_allow_list " \
-          f"WHERE allow_list_type=0 AND " \
-          f"video_id NOT IN (" \
-          f"SELECT video_id FROM videoods.movie_store_video_allow_list WHERE allow_list_type=1" \
-          f") AND " \
-          f"create_time>='{sql_create_time}'" \
+    sql = f"SELECT video_id, create_time FROM videoods.movie_store_video_allow_list_final " \
+          f"WHERE create_time>='{sql_create_time}'" \
           f"ORDER BY create_time DESC;"
     data_df = get_data_from_odps(project='videoods', sql=sql)