update

new_user_analysis/new_user_has_protratit_rate.py

@@ -105,7 +105,7 @@ for t in range(1, task_days):
     one_week_age_str = (now + datetime.timedelta(days=-7)).strftime("%Y%m%d")
     new_urser_device_id_sql = r"""
     select t2.device_id as device_id from 
-    (select first_device as device_id from online.ml_user_history_detail where partition_date = '{today_str}' and date_joined >= '{yesterday_str_format}' and date_joined <= '{today_str_format}') t2
+    (select device_id from online.ml_device_day_active_status where partition_date = '${today_str}' and active_type in (1,2)) t2
     LEFT JOIN
     (
         select distinct device_id
@@ -195,6 +195,8 @@ WHERE spam_pv.device_id IS NULL
     for count_user_count, res in enumerate(sql_res):
         # print(count, res)
         portratit_res = get_user_portrait_tag3_from_redis(res.device_id)
+        portratit_res
+
         # print(count_user_count, res, portratit_res)
         temp_count = 0
         for demand in portratit_res:

new_user_analysis/user_behavior_path.py

@@ -870,7 +870,7 @@ for t in range(1, task_days):
     one_week_age_str = (now + datetime.timedelta(days=-7)).strftime("%Y%m%d")
     new_urser_device_id_sql = r"""
     select t2.device_id as device_id from 
-    (select first_device as device_id from online.ml_user_history_detail where partition_date = '{today_str}' and date_joined >= '{yesterday_str_format}' and date_joined <= '{today_str_format}') t2
+    (select device_id from online.ml_device_day_active_status where partition_date = '${today_str}' and active_type in (1,2)) t2
     LEFT JOIN
     (
         select distinct device_id