Compare commits
6 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 1f6b02c5f6 | |||
| 69523a9fd2 | |||
| 094662f59e | |||
| 88454f381d | |||
| 119547d288 | |||
| b58167f0de |
@@ -0,0 +1,13 @@
|
|||||||
|
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: 20
|
BATCH_SIZE: 4
|
||||||
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()
|
r = processed_agent_data.select().order_by(processed_agent_data.c.timestamp)
|
||||||
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