update

new_user_analysis/user_behavior_path.py

@@ -99,7 +99,7 @@ for t in range(1, task_days):
     yesterday_str_format = (now + datetime.timedelta(days=-1)).strftime("%Y-%m-%d")
     one_week_age_str = (now + datetime.timedelta(days=-7)).strftime("%Y%m%d")
     new_urser_device_id_sql = r"""
-    select t2.device_id from 
+    select t2.device_id as total_new_user 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
     LEFT JOIN
     (
@@ -179,6 +179,7 @@ WHERE spam_pv.device_id IS NULL
     for count,res in enumerate(sql_res):
         print(count,res)
 
+    res_dict = {}
     maidian_sql = """select t1.device_id,t2.track from 
     (select device_id from device_id_view)t1 
     left join 
@@ -193,4 +194,12 @@ on t1.device_id = t2.cl_id""".format(partition_date=yesterday_str)
 
     print("-------------------------------")
     for count, res in enumerate(sql_res):
-        print(count, res)
+        # print(count, res)
+        track = res.track
+        track_list = track.split(",")
+        for one_key_word in track_list:
+            if one_key_word in res_dict:
+                res_dict[one_key_word] += 1
+            else:
+                res_dict[one_key_word] = 1
+    print(res_dict)