Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| ae69bd601e | |||
| 2b8d042306 | |||
| 5ab16fec72 | |||
| d633926a1a |
@@ -1,13 +0,0 @@
|
||||
print('lat,lon')
|
||||
|
||||
try:
|
||||
while True:
|
||||
i = input()
|
||||
|
||||
if '<trkpt' not in i:
|
||||
continue
|
||||
|
||||
si = i.split('"')[1::2]
|
||||
print(f"{si[0]},{si[1]}")
|
||||
except EOFError:
|
||||
pass
|
||||
+1
-1
@@ -148,7 +148,7 @@ services:
|
||||
MQTT_BROKER_HOST: "mqtt"
|
||||
MQTT_BROKER_PORT: 1883
|
||||
MQTT_TOPIC: "processed_data_topic"
|
||||
BATCH_SIZE: 4
|
||||
BATCH_SIZE: 20
|
||||
ports:
|
||||
- "9000:8000"
|
||||
networks:
|
||||
|
||||
+1
-1
@@ -45,7 +45,7 @@ async def websocket_endpoint(websocket: WebSocket, user_id: int):
|
||||
|
||||
try:
|
||||
# send already available data
|
||||
r = processed_agent_data.select().order_by(processed_agent_data.c.timestamp)
|
||||
r = processed_agent_data.select()
|
||||
stored_data = SessionLocal().execute(r).fetchall()
|
||||
|
||||
jsonable_data = [{c.name: getattr(i, c.name) for c in processed_agent_data.columns} for i in stored_data]
|
||||
|
||||
Reference in New Issue
Block a user