add print

config.py

@@ -24,9 +24,6 @@ LOCAL_DIRCTORY = "/Users/mac/utils/"
 # 线上日记队列域名
 QUEUE_ONLINE_HOST = 'rm-m5e842126ng59jrv6.mysql.rds.aliyuncs.com'
 
-# import pymysql
-# db = pymysql.connect(host='rm-m5e842126ng59jrv6.mysql.rds.aliyuncs.com', port=3306, user='doris',passwd='o5gbA27hXHHm',
-#                              db='doris_prod')
 
 
 # 本地日记队列域名

diaryUpdateOnlineOffline.py

@@ -179,7 +179,7 @@ def update_sql_dairy_queue(queue_name, diary_id,device_id, city_id):
                              db='doris_prod')
     else:
         db = pymysql.connect(host=LOCAL_HOST, port=3306, user='work',passwd='workwork', db='doris_test')
-
+    print("bd")
     cursor = db.cursor()
     id_str = str(diary_id[0])
     for i in range(1, len(diary_id)):
@@ -188,7 +188,9 @@ def update_sql_dairy_queue(queue_name, diary_id,device_id, city_id):
     sql = "update device_diary_queue set {}='{}' where device_id = '{}' and city_id = '{}'".format\
         (queue_name,id_str,device_id, city_id)
     cursor.execute(sql)
+    print("1bd")
     db.commit()
+    print("2bd")
     db.close()
     print("成功写入diary_id")
 
@@ -216,23 +218,18 @@ def queue_compare(old_list, new_list):
 
 def get_queue(device_id, city_id,queue_name):
     if flag:
-        print("db")
         db = pymysql.connect(host=QUEUE_ONLINE_HOST, port=3306, user='doris',passwd='o5gbA27hXHHm',
                              db='doris_prod')
-        print(db)
 
     else:
         db = pymysql.connect(host=LOCAL_HOST, port=3306, user='work',
                              passwd='workwork', db='doris_test')
-
     cursor = db.cursor()
     sql = "select {} from device_diary_queue " \
           "where device_id = '{}' and city_id = '{}';".format(queue_name,device_id, city_id)
     cursor.execute(sql)
-    print("cursor")
     result = cursor.fetchall()
     df = pd.DataFrame(list(result))
-
     if df.empty:
         print("该用户对应的日记为空")
         return False