Variables | |
| host = os.environ.get("MQTT_BROKER_HOST", "127.0.0.1") | |
| port = int(os.environ.get("MQTT_BROKER_PORT", 1883)) | |
| client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2) | |
| msg = String() | |
| data | |
| mqtt_publish.client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2) |
| mqtt_publish.data |
| mqtt_publish.host = os.environ.get("MQTT_BROKER_HOST", "127.0.0.1") |
| mqtt_publish.msg = String() |
| mqtt_publish.port = int(os.environ.get("MQTT_BROKER_PORT", 1883)) |