Commit 3242889e authored by 张彦钊's avatar 张彦钊

add print

parent ff7715c4
...@@ -179,12 +179,12 @@ def update_dairy_queue(score_df): ...@@ -179,12 +179,12 @@ def update_dairy_queue(score_df):
for j in video_id: for j in video_id:
diary_id.insert(i, j) diary_id.insert(i, j)
i += 5 i += 5
print("排序成功1")
return diary_id return diary_id
else: else:
score_df = score_df.sort_values(by="score", ascending=False) score_df = score_df.sort_values(by="score", ascending=False)
print("排序成功2")
return score_df["cid"].values.tolist() return score_df["cid"].values.tolist()
...@@ -196,7 +196,6 @@ def update_sql_dairy_queue(queue_name, diary_id): ...@@ -196,7 +196,6 @@ def update_sql_dairy_queue(queue_name, diary_id):
## 去除diary_id 前面的"diary|" ## 去除diary_id 前面的"diary|"
diary_id = json.dumps(list(map(lambda x:x[6:],diary_id))) diary_id = json.dumps(list(map(lambda x:x[6:],diary_id)))
sql = "update device_diary_queue set {}='{}' where device_id = '{}'".format(queue_name, diary_id, device_id) sql = "update device_diary_queue set {}='{}' where device_id = '{}'".format(queue_name, diary_id, device_id)
print(sql)
cursor.execute(sql) cursor.execute(sql)
db.close() db.close()
print("成功写入") print("成功写入")
......
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