Commit 332ec245 authored by 张彦钊's avatar 张彦钊

add print for test

parent cc3d2ba0
......@@ -13,6 +13,7 @@ from config import *
def test_con_sql(device_id):
db = pymysql.connect(host='rm-m5e842126ng59jrv6.mysql.rds.aliyuncs.com', port=3306, user='doris',
passwd='o5gbA27hXHHm', db='doris_prod')
print("连接成功")
cursor = db.cursor()
sql = "select native_queue,nearby_queue,nation_queue,megacity_queue from device_diary_queue " \
"where device_id = '{}';".format(device_id)
......@@ -172,7 +173,7 @@ def multi_update(key, name_dict):
if __name__ == "__main__":
warnings.filterwarnings("ignore")
# TODO 上线后把预测用户改成多进程预测
print(1)
device_id = "358035085192742"
native_queue_list, nearby_queue_list, nation_queue_list, megacity_queue_list = test_con_sql(device_id)
name_dict = {"native_queue": native_queue_list, "nearby_queue": nearby_queue_list,
......
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