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

update dairyQueueUpdate file

parent 70d54159
......@@ -239,6 +239,13 @@ def user_update(device_id,city_id,data_set_cid):
queue_arg = [queue_predict,queue_not_predict,queue_list]
if queue_predict != []:
diary_queue = pipe_line(queue_name, queue_arg, device_id)
print("diaryqu")
print(diary_queue[:30])
print("native_queue_list")
print(native_queue_list[:30])
print("get_native_queue")
print(get_native_queue(device_id, city_id)[:30])
if diary_queue and (native_queue_list == get_native_queue(device_id, city_id)):
update_sql_dairy_queue(queue_name, diary_queue, device_id, city_id)
print("更新结束")
......@@ -254,7 +261,7 @@ def run(data_set_cid):
# TODO 如果测刘潇的没问题,去掉下面代码的注释
# device_city_list = get_active_users()
# TODO 先测一下高雅喆的,如果没问题,然后再测刘潇的
device_city_list = (("358035085192742", "beijing"),)
device_city_list = (("AB20292B-5D15-4C44-9429-1C2FF5ED26F6", "beijing"),)
# TODO 测试通过后加上计时
start = time.time()
for device_city in device_city_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