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

add print

parent eff4085f
......@@ -216,8 +216,11 @@ def queue_compare(old_list, new_list):
def get_queue(device_id, city_id,queue_name):
if flag:
print("db")
db = pymysql.connect(host=QUEUE_ONLINE_HOST, port=3306, user='doris',passwd='o5gbA27hXHHm',
db='doris_prod')
print(db)
else:
db = pymysql.connect(host=LOCAL_HOST, port=3306, user='work',
passwd='workwork', db='doris_test')
......@@ -226,7 +229,7 @@ def get_queue(device_id, city_id,queue_name):
sql = "select {} from device_diary_queue " \
"where device_id = '{}' and city_id = '{}';".format(queue_name,device_id, city_id)
cursor.execute(sql)
print("cursor")
result = cursor.fetchall()
df = pd.DataFrame(list(result))
......
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