seperate batch topic per mqtt processor

2025-03-22 20:05:16 +00:00 · 2022-10-03 22:05:32 +11:00 · 2022-10-03 22:05:32 +11:00 · 32a95dd95a
commit 32a95dd95a
parent 422956c8e7
1 changed files with 1 additions and 1 deletions
--- a/lambda/sns_to_mqtt/init.py
+++ b/lambda/sns_to_mqtt/init.py
@ -75,7 +75,7 @@ def lambda_handler(event, context):
                retain=False
            )
        client.publish(
-            topic=f'batch',
+            topic=os.getenv("MQTT_BATCH"),
            payload=json.dumps(payloads),
            qos=0,
            retain=False