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

add print

parent fc55a89a
......@@ -226,7 +226,7 @@ def get_queue(device_id, city_id,queue_name):
cursor.execute(sql)
result = cursor.fetchall()
df = pd.DataFrame(list(result))
print("multi")
if df.empty:
print("该用户对应的日记为空")
return False
......@@ -274,7 +274,7 @@ def user_update(device_id, city_id, queue_name,data_set_cid,total_video_id):
def multi_proecess_update(device_id, city_id, data_set_cid,total_video_id):
queue_name_list = ["native_queue","nearby_queue","nation_queue","megacity_queue"]
print("multi")
pool = Pool(4)
for queue_name in queue_name_list:
pool.apply_async(user_update, (device_id, city_id, queue_name,data_set_cid,total_video_id,))
......
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