update

task/portary_article_distribution.py

@@ -130,8 +130,9 @@ for redis_count,res in enumerate(user_portrait_scan):
     else:
         bulk_dict[1000][2] += 1
 
-    print(bulk_dict)
-    if redis_count % 500 == 0:
+    # print(bulk_dict)
+    if redis_count % 5000 == 0:
+        print(redis_count)
         for page_type in range(3):
             if page_type == 0:
                 page_type_str = "回答"
@@ -146,7 +147,7 @@ for redis_count,res in enumerate(user_portrait_scan):
                     page_type_str=page_type_str, pid=pid, num_type=str(count_num),
                     num_value=bulk_dict[count_num][page_type]
                 )
-                print(instert_sql)
+                # print(instert_sql)
                 # cursor.execute("set names 'UTF8'")
                 db = pymysql.connect(host='172.16.40.158', port=4000, user='st_user',
                                      passwd='aqpuBLYzEV7tML5RPsN1pntUzFy',
@@ -154,7 +155,7 @@ for redis_count,res in enumerate(user_portrait_scan):
                 cursor = db.cursor()
                 res = cursor.execute(instert_sql)
                 db.commit()
-                print(res)
+                # print(res)
 
 
 for page_type in range(3):