add print

diaryQueueUpdate.py

@@ -9,7 +9,7 @@ import warnings
 from multiprocessing import Pool
 from config import *
 import time
-
+import json
 
 def test_con_sql(device_id):
     db = pymysql.connect(host='rm-m5e842126ng59jrv6.mysql.rds.aliyuncs.com', port=3306, user='doris',
@@ -194,7 +194,7 @@ def update_sql_dairy_queue(queue_name, diary_id):
                          passwd='o5gbA27hXHHm', db='doris_prod')
     cursor = db.cursor()
     ## 去除diary_id 前面的"diary|"
-    diary_id = tuple(list(map(lambda x:x[6:],diary_id)))
+    diary_id = json.dumps(list(map(lambda x:x[6:],diary_id)))
     sql = "update device_diary_queue set {}='{}' where device_id = '{}'".format(queue_name, diary_id, device_id)
     print(sql)
     cursor.execute(sql)