mirror of
https://github.com/Rhinemann/IoT-Systems.git
synced 2026-03-14 20:50:39 +02:00
25 lines
823 B
Python
25 lines
823 B
Python
|
import os
|
||
|
|
|
||
|
|
|
||
|
|
def try_parse_int(value: str):
|
||
|
|
try:
|
||
|
|
return int(value)
|
||
|
|
except Exception:
|
||
|
|
return None
|
||
|
|
|
||
|
|
|
||
|
|
# Configuration for agent MQTT
|
||
|
|
MQTT_BROKER_HOST = os.environ.get("MQTT_BROKER_HOST") or "localhost"
|
||
|
|
MQTT_BROKER_PORT = try_parse_int(os.environ.get("MQTT_BROKER_PORT")) or 1883
|
||
|
|
MQTT_TOPIC = os.environ.get("MQTT_TOPIC") or "agent_data_topic"
|
||
|
|
|
||
|
|
# Configuration for hub MQTT
|
||
|
|
HUB_MQTT_BROKER_HOST = os.environ.get("HUB_MQTT_BROKER_HOST") or "localhost"
|
||
|
|
HUB_MQTT_BROKER_PORT = try_parse_int(os.environ.get("HUB_MQTT_BROKER_PORT")) or 1883
|
||
|
|
HUB_MQTT_TOPIC = os.environ.get("HUB_MQTT_TOPIC") or "processed_agent_data_topic"
|
||
|
|
|
||
|
|
# Configuration for the Hub
|
||
|
|
HUB_HOST = os.environ.get("HUB_HOST") or "localhost"
|
||
|
|
HUB_PORT = try_parse_int(os.environ.get("HUB_PORT")) or 12000
|
||
|
|
HUB_URL = f"http://{HUB_HOST}:{HUB_PORT}"
|