This commit is contained in:
Atilla
2024-04-12 21:23:08 +02:00
parent 18fae2f870
commit 88424cf30c
39 changed files with 454 additions and 433 deletions

View File

@@ -7,7 +7,7 @@ import json
from mqtt_client import create_client, start_loop
# Stel het interval in seconden in voor het periodiek ophalen en publiceren van data.
publish_interval = 900 # MOET ~900 ZIJN voor productiegebruik. -- 15min
publish_interval = 900 # MOET ~900 ZIJN. -- 15min
# Definieer API-eindpunten en de corresponderende MQTT topics.
api_endpoints = [
@@ -65,7 +65,7 @@ def fetch_and_publish_data():
for endpoint in api_endpoints:
url = endpoint["url"]
mqtt_topic = endpoint["topic"]
access_token = "33bb3b42452306c58ecedc3c86cfae28ba22329c" # Voorbeeld token.
access_token = "33bb3b42452306c58ecedc3c86cfae28ba22329c"
try:
headers = {"Authorization": f"Token {access_token}"}
@@ -84,4 +84,4 @@ if __name__ == "__main__":
print(f"\033[91mWachten, wachten en nog eens wachten... {publish_interval} secondes!\033[0m\n")
time.sleep(publish_interval) # Wacht voor het ingestelde interval.
client.loop_stop()
client.loop_stop()