计算ctr

ctr.py

@@ -19,7 +19,7 @@ print(pre_list[:2])
 stat_date = "2018-09-02"
 cid_type = "diary"
 db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
-sql = "select count(device_id) from data_feed_click2 \
+sql = "select distinct device_id from data_feed_click2 \
       where stat_date='{}' \
       and cid_type='{}' \
       and device_id in {}".format(stat_date,cid_type,pre_list)
@@ -27,16 +27,32 @@ cursor = db.cursor()
 print("开始获取")
 cursor.execute(sql)
 print("成功获取")
+result = cursor.fetchall()
+user = pd.DataFrame(list(result))[0].values.tolist()
+user = tuple(user)
+print("用户个数")
+print(len(user))
+
+sql = "select count(device_id) from data_feed_click2 \
+      where stat_date='{}' \
+      and cid_type='{}' \
+      and device_id in {}".format(stat_date,cid_type,user)
+cursor = db.cursor()
+print("开始获取")
+cursor.execute(sql)
 click = cursor.fetchall()[0][0]
 print(click)
 
 sql = "select count(device_id) from data_feed_exposure2 \
       where stat_date='{}' \
       and cid_type='{}' \
-      and device_id in {}".format(stat_date,cid_type,pre_list)
+      and device_id in {}".format(stat_date,cid_type,user)
 cursor = db.cursor()
 print("开始获取")
 cursor.execute(sql)
 exp = cursor.fetchall()[0][0]
 print(exp)
 print(click/exp)
+
+
+