Commit 0f05cbd8 authored by 张彦钊's avatar 张彦钊

change sql for test

parent 13d9c3eb
......@@ -216,12 +216,12 @@ def update_sql_dairy_queue(queue_name, diary_id):
passwd='o5gbA27hXHHm', db='doris_prod')
cursor = db.cursor()
## 去除diary_id 前面的"diary|"
diary_id = json.dumps(list(map(lambda x:x[6:],diary_id)))[:6]
diary_id = json.dumps(list(map(lambda x:x[6:],diary_id)))
print("写入前")
print(diary_id)
sql = "update device_diary_queue set {}='{}' where device_id = '{}'".format(queue_name, diary_id, device_id)
cursor.execute(sql)
db.close()
# sql = "update device_diary_queue set {}='{}' where device_id = '{}'".format(queue_name, diary_id, device_id)
# cursor.execute(sql)
# db.close()
print("成功写入diaryid")
......
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