Commit 7932dfa8 authored by 张彦钊's avatar 张彦钊

add print

parent 50d76988
...@@ -123,8 +123,8 @@ def save_result(queue_name, x_list): ...@@ -123,8 +123,8 @@ def save_result(queue_name, x_list):
mm_scaler = MinMaxScaler() mm_scaler = MinMaxScaler()
mm_scaler.fit(score_df) mm_scaler.fit(score_df)
score_df = pd.DataFrame(mm_scaler.transform(score_df)) score_df = pd.DataFrame(mm_scaler.transform(score_df))
# print("概率前十行:") print("概率前十行:")
# print(score_df) print(score_df)
score_df = score_df.rename(columns={0: "score"}) score_df = score_df.rename(columns={0: "score"})
score_df["cid"] = x_list score_df["cid"] = x_list
...@@ -146,15 +146,15 @@ def merge_score(x_list, score_df): ...@@ -146,15 +146,15 @@ def merge_score(x_list, score_df):
cursor.execute(sql) cursor.execute(sql)
result = cursor.fetchall() result = cursor.fetchall()
score = pd.DataFrame(list(result)) score = pd.DataFrame(list(result))
# print("数据库日记表前十行") print("数据库日记表前十行")
# print(score) print(score)
score_list = score[0].values.tolist() score_list = score[0].values.tolist()
db.close() db.close()
score_df["score"] = score_df["score"] + score_list score_df["score"] = score_df["score"] + score_list
# print("sum") print("sum")
# print(score_df) print(score_df)
return score_df return score_df
...@@ -209,7 +209,7 @@ def multi_update(key, name_dict): ...@@ -209,7 +209,7 @@ def multi_update(key, name_dict):
if get_native_queue(device_id) == native_queue_list: if get_native_queue(device_id) == native_queue_list:
update_sql_dairy_queue(key, diary_id) update_sql_dairy_queue(key, diary_id)
# print("更新结束") print("更新结束")
else: else:
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