Commit eb56b3d2 authored by 赵威's avatar 赵威

update logger

parent 124b439d
...@@ -27,7 +27,7 @@ def consume_kafka(device_dict, diary_dict, tractate_dict, diary_predict_fn, trac ...@@ -27,7 +27,7 @@ def consume_kafka(device_dict, diary_dict, tractate_dict, diary_predict_fn, trac
log_time = str(datetime.fromtimestamp(int(data.get("log_time", 1)))) log_time = str(datetime.fromtimestamp(int(data.get("log_time", 1))))
event_cn = data.get("event_cn", "") event_cn = data.get("event_cn", "")
# if device_id == "androidid_a25a1129c0b38f7b": # if device_id == "androidid_a25a1129c0b38f7b":
print(device_id + " " + event_cn + " " + log_time) print(device_id + " " + log_time + " " + event_cn + " " + str(datetime.now()))
offline_predict_diary(device_id, device_dict, diary_dict, diary_predict_fn, size=300) offline_predict_diary(device_id, device_dict, diary_dict, diary_predict_fn, size=300)
offline_predict_tractate(device_id, device_dict, tractate_dict, tractate_predict_fn, size=300) offline_predict_tractate(device_id, device_dict, tractate_dict, tractate_predict_fn, size=300)
print("=========================================\n") 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