สร้างสถานีตรวจวัดอากาศด้วย Raspberry Pi Pico W และ DHT11

# Raspberry Pi Pico W Weather Station
# วัดอุณหภูมิและความชื้นด้วย DHT11 ส่งข้อมูลไป CynoIoT

import machine
import network
import time
import urequests as requests
from machine import Pin
import dht

# ========== การตั้งค่า ==========
# แก้ไข WiFi และ CynoIoT credentials ของคุณที่นี่
WIFI_SSID = "your_wifi_ssid"
WIFI_PASSWORD = "your_wifi_password"
CYNOIOT_API_KEY = "your_cynoiot_api_key"  # ได้จาก cynoiot.com
DEVICE_ID = "your_device_id"

# DHT11 sensor settings
DHT_PIN = 0  # GP0

# เวลาในการส่งข้อมูล (วินาที)
SEND_INTERVAL = 60  # ส่งทุก 1 นาที

# ========== เริ่มต้นใช้งานเซ็นเซอร์ ==========
print("เริ่มต้นสถานีตรวจวัดอากาศ...")

# เริ่มต้น DHT11 sensor
dht_sensor = dht.DHT11(machine.Pin(DHT_PIN))

# ========== เชื่อมต่อ WiFi ==========
def connect_wifi():
    """เชื่อมต่อ WiFi"""
    wlan = network.WLAN(network.STA_IF)
    wlan.active(True)
    
    if not wlan.isconnected():
        print('กำลังเชื่อมต่อ WiFi...')
        wlan.connect(WIFI_SSID, WIFI_PASSWORD)
        
        # รอให้เชื่อมต่อสำเร็จ
        timeout = 20
        while not wlan.isconnected() and timeout > 0:
            print('.', end='')
            time.sleep(1)
            timeout -= 1
        
        if wlan.isconnected():
            print('\n✅ เชื่อมต่อ WiFi สำเร็จ!')
            print('IP Address:', wlan.ifconfig()[0])
        else:
            print('\n❌ ไม่สามารถเชื่อมต่อ WiFi ได้')
            return None
    
    return wlan

# ========== อ่านค่าจาก DHT11 ==========
def read_dht11():
    """อ่านค่าอุณหภูมิและความชื้นจาก DHT11"""
    try:
        dht_sensor.measure()
        temperature = dht_sensor.temperature()
        humidity = dht_sensor.humidity()
        
        print(f'🌡️ อุณหภูมิ: {temperature}°C')
        print(f'💧 ความชื้น: {humidity}%')
        
        return {
            'temperature': temperature,
            'humidity': humidity
        }
    except OSError as e:
        print('❌ ไม่สามารถอ่านค่าจาก DHT11 ได้:', e)
        return None

# ========== ส่งข้อมูลไป CynoIoT ==========
def send_to_cynoiot(data):
    """ส่งข้อมูลไปยัง CynoIoT Platform"""
    url = f"https://www.cynoiot.com/api/devices/{DEVICE_ID}/data"
    
    headers = {
        'Content-Type': 'application/json',
        'Authorization': f'Bearer {CYNOIOT_API_KEY}'
    }
    
    payload = {
        'temperature': data['temperature'],
        'humidity': data['humidity'],
        'timestamp': time.time()
    }
    
    try:
        response = requests.post(url, json=payload, headers=headers, timeout=10)
        if response.status_code == 200:
            print('✅ ส่งข้อมูลไป CynoIoT สำเร็จ')
        else:
            print(f'⚠️ ส่งข้อมูลไม่สำเร็จ: {response.status_code}')
    except Exception as e:
        print(f'❌ ข้อผิดพลาดในการส่งข้อมูล: {e}')

# ========== Main Loop ==========
def main():
    """ฟังก์ชันหลัก"""
    # เชื่อมต่อ WiFi
    wlan = connect_wifi()
    if wlan is None:
        print('ไม่สามารถดำเนินการต่อได้ หยุดโปรแกรม')
        return
    
    print('--- เริ่มต้นการทำงาน ---')
    
    while True:
        # อ่านค่าจากเซ็นเซอร์
        sensor_data = read_dht11()
        
        if sensor_data:
            # ส่งข้อมูลไป CynoIoT
            send_to_cynoiot(sensor_data)
        
        # รอจนถึงเวลาส่งครั้งถัดไป
        print(f'รอ {SEND_INTERVAL} วินาที...\n')
        time.sleep(SEND_INTERVAL)

# ========== รันโปรแกรม ==========
if __name__ == '__main__':
    main()