Create weather.py

weather.py

@@ -0,0 +1,117 @@
+import time
+import requests
+import os
+import json
+from datetime import datetime, timedelta
+from zoneinfo import ZoneInfo
+
+BASE_URL = "https://desk-api.channel.io/desk/channels/200605"
+TARGET_GROUP_CHAT_ID = "463667"
+
+HEADERS = {
+    "accept-language": "ja",
+    "x-account": os.getenv("dmsendertoken")
+}
+
+JST = ZoneInfo("Asia/Tokyo")
+
+WEATHER_CODE_MAP = {
+    0: "☀️晴れ",
+    1: "☁️曇り",
+    2: "吹雪",
+    3: "砂嵐",
+    4: "🌫️霧",
+    5: "🌫️霧雨",
+    6: "🌧️雨",
+    7: "🌨️雪",
+    8: "🌦️シャワー",
+    9: "⛈️雷雨",
+}
+
+
+def post_group_message(chat_id, body):
+    url = f"{BASE_URL}/groups/{chat_id}/messages"
+    r = requests.post(url, headers=HEADERS, json=body)
+    r.raise_for_status()
+    return r.json()
+
+
+def wait_until_7am():
+    now = datetime.now(JST)
+    target = now.replace(hour=7, minute=0, second=0, microsecond=0)
+    if now >= target:
+        target += timedelta(days=1)
+    time.sleep((target - now).total_seconds())
+
+
+def fetch_weather(lat, lon):
+    url = (
+        "https://api.open-meteo.com/v1/forecast"
+        f"?latitude={lat}&longitude={lon}"
+        "&hourly=relative_humidity_2m,apparent_temperature,"
+        "temperature_2m,precipitation_probability,weather_code"
+        "&forecast_days=1"
+        "&timezone=Asia%2FTokyo"
+    )
+    r = requests.get(url)
+    r.raise_for_status()
+    return r.json()
+
+
+def extract_after_6am(hourly):
+    for i, t in enumerate(hourly["time"]):
+        hour = int(t[11:13])
+        if hour >= 6:
+            return {
+                "weather": WEATHER_CODE_MAP.get(hourly["weather_code"][i], "不明"),
+                "apparent": hourly["apparent_temperature"][i],
+                "temp": hourly["temperature_2m"][i],
+                "rain": hourly["precipitation_probability"][i],
+                "humidity": hourly["relative_humidity_2m"][i],
+            }
+    return None
+
+
+def create_weather_message():
+    with open("todoufuken.json", encoding="utf-8") as f:
+        prefectures = json.load(f)
+
+    lines = ["<b>☀️ 本日の天気予報（6時以降）</b>"]
+
+    for p in prefectures:
+        data = fetch_weather(p["lat"], p["lon"])
+        info = extract_after_6am(data["hourly"])
+        if not info:
+            continue
+
+        line = (
+            f'{p["name"]}　{info["weather"]}　'
+            f'{info["apparent"]}℃　{info["temp"]}℃　'
+            f'{info["rain"]}%　{info["humidity"]}%'
+        )
+        lines.append(line)
+
+    return {
+        "requestId": f"desk-weather-{int(time.time())}",
+        "blocks": [
+            {
+                "type": "text",
+                "value": "\n".join(lines),
+            }
+        ],
+    }
+
+
+def main_loop():
+    while True:
+        try:
+            wait_until_7am()
+            body = create_weather_message()
+            post_group_message(TARGET_GROUP_CHAT_ID, body)
+        except Exception as e:
+            print("Error:", e)
+            time.sleep(30)
+
+
+if __name__ == "__main__":
+    main_loop()