Commit 32244021 authored by 张彦钊's avatar 张彦钊

add print

parent 9faad0f0
...@@ -193,10 +193,10 @@ def update_sql_dairy_queue(queue_name, diary_id): ...@@ -193,10 +193,10 @@ def update_sql_dairy_queue(queue_name, diary_id):
db = pymysql.connect(host='rm-m5e842126ng59jrv6.mysql.rds.aliyuncs.com', port=3306, user='doris', db = pymysql.connect(host='rm-m5e842126ng59jrv6.mysql.rds.aliyuncs.com', port=3306, user='doris',
passwd='o5gbA27hXHHm', db='doris_prod') passwd='o5gbA27hXHHm', db='doris_prod')
cursor = db.cursor() cursor = db.cursor()
print("写入连接成功")
## 去除diary_id 前面的"diary|" ## 去除diary_id 前面的"diary|"
diary_id = tuple(list(map(lambda x:x[6:],diary_id))) diary_id = tuple(list(map(lambda x:x[6:],diary_id)))
sql = "update device_diary_queue set {}='{}' where device_id = '{}'".format(queue_name, diary_id, device_id) sql = "update device_diary_queue set {}='{}' where device_id = '{}'".format(queue_name, diary_id, device_id)
print(sql)
cursor.execute(sql) cursor.execute(sql)
db.close() db.close()
print("成功写入") print("成功写入")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment