update logger

src/online_prediction.py

@@ -17,14 +17,20 @@ def consume_kafka(device_dict, diary_dict, tractate_dict, diary_predict_fn, trac
 
     consumer.subscribe(["gm-portrait-update-device"])
 
-    for msg in consumer:
-        data = json.loads(msg.value)
-        device_id = data.get("device_id", "")
-        if device_id == "androidid_a25a1129c0b38f7b":
-            print(device_id + " " + str(datetime.now()))
-            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")
+    try:
+        for msg in consumer:
+            data = json.loads(msg.value)
+            device_id = data.get("device_id", "")
+            log_time = datetime.fromtimestamp(data.get("log_time"))
+            event_cn = data.get("event_cn", "")
+
+            if device_id == "androidid_a25a1129c0b38f7b":
+                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")
+    except Exception as e:
+        print(e)
 
 
 if __name__ == "__main__":