Pico WからLINEへ通知を送るMicroPythonコード｜urequestsでプッシュ送信・日本語エラー400対策【自作スマートリモコン 第3回】

# Wifi_Connection_test.py
import network
import time

# Wi-Fi情報をご自身の環境に書き換えてください
WIFI_SSID = "あなたのWi-FiのSSID"
WIFI_PASSWORD = "あなたのWi-Fiのパスワード"

wlan = network.WLAN(network.STA_IF)
wlan.active(True)

print(f"Wi-Fi（{WIFI_SSID}）に接続中...")
wlan.connect(WIFI_SSID, WIFI_PASSWORD)

# 接続を少し待つ（最大10秒）
timeout = 10
while timeout > 0:
    if wlan.isconnected():
        break
    timeout -= 1
    print(".")
    time.sleep(1)

if wlan.isconnected():
    print("Wi-Fi接続に成功しました！")
    # Pico Wに割り当てられたIPアドレスを表示
    print("IP設定:", wlan.ifconfig())
else:
    print("Wi-Fi接続に失敗しました。SSIDやパスワードを確認してください。")

# get_line_message.py
import network
import time
import urequests
import json

# --- ここをご自身の環境のものに書き換えて下さい ---
WIFI_SSID = "あなたのWi-FiのSSID"
WIFI_PASSWORD = "あなたのWi-Fiのパスワード"
LINE_TOKEN = "あなたのトークン（b7+ux...）"
USER_ID = "あなたのユーザーID（U...）"
# --------------------------------------------------

wlan = network.WLAN(network.STA_IF)
wlan.active(True)
wlan.connect(WIFI_SSID, WIFI_PASSWORD)

print("Connecting to Wi-Fi...")
while not wlan.isconnected():
    time.sleep(1)
print("Wi-Fi Connected!")

url = "https://api.line.me/v2/bot/message/push"

# f-stringを使って、完全に1本の文字列にしてヘッダーを作ります
auth_header = f"Bearer {LINE_TOKEN}"

headers = {
    "Content-Type": "application/json",
    "Authorization": auth_header
}

payload = {
    "to": USER_ID,
    "messages": [
        {
            "type": "text",
            "text": "Hello from Pico W! Test OK."
        }
    ]
}

print("Sending to LINE...")
try:
    # データをLINEのサーバーへ送信します
    response = urequests.post(url, data=json.dumps(payload), headers=headers)
    print("Status Code:", response.status_code)
    print("Response:", response.text)
    response.close()
except Exception as e:
    print("Error:", e)

# Main_Temp_Line_bot.py
import machine
import dht
import network
import time
import urequests
import json

# --- ここをご自身の環境のものに書き換えて下さい ---
WIFI_SSID = "SSIDを入力"
WIFI_PASSWORD = "Passwordを入力"
LINE_TOKEN = "b7+u･･･で始まるLINEトークンを入力"
USER_ID = "U････から始まるユーザーIDを入力"
# --------------------------------------------------

# --- 2. 見守りの設定 ---
ALERT_TEMP = 28          # この温度（℃）を超えたらLINEを送る
CHECK_INTERVAL = 10      # 温度をチェックする間隔（秒） ※テスト用に短くしています
# --------------------------------------------

# センサーとWi-Fiの初期設定
sensor = dht.DHT11(machine.Pin(15))
wlan = network.WLAN(network.STA_IF)

def connect_wifi():
    wlan.active(True)
    if not wlan.isconnected():
        print("Wi-Fiに接続中...")
        wlan.connect(WIFI_SSID, WIFI_PASSWORD)
        while not wlan.isconnected():
            time.sleep(1)
    print("Wi-Fi接続成功！ IP:", wlan.ifconfig()[0])

def send_line(message):
    try:
        connect_wifi()
        url = "https://api.line.me/v2/bot/message/push"
        headers = {
            "Content-Type": "application/json; charset=UTF-8", # 文字コードを指定
            "Authorization": f"Bearer {LINE_TOKEN}"
        }
        payload = {
            "to": USER_ID,
            "messages": [{"type": "text", "text": message}]
        }
        
        # ★ココが重要！ json.dumps(payload) をさらに .encode('utf-8') で変換します
        binary_data = json.dumps(payload).encode('utf-8')
        
        # data= にバイナリデータを渡す
        response = urequests.post(url, data=binary_data, headers=headers)
        print(f"LINE送信結果ステータス: {response.status_code}")
        response.close()
    except Exception as e:
        print(f"LINE送信エラー: {e}")

# メイン処理開始
print("温湿度監視システムを起動しました")
send_line("温湿度監視システムが起動しました！監視を開始します。")

# 一度LINEを送ったら、しばらく連続送信を防ぐためのフラグ
alert_sent = False

while True:
    try:
        # センサーから値を読み取る
        sensor.measure()
        temp = sensor.temperature()
        humidity = sensor.humidity()
        print(f"【現在値】 温度: {temp}°C, 湿度: {humidity}%")
        
        # 温度がしきい値を超えた場合の判定
        if temp >= ALERT_TEMP:
            if not alert_sent:
                # まだアラートを送っていない場合のみ送信
                msg = f"【警告】室温が{temp}°Cになりました！エアコンを確認してください！（湿度: {humidity}%）"
                print("警報レベル到達！LINEを送ります。")
                send_line(msg)
                alert_sent = True # フラグを立てて、連続送信を防ぐ
        else:
            if alert_sent:
                # 温度が安全圏内に戻ったらフラグをリセットし、安心通知を送る
                print("温度が安全圏に戻りました。")
                send_line(f"室温が{temp}°Cに下がりました。安全圏内です。")
                alert_sent = False
                
    except OSError as e:
        print("センサーの読み取りエラー（スキップします）")
        
    # 指定した時間だけ待つ
    time.sleep(CHECK_INTERVAL)