[P] Add GPS file selection to agent
This commit is contained in:
@@ -1,18 +1,17 @@
|
|||||||
import os
|
import os
|
||||||
|
|
||||||
|
|
||||||
def try_parse(type, value: str):
|
def try_parse(type, value: str):
|
||||||
try:
|
try:
|
||||||
return type(value)
|
return type(value)
|
||||||
except Exception:
|
except Exception:
|
||||||
return None
|
return None
|
||||||
|
|
||||||
|
|
||||||
USER_ID = try_parse(int, os.environ.get("USER_ID")) or 1
|
|
||||||
# MQTT config
|
# MQTT config
|
||||||
MQTT_BROKER_HOST = os.environ.get("MQTT_BROKER_HOST") or "mqtt"
|
MQTT_BROKER_HOST = os.environ.get("MQTT_BROKER_HOST") or "mqtt"
|
||||||
MQTT_BROKER_PORT = try_parse(int, os.environ.get("MQTT_BROKER_PORT")) or 1883
|
MQTT_BROKER_PORT = try_parse(int, os.environ.get("MQTT_BROKER_PORT")) or 1883
|
||||||
MQTT_TOPIC = os.environ.get("MQTT_TOPIC") or "agent"
|
MQTT_TOPIC = os.environ.get("MQTT_TOPIC") or "agent"
|
||||||
|
|
||||||
# Delay for sending data to mqtt in seconds
|
# Data-related config
|
||||||
|
USER_ID = try_parse(int, os.environ.get("USER_ID")) or 1
|
||||||
DELAY = try_parse(float, os.environ.get("DELAY")) or 1
|
DELAY = try_parse(float, os.environ.get("DELAY")) or 1
|
||||||
|
GPS_SOURCE = os.environ.get("GPS_SOURCE") or "data/gps.csv"
|
||||||
|
|||||||
@@ -42,7 +42,7 @@ def run():
|
|||||||
# Prepare mqtt client
|
# Prepare mqtt client
|
||||||
client = connect_mqtt(config.MQTT_BROKER_HOST, config.MQTT_BROKER_PORT)
|
client = connect_mqtt(config.MQTT_BROKER_HOST, config.MQTT_BROKER_PORT)
|
||||||
# Prepare datasource
|
# Prepare datasource
|
||||||
datasource = FileDatasource(16384.0, "data/accelerometer.csv", "data/gps.csv", "data/parking.csv")
|
datasource = FileDatasource(16384.0, "data/accelerometer.csv", config.GPS_SOURCE, "data/parking.csv")
|
||||||
# Infinity publish data
|
# Infinity publish data
|
||||||
publish(client, config.MQTT_TOPIC, datasource)
|
publish(client, config.MQTT_TOPIC, datasource)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user