from machine import Pin
from utime import sleep, sleep_ms
import network, time
import ujson
from neopixel import NeoPixel
from umqtt.simple import MQTTClient
MQTT_CLIENT_ID = "clien333tFFFFORhugo"
MQTT_BROKER = "broker.hivemq.com"
MQTT_USER = ""
MQTT_PASSWORD = ""
MQTT_TOPIC_SUB = "control/bombillo"
np= NeoPixel(Pin(16), 3)
def conectaWifi (red, password):
global miRed
miRed = network.WLAN(network.STA_IF)
if not miRed.isconnected(): #Si no está conectado…
miRed.active(True) #activa la interface
miRed.connect(red, password) #Intenta conectar con la red
print('Conectando a la red', red +"…")
timeout = time.time ()
while not miRed.isconnected(): #Mientras no se conecte..
if (time.ticks_diff (time.time (), timeout) > 10):
return False
return True
if conectaWifi("Wokwi-GUEST", ""):
print ("Conexión exitosa!")
print('Datos de la red (IP/netmask/gw/DNS):', miRed.ifconfig())
print("Conectando a MQTT server... ",MQTT_BROKER,"...", end="")
client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, user=MQTT_USER, password=MQTT_PASSWORD)
client.connect()
def sub_cb(topic, msg):
dato = ujson.loads(msg.decode())
print(f'Recibido:{dato}')
print(dato["Verificacion"])
uno=dato["Verificacion"]
if uno == "ok":
np[0]=(0,255,0)
np.write()
while True:
client.set_callback(sub_cb)
client.subscribe(MQTT_TOPIC_SUB)
np[0]=(255,0,0)
np.write()
print ("esperando")
client.wait_msg()
time.sleep(3)
else:
print ("Imposible conectar")
miRed.active (False)