add print

diaryUpdateOnlineOffline.py

@@ -219,11 +219,12 @@ def get_queue(device_id, city_id,queue_name):
     else:
         db = pymysql.connect(host=LOCAL_HOST, port=3306, user='work',
                              passwd='workwork', db='doris_test')
-
+    print(1)
     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(2)
     result = cursor.fetchall()
     df = pd.DataFrame(list(result))
     print("multi")
@@ -253,6 +254,7 @@ def pipe_line(queue_name, queue_arg, device_id,total_video_id):
 
 
 def user_update(device_id, city_id, queue_name,data_set_cid,total_video_id):
+    print(0)
     queue_list = get_queue(device_id, city_id, queue_name)
     if queue_list:
         queue_predict = list(set(queue_list) & set(data_set_cid))