try get time

src/online_prediction.py

@@ -21,14 +21,17 @@ def consume_kafka(device_dict, diary_dict, tractate_dict, diary_predict_fn, trac
         for msg in consumer:
             data = json.loads(msg.value)
             device_id = data.get("device_id", "")
-            log_time = data.get("log_time")
-            print(log_time)
-            print(type(log_time))
-            log_time = datetime.fromtimestamp(int(log_time))
+            try:
+                log_time = data.get("log_time")
+                print(log_time)
+                print(type(log_time))
+                log_time = datetime.fromtimestamp(int(log_time))
+            except:
+                pass
             event_cn = data.get("event_cn", "")
 
             if device_id == "androidid_a25a1129c0b38f7b":
-                print(device_id + " " + str(log_time) + " " + event_cn)
+                print(device_id + " " + 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")