add print

config.py

@@ -28,6 +28,7 @@ QUEUE_ONLINE_HOST = 'rm-m5e842126ng59jrv6.mysql.rds.aliyuncs.com'
 # db = pymysql.connect(host='rm-m5e842126ng59jrv6.mysql.rds.aliyuncs.com', port=3306, user='doris',passwd='o5gbA27hXHHm',
 #                              db='doris_prod')
 
+
 # 本地日记队列域名
 LOCAL_HOST = 'rdsmaqevmuzj6jy.mysql.rds.aliyuncs.com'
 

diaryUpdateOnlineOffline.py

@@ -215,16 +215,13 @@ def queue_compare(old_list, new_list):
 
 
 def get_queue(device_id, city_id,queue_name):
-    print(1)
     if flag:
-        print('db')
         db = pymysql.connect(host=QUEUE_ONLINE_HOST, port=3306, user='doris',passwd='o5gbA27hXHHm',
                              db='doris_prod')
-        print(10)
     else:
         db = pymysql.connect(host=LOCAL_HOST, port=3306, user='work',
                              passwd='workwork', db='doris_test')
-        print(db)
+
     cursor = db.cursor()
     sql = "select {} from device_diary_queue " \
           "where device_id = '{}' and city_id = '{}';".format(queue_name,device_id, city_id)
@@ -232,7 +229,7 @@ def get_queue(device_id, city_id,queue_name):
 
     result = cursor.fetchall()
     df = pd.DataFrame(list(result))
-    print("multi")
+
     if df.empty:
         print("该用户对应的日记为空")
         return False
@@ -281,7 +278,7 @@ def user_update(device_id, city_id, queue_name,data_set_cid,total_video_id):
 def multi_proecess_update(device_id, city_id, data_set_cid,total_video_id):
     queue_name_list = ["native_queue","nearby_queue","nation_queue","megacity_queue"]
 
-    pool = Pool(1)
+    pool = Pool(4)
     for queue_name in queue_name_list:
         pool.apply_async(user_update, (device_id, city_id, queue_name,data_set_cid,total_video_id,))
     pool.close()