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_HOST: "mqtt"
|
||||||
MQTT_BROKER_PORT: 1883
|
MQTT_BROKER_PORT: 1883
|
||||||
MQTT_TOPIC: "processed_data_topic"
|
MQTT_TOPIC: "processed_data_topic"
|
||||||
BATCH_SIZE: 4
|
BATCH_SIZE: 20
|
||||||
ports:
|
ports:
|
||||||
- "9000:8000"
|
- "9000:8000"
|
||||||
networks:
|
networks:
|
||||||
|
|||||||
+1
-1
@@ -45,7 +45,7 @@ async def websocket_endpoint(websocket: WebSocket, user_id: int):
|
|||||||
|
|
||||||
try:
|
try:
|
||||||
# send already available data
|
# 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()
|
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]
|
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