Skip to content

G
gm_strategy_cvr
Commit f1be9d19 authored by 赵威's avatar 赵威
Browse files
Options

add printer

parent ee3d67bd
Show whitespace changes
Inline Side-by-side
Showing with 5 additions and 7 deletions
src/online_prediction.py
View file @ f1be9d19
...@@ -21,17 +21,15 @@ def consume_kafka(device_dict, diary_dict, tractate_dict, diary_predict_fn, trac ...@@ -21,17 +21,15 @@ def consume_kafka(device_dict, diary_dict, tractate_dict, diary_predict_fn, trac
for msg in consumer: for msg in consumer:
data = json.loads(msg.value) data = json.loads(msg.value)
device_id = data.get("device_id", "") device_id = data.get("device_id", "")
event_cn = data.get("event_cn", "")
log_time = ""
try: try:
log_time = data.get("log_time") log_time = datetime.fromtimestamp(int(data.get("log_time")))
print(log_time)
print(type(log_time))
log_time = datetime.fromtimestamp(int(log_time))
except: except:
pass print("!!!!! " + device_id + " " + event_cn)
event_cn = data.get("event_cn", "")
if device_id == "androidid_a25a1129c0b38f7b": if device_id == "androidid_a25a1129c0b38f7b":
print(device_id + " " + event_cn) print(device_id + " " + event_cn + " " + log_time)
offline_predict_diary(device_id, device_dict, diary_dict, diary_predict_fn) offline_predict_diary(device_id, device_dict, diary_dict, diary_predict_fn)
offline_predict_tractate(device_id, device_dict, tractate_dict, tractate_predict_fn) offline_predict_tractate(device_id, device_dict, tractate_dict, tractate_predict_fn)
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