mqtt_subscribe Namespace Reference

Functions
def	on_connect (client, userdata, flags, reason_code, properties)
def	on_message (client, userdata, message)

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)
	on_connect
	on_message

Function Documentation

on_connect()

def mqtt_subscribe.on_connect	(		client,
			userdata,
			flags,
			reason_code,
			properties
	)

on_message()

def mqtt_subscribe.on_message	(		client,
			userdata,
			message
	)

Variable Documentation

client

mqtt_subscribe.client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)

host

mqtt_subscribe.host = os.environ.get("MQTT_BROKER_HOST", "127.0.0.1")

on_connect

mqtt_subscribe.on_connect

on_message

mqtt_subscribe.on_message

port

mqtt_subscribe.port = int(os.environ.get("MQTT_BROKER_PORT", 1883))