修改统计指标

ctr-56.py

@@ -34,23 +34,13 @@ def ctr_all():
     result = cursor.fetchall()
     tail56 = pd.DataFrame(list(result))[0].values.tolist()
 
-    start = "2018-09-05"
-    sql_all = "select distinct device_id from data_feed_click " \
-              "where stat_date >= '{}' and stat_date <= '{}' and cid_type = 'diary'".format(start, date)
-    cursor.execute(sql_all)
-    result_all = cursor.fetchall()
-    df = pd.DataFrame(list(result_all))
-    all_user = df[0].values.tolist()
-    print("老用户总数：")
-    print(len(all_user))
-    day_all = set(all_user) & set(tail56)
-    print("当天老用户总数：")
-    print(len(day_all))
-    cover = len(day_all & set(device_id))
+    print("当天尾号5或6活跃用户总数：")
+    print(len(tail56))
 
+    cover = len(set(tail56)&set(device_id))
     print("当天尾号5或6活跃用户覆盖数：")
     print(cover)
-    cover_percent = format(cover / len(day_all), ".3f")
+    cover_percent = format(cover / len(tail56), ".3f")
     print("当天尾号5或6活跃用户覆盖率：")
     print(cover_percent)
     sql_click = "select count(cid) from data_feed_click " \
@@ -66,7 +56,7 @@ def ctr_all():
     exp = cursor.fetchone()[0]
     print("曝光数：" + str(exp))
     print("点击率：" + str(click / exp))
-    return len(day_all),cover,cover_percent,click,exp,format(click/exp,".6f")
+    return len(tail56),cover,cover_percent,click,exp,format(click/exp,".6f")
 
 
 def ctr():

local/test_supervisor.py

@@ -196,6 +196,7 @@ def router(device_id):
         predict(user_profile)
 
 if __name__ == "__main__":
+    sql = "delete from data_feed_click where stat_date = '2018-10-17'"
     while True:
         start = time.time()
         empty,device_id_list = get_active_users()