Commit 9148eded authored by 赵威's avatar 赵威

update logger

parent 0057192c
......@@ -25,7 +25,7 @@ def consume_kafka(device_dict, diary_dict, tractate_dict, diary_predict_fn, trac
event_cn = data.get("event_cn", "")
if device_id == "androidid_a25a1129c0b38f7b":
print(device_id + " " + str(log_time) + " " + event_cn
print(device_id + " " + str(log_time) + " " + event_cn)
offline_predict_diary(device_id, device_dict, diary_dict, diary_predict_fn)
offline_predict_tractate(device_id, device_dict, tractate_dict, tractate_predict_fn)
print("=========================================\n")
......
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