From 32a95dd95ac065c28cdb6a4d81c7bdf1264d3126 Mon Sep 17 00:00:00 2001 From: xss Date: Mon, 3 Oct 2022 22:05:32 +1100 Subject: [PATCH] seperate batch topic per mqtt processor --- lambda/sns_to_mqtt/__init__.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lambda/sns_to_mqtt/__init__.py b/lambda/sns_to_mqtt/__init__.py index b6d41c7..943f56a 100644 --- 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