Add files via upload

Author: potentialhades

SUBSCRIBER_LED.zip

@@ -0,0 +1,30 @@
+{
+  "version": 1,
+  "author": "Anonymous maker",
+  "editor": "wokwi",
+  "parts": [
+    { "type": "wokwi-esp32-devkit-v1", "id": "esp", "top": 0, "left": -77.99, "attrs": {} },
+    {
+      "type": "wokwi-led",
+      "id": "led1",
+      "top": -74.81,
+      "left": 103.67,
+      "attrs": { "color": "purple" }
+    },
+    {
+      "type": "wokwi-resistor",
+      "id": "r1",
+      "top": 8.52,
+      "left": 100.33,
+      "rotate": 270,
+      "attrs": { "value": "1000" }
+    }
+  ],
+  "connections": [
+    [ "esp:TX0", "$serialMonitor:RX", "", [] ],
+    [ "esp:RX0", "$serialMonitor:TX", "", [] ],
+    [ "led1:A", "r1:2", "red", [ "v0" ] ],
+    [ "r1:1", "esp:D4", "red", [ "h0", "v67.07" ] ],
+    [ "led1:C", "esp:GND.1", "black", [ "v0" ] ]
+  ]
+}

diagram.json

@@ -0,0 +1,65 @@
+import network
+import time
+from umqtt.simple import MQTTClient
+from machine import Pin
+
+##################################################################################
+
+# MQTT CONFIG
+MQTT_BROKER    = "broker.hivemq.com"
+MQTT_USER      = ""
+MQTT_PASSWORD  = ""
+MQTT_CLIENT_ID = ""
+MQTT_TOPIC     = "sala306/led"
+MQTT_PORT = 1883
+
+################################################################################
+
+# CONNECT WI-FI WOKWI-GUEST
+def wifi_connect():
+  print("Connecting", end="")
+
+  sta_if = network.WLAN(network.STA_IF)
+  sta_if.active(True)
+  sta_if.connect('Wokwi-GUEST', '')
+
+  while not sta_if.isconnected():
+    print(".", end="")
+    time.sleep(0.3)
+
+  print(" Wi-Fi connected!")
+
+################################################################################
+
+# LED MESSAGE CONFIG
+def message_arrived(topic, msg):
+  if (msg == b'1'):
+      led.value(1)
+  if (msg == b'0'):
+      led.value(0)
+
+################################################################################
+
+# SUBSCRIBER
+def subscribe():
+    client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, port=MQTT_PORT, user=MQTT_USER, password=MQTT_PASSWORD, keepalive=0)
+ 
+    # Subscribed messages will be delivered to this callback
+    client.set_callback(message_arrived)
+    client.connect()
+    client.subscribe(MQTT_TOPIC)
+    print("Conected on %s, topic subscribed: %s " % (MQTT_BROKER, MQTT_TOPIC))
+    return client
+
+################################################################################
+
+# MAIN PROGRAM
+led = Pin(4, Pin.OUT)
+led.value(0)
+
+wifi_connect()
+client = subscribe()
+
+while True:
+  client.wait_msg()
+  #time.sleep(0.5)      # BLINK LED

main.py

@@ -0,0 +1,3 @@
+Downloaded from https://wokwi.com/projects/329467649115292243
+
+Simulate this project on https://wokwi.com