Skip to content

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

update data

parent 3b7cb157
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 2 deletions
src/online_prediction.py
View file @ de1cdd01
from kafka import KafkaConsumer
import json import json
from datetime import datetime
from kafka import KafkaConsumer
def consume_kafka(): def consume_kafka():
...@@ -13,7 +15,7 @@ def consume_kafka(): ...@@ -13,7 +15,7 @@ def consume_kafka():
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", "")
print(device_id) print(device_id + " " + str(datetime.now()))
if __name__ == "__main__": if __name__ == "__main__":
......
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