update

task/portary_article_distribution.py

@@ -130,28 +130,28 @@ for res in user_portrait_scan:
         bulk_dict[1000][2] += 1
 
     print(bulk_dict)
-#     for active_type in res_dict:
-#         for device_os_type in res_dict[active_type]:
-#             partition_date = yesterday_str
-#             pid = hashlib.md5((partition_date + device_os_type + active_type).encode("utf8")).hexdigest()
-#             click_num = res_dict[active_type][device_os_type]["click_num"]
-#             exposure = res_dict[active_type][device_os_type]["exposure"]
-#             try:
-#                 search_ctr = round(click_num / exposure, 5)
-#             except:
-#                 search_ctr = 0
-#             instert_sql = """replace into search_tractate_ctr(
-#             partition_date,device_os_type,active_type,pid,click_num,exposure,search_ctr) VALUES('{partition_date}','{device_os_type}','{active_type}','{pid}',{click_num},{exposure},{search_ctr});""".format(
-#                 partition_date=partition_date, device_os_type=device_os_type, active_type=active_type, pid=pid, click_num=click_num,
-#                 exposure=exposure, search_ctr=search_ctr
-#             )
-#             print(instert_sql)
-#             # cursor.execute("set names 'UTF8'")
-#             db = pymysql.connect(host='172.16.40.158', port=4000, user='st_user', passwd='aqpuBLYzEV7tML5RPsN1pntUzFy',
-#                                  db='jerry_prod')
-#             cursor = db.cursor()
-#             res = cursor.execute(instert_sql)
-#             db.commit()
-#             print(res)
-# # cursor.executemany()
-# db.close()
+
+for page_type in range(3):
+    if page_type == 0:
+        page_type_str = "回答"
+    elif page_type == 1:
+        page_type_str = "帖子"
+    else:
+        page_type_str = "日记"
+    pid = str(page_type)
+    instert_sql = """replace into portary_article_distribution(
+    page_type,C0,C10,C50,C100,C200,C500,C1000,pid) VALUES('{page_type_str}',{C0},{C10},{C50},{C100},{C200},{C500},{C1000},'{pid}');""".format(
+        page_type_str=page_type_str,C0=bulk_dict[0][page_type],C10=bulk_dict[10][page_type],C50=bulk_dict[50][page_type],
+        C100=bulk_dict[100][page_type],C200=bulk_dict[200][page_type],C500=bulk_dict[500][page_type],
+        C1000=bulk_dict[1000][page_type],pid=pid
+    )
+    print(instert_sql)
+    # cursor.execute("set names 'UTF8'")
+    db = pymysql.connect(host='172.16.40.158', port=4000, user='st_user', passwd='aqpuBLYzEV7tML5RPsN1pntUzFy',
+                         db='jerry_prod')
+    cursor = db.cursor()
+    res = cursor.execute(instert_sql)
+    db.commit()
+    print(res)
+# cursor.executemany()
+db.close()