Skip to content

F
ffm-baseline
Commit b2aa20b7 authored by 张彦钊's avatar 张彦钊
Browse files
Options

delete print

parent 51439953
Show whitespace changes
Inline Side-by-side
Showing with 0 additions and 3 deletions
diaryUpdateOnlineOffline.py
View file @ b2aa20b7
...@@ -180,7 +180,6 @@ def update_sql_dairy_queue(queue_name, diary_id,device_id, city_id): ...@@ -180,7 +180,6 @@ def update_sql_dairy_queue(queue_name, diary_id,device_id, city_id):
db='doris_prod') db='doris_prod')
else: else:
db = pymysql.connect(host=LOCAL_HOST, port=3306, user='work',passwd='workwork', db='doris_test') db = pymysql.connect(host=LOCAL_HOST, port=3306, user='work',passwd='workwork', db='doris_test')
print("bd")
cursor = db.cursor() cursor = db.cursor()
id_str = str(diary_id[0]) id_str = str(diary_id[0])
for i in range(1, len(diary_id)): for i in range(1, len(diary_id)):
...@@ -189,9 +188,7 @@ def update_sql_dairy_queue(queue_name, diary_id,device_id, city_id): ...@@ -189,9 +188,7 @@ 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\ sql = "update device_diary_queue set {}='{}' where device_id = '{}' and city_id = '{}'".format\
(queue_name,id_str,device_id, city_id) (queue_name,id_str,device_id, city_id)
cursor.execute(sql) cursor.execute(sql)
print("1bd")
db.commit() db.commit()
print("2bd")
db.close() db.close()
over = time.time() over = time.time()
print("写入日记队列耗时{}秒".format(over-begin)) print("写入日记队列耗时{}秒".format(over-begin))
......
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