บทความ: เริ่มต้นใช้งาน ESP32 MicroPython กับ MQTT สำหรับ IoT

# ESP32 MicroPython MQTT Basic Example
# ตัวอย่างการเชื่อมต่อ MQTT Broker

import network
import time
from umqtt.simple import MQTTClient

# ============ WiFi Configuration ============
WIFI_SSID = "your_wifi_ssid"      # แก้ไขเป็น WiFi ของคุณ
WIFI_PASSWORD = "your_wifi_password"  # แก้ไขเป็น Password ของคุณ

# ============ MQTT Configuration ============
MQTT_BROKER = "broker.hivemq.com"  # ใช้ Broker ฟรี
MQTT_PORT = 1883
MQTT_CLIENT_ID = "esp32_client_" + str(time.ticks_ms())
MQTT_USER = ""        # ถ้ามี Authentication
MQTT_PASSWORD = ""    # ถ้ามี Authentication

# ============ WiFi Connection ============
def connect_wifi():
    """เชื่อมต่อ WiFi"""
    wlan = network.WLAN(network.STA_IF)
    wlan.active(True)
    
    if not wlan.isconnected():
        print('Connecting to WiFi...')
        wlan.connect(WIFI_SSID, WIFI_PASSWORD)
        
        # รอการเชื่อมต่อ (timeout 10 วินาที)
        timeout = 10
        while not wlan.isconnected() and timeout > 0:
            print('.', end='')
            time.sleep(1)
            timeout -= 1
    
    if wlan.isconnected():
        print('\nWiFi connected! IP:', wlan.ifconfig()[0])
        return True
    else:
        print('\nFailed to connect WiFi')
        return False

# ============ MQTT Callbacks ============
def mqtt_callback(topic, msg):
    """ฟังก์ชันที่ทำงานเมื่อได้รับข้อความ"""
    print(f"Received message:")
    print(f"  Topic: {topic.decode('utf-8')}")
    print(f"  Message: {msg.decode('utf-8')}")

# ============ Main Program ============
if __name__ == "__main__":
    # เชื่อมต่อ WiFi
    if connect_wifi():
        # สร้าง MQTT Client
        client = MQTTClient(
            MQTT_CLIENT_ID,
            MQTT_BROKER,
            MQTT_PORT,
            MQTT_USER,
            MQTT_PASSWORD
        )
        
        # ตั้งค่า Callback
        client.set_callback(mqtt_callback)
        
        # เชื่อมต่อ MQTT Broker
        print(f"Connecting to MQTT Broker: {MQTT_BROKER}")
        client.connect()
        print("MQTT connected!")
        
        # Subscribe หัวข้อ
        topic = b"esp32/test"
        client.subscribe(topic)
        print(f"Subscribed to: {topic.decode('utf-8')}")
        
        # วนลูปรับข้อความ
        print("Waiting for messages...")
        while True:
            try:
                client.wait_msg()  # รอรับข้อความ
            except Exception as e:
                print(f"Error: {e}")
                client.disconnect()
                time.sleep(5)
                client.connect()
                client.subscribe(topic)

# ESP32 MicroPython MQTT Publisher Example
# ส่งข้อมูลจำลอง Sensor ไปยัง MQTT Broker

import network
import time
import json
from umqtt.simple import MQTTClient
from machine import Pin
import dht

# ============ Configuration ============
WIFI_SSID = "your_wifi_ssid"
WIFI_PASSWORD = "your_wifi_password"

MQTT_BROKER = "broker.hivemq.com"
MQTT_PORT = 1883
MQTT_CLIENT_ID = "esp32_sensor_" + str(time.ticks_ms())

# ============ Sensor Setup ============
# ใช้ DHT22 Sensor (หรือ DHT11) ที่ขา GPIO 4
dht_sensor = dht.DHT22(Pin(4))

# ============ WiFi Connection ============
def connect_wifi():
    wlan = network.WLAN(network.STA_IF)
    wlan.active(True)
    
    if not wlan.isconnected():
        print('Connecting to WiFi...')
        wlan.connect(WIFI_SSID, WIFI_PASSWORD)
        timeout = 10
        while not wlan.isconnected() and timeout > 0:
            print('.', end='')
            time.sleep(1)
            timeout -= 1
    
    if wlan.isconnected():
        print('\nWiFi connected!')
        return True
    return False

# ============ Read Sensor ============
def read_sensor():
    """อ่านค่าจาก DHT22 Sensor"""
    try:
        dht_sensor.measure()
        temperature = dht_sensor.temperature()
        humidity = dht_sensor.humidity()
        return temperature, humidity
    except Exception as e:
        print(f"Sensor error: {e}")
        return None, None

# ============ Main Program ============
if __name__ == "__main__":
    if connect_wifi():
        # สร้าง MQTT Client
        client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, MQTT_PORT)
        client.connect()
        print("MQTT connected!")
        
        # หัวข้อ Topic
        topic_temp = b"sensor/temperature"
        topic_humidity = b"sensor/humidity"
        
        # วนลูปส่งข้อมูลทุก 5 วินาที
        print("Publishing sensor data...")
        while True:
            try:
                # อ่านค่า Sensor
                temp, hum = read_sensor()
                
                if temp is not None and hum is not None:
                    # สร้างข้อมูล JSON
                    data = {
                        "temperature": temp,
                        "humidity": hum,
                        "timestamp": time.ticks_ms(),
                        "unit": "celsius"
                    }
                    
                    # แปลงเป็น JSON String
                    payload = json.dumps(data)
                    
                    # ส่งข้อมูลไปยัง Broker
                    client.publish(topic_temp, payload)
                    print(f"Published: {payload}")
                    
                    # แยกส่งค่าความชื้น
                    client.publish(topic_humidity, str(hum))
                    
                else:
                    print("Failed to read sensor")
                
                # รอ 5 วินาที
                time.sleep(5)
                
            except Exception as e:
                print(f"Error: {e}")
                time.sleep(5)