# -*- coding: utf-8 -*-
"""
Created on Thu Sep 10 15:48:33 2020

@author: Esdra Santos
"""
# Bibliotecas
import paho.mqtt.client as mqtt
import json

# Tratamento do evento de mensagem recebida no tópico assinado pelo cliente mqtt
def on_message(client, userdata, message):
    print("mensagem recebida do topico",message.topic)

# Método que exibe o registro da comunicacao por protocolo mqtt no terminal
def on_log(client, userdata, level, buf):
    print("log: ",buf)

# Rotina que trata o evento de conexao, exibindo o return code e subscrevendo o cliente aos topicos de interesse
def on_connect(client, userdata, flags, rc):

    print("[STATUS] Conectado ao Broker" + broker + " Resultado de conexao: " + str(rc))
    print("subscrevendo ao topico", topico1)
    client.subscribe(topico1)
 
# Definindo os objetos
broker = "mqtt.tago.io"          # Endereço do broker
porta = 1883                           # Porta do broker
keepAlive = 60                         # Tempo em segundos para o envio de uma requisicao ping
# Topicos para publicar e subscrever
topico1    = "tago/data/regador"

mqtt_username = "token"
mqtt_password = "7f1d7f85-761e-4b98-92b4-7bab3f528b82"

print("criando nova instancia")
client = mqtt.Client()
print("Configurando o cliente")
client.username_pw_set(mqtt_username, password=mqtt_password)
print("Conectando ao broker...")
client.connect(broker,porta,keepAlive)

client.on_connect = on_connect
client.on_message = on_message
client.on_log     = on_log

client.loop_forever() # Estabelece uma comunicacao continua entre o cliente e o broker



b5d68d9edf645f4819f7a3128da3ff9831475aa3
<mask token>


def on_message(client, userdata, message):
    print('mensagem recebida do topico', message.topic)


def on_log(client, userdata, level, buf):
    print('log: ', buf)


def on_connect(client, userdata, flags, rc):
    print('[STATUS] Conectado ao Broker' + broker +
        ' Resultado de conexao: ' + str(rc))
    print('subscrevendo ao topico', topico1)
    client.subscribe(topico1)


<mask token>

<mask token>


def on_message(client, userdata, message):
    print('mensagem recebida do topico', message.topic)


def on_log(client, userdata, level, buf):
    print('log: ', buf)


def on_connect(client, userdata, flags, rc):
    print('[STATUS] Conectado ao Broker' + broker +
        ' Resultado de conexao: ' + str(rc))
    print('subscrevendo ao topico', topico1)
    client.subscribe(topico1)


<mask token>
print('criando nova instancia')
<mask token>
print('Configurando o cliente')
client.username_pw_set(mqtt_username, password=mqtt_password)
print('Conectando ao broker...')
client.connect(broker, porta, keepAlive)
<mask token>
client.loop_forever()

<mask token>


def on_message(client, userdata, message):
    print('mensagem recebida do topico', message.topic)


def on_log(client, userdata, level, buf):
    print('log: ', buf)


def on_connect(client, userdata, flags, rc):
    print('[STATUS] Conectado ao Broker' + broker +
        ' Resultado de conexao: ' + str(rc))
    print('subscrevendo ao topico', topico1)
    client.subscribe(topico1)


broker = 'mqtt.tago.io'
porta = 1883
keepAlive = 60
topico1 = 'tago/data/regador'
mqtt_username = 'token'
mqtt_password = '7f1d7f85-761e-4b98-92b4-7bab3f528b82'
print('criando nova instancia')
client = mqtt.Client()
print('Configurando o cliente')
client.username_pw_set(mqtt_username, password=mqtt_password)
print('Conectando ao broker...')
client.connect(broker, porta, keepAlive)
client.on_connect = on_connect
client.on_message = on_message
client.on_log = on_log
client.loop_forever()

<mask token>
import paho.mqtt.client as mqtt
import json


def on_message(client, userdata, message):
    print('mensagem recebida do topico', message.topic)


def on_log(client, userdata, level, buf):
    print('log: ', buf)


def on_connect(client, userdata, flags, rc):
    print('[STATUS] Conectado ao Broker' + broker +
        ' Resultado de conexao: ' + str(rc))
    print('subscrevendo ao topico', topico1)
    client.subscribe(topico1)


broker = 'mqtt.tago.io'
porta = 1883
keepAlive = 60
topico1 = 'tago/data/regador'
mqtt_username = 'token'
mqtt_password = '7f1d7f85-761e-4b98-92b4-7bab3f528b82'
print('criando nova instancia')
client = mqtt.Client()
print('Configurando o cliente')
client.username_pw_set(mqtt_username, password=mqtt_password)
print('Conectando ao broker...')
client.connect(broker, porta, keepAlive)
client.on_connect = on_connect
client.on_message = on_message
client.on_log = on_log
client.loop_forever()

# -*- coding: utf-8 -*-
"""
Created on Thu Sep 10 15:48:33 2020

@author: Esdra Santos
"""
# Bibliotecas
import paho.mqtt.client as mqtt
import json

# Tratamento do evento de mensagem recebida no tópico assinado pelo cliente mqtt
def on_message(client, userdata, message):
    print("mensagem recebida do topico",message.topic)

# Método que exibe o registro da comunicacao por protocolo mqtt no terminal
def on_log(client, userdata, level, buf):
    print("log: ",buf)

# Rotina que trata o evento de conexao, exibindo o return code e subscrevendo o cliente aos topicos de interesse
def on_connect(client, userdata, flags, rc):

    print("[STATUS] Conectado ao Broker" + broker + " Resultado de conexao: " + str(rc))
    print("subscrevendo ao topico", topico1)
    client.subscribe(topico1)
 
# Definindo os objetos
broker = "mqtt.tago.io"          # Endereço do broker
porta = 1883                           # Porta do broker
keepAlive = 60                         # Tempo em segundos para o envio de uma requisicao ping
# Topicos para publicar e subscrever
topico1    = "tago/data/regador"

mqtt_username = "token"
mqtt_password = "7f1d7f85-761e-4b98-92b4-7bab3f528b82"

print("criando nova instancia")
client = mqtt.Client()
print("Configurando o cliente")
client.username_pw_set(mqtt_username, password=mqtt_password)
print("Conectando ao broker...")
client.connect(broker,porta,keepAlive)

client.on_connect = on_connect
client.on_message = on_message
client.on_log     = on_log

client.loop_forever() # Estabelece uma comunicacao continua entre o cliente e o broker


