29 lines
827 B
Python
29 lines
827 B
Python
import paho.mqtt.client as mqtt
|
|
|
|
# Configurações do Broker
|
|
broker_address = "localhost" # Ou o IP/endereço do seu broker MQTT
|
|
port = 1883 # Porta padrão do MQTT
|
|
topic = "test/topic" # Tópico em que a mensagem será publicada
|
|
|
|
# Callback de conexão (opcional)
|
|
def on_connect(client, userdata, flags, rc):
|
|
if rc == 0:
|
|
print("Connected to MQTT Broker!")
|
|
else:
|
|
print("Failed to connect, return code %d\n", rc)
|
|
|
|
# Instanciando o cliente
|
|
client = mqtt.Client("PythonClient")
|
|
client.on_connect = on_connect # Associa a função de callback de conexão
|
|
|
|
# Conectando ao broker
|
|
client.connect(broker_address, port=port)
|
|
|
|
# Publicando uma mensagem
|
|
message = "Hello MQTT"
|
|
client.publish(topic, message)
|
|
|
|
print(f"Message '{message}' sent to topic '{topic}'")
|
|
|
|
# Desconectando do broker
|
|
client.disconnect() |