Python+Lambdaで天気予報をLINEから通知するアプリを簡単に作ってみた

# ライブラリインポート--------------
from bs4 import BeautifulSoup
import requests
import time

# 変数定義--------------------------
## APIエンドポイント・アクセストークン
ENDPOINT="https://api.line.me/v2/bot/message/broadcast"
TOKEN="発行したアクセストークン"

## 天気予報サイトURL
YAHOO="https://weather.yahoo.co.jp/weather/jp/13/4410.html"
TENKI="https://tenki.jp/forecast/3/16/4410/13116/"

## 降水確率基準・傘要否の判定
RAIN_SD=40
is_rain=False

## LINE送信メッセージ格納リスト
messages=[]

# メイン処理-----------------------
def lambda_handler(event,context):
    get_weather(YAHOO)
    get_weather(TENKI)
    if is_rain:
        messages.append({"type":"text","text":"傘が必要です！"})
    send_message()

# 天気予報情報スクレイピング処理---
def get_weather(site):
    global is_rain
    ## サイトにアクセスし各要素情報取得
    response=requests.get(site)
    soup=BeautifulSoup(response.text,"html.parser")
    try:
        if site==YAHOO:
            site_name="Yahoo天気"
            date=soup.select_one("#main > div.forecastCity > table > tr > td:nth-child(2) > div > p.date > span:nth-child(1)").get_text()
            day=soup.select_one("#main > div.forecastCity > table > tr > td:nth-child(2) > div > p.date > span:nth-child(2)").get_text()
            weather=soup.select_one("#main > div.forecastCity > table > tr > td:nth-child(2) > div > p.pict").get_text().replace("\n","").strip()
            max_temp=soup.select_one("#main > div.forecastCity > table > tr > td:nth-child(2) > div > ul > li.high > em").get_text()
            min_temp=soup.select_one("#main > div.forecastCity > table > tr > td:nth-child(2) > div > ul > li.low > em").get_text()
            rain_rate1=int(soup.select_one("#main > div.forecastCity > table > tr > td:nth-child(2) > div > table > tr.precip > td:nth-child(2)").get_text().replace("％",""))
            rain_rate2=int(soup.select_one("#main > div.forecastCity > table > tr > td:nth-child(2) > div > table > tr.precip > td:nth-child(3)").get_text().replace("％",""))
            rain_rate3=int(soup.select_one("#main > div.forecastCity > table > tr > td:nth-child(2) > div > table > tr.precip > td:nth-child(4)").get_text().replace("％",""))
            rain_rate4=int(soup.select_one("#main > div.forecastCity > table > tr > td:nth-child(2) > div > table > tr.precip > td:nth-child(5)").get_text().replace("％",""))
        elif site==TENKI:
            site_name="tenki"
            date_data=soup.select_one("#main-column > section > div.forecast-days-wrap.clearfix > section.tomorrow-weather > h3").get_text()
            date=date_data.split("\xa0")[1].split("(")[0]
            day=date_data.split("\xa0")[1].split("(")[1].split(")")[0]
            weather=soup.select_one("#main-column > section > div.forecast-days-wrap.clearfix > section.tomorrow-weather > div.weather-wrap.clearfix > div.weather-icon > p").get_text()
            max_temp=soup.select_one("#main-column > section > div.forecast-days-wrap.clearfix > section.tomorrow-weather > div.weather-wrap.clearfix > div.date-value-wrap > dl > dd.high-temp.temp > span.value").get_text()
            min_temp=soup.select_one("#main-column > section > div.forecast-days-wrap.clearfix > section.tomorrow-weather > div.weather-wrap.clearfix > div.date-value-wrap > dl > dd.low-temp.temp > span.value").get_text()
            rain_rate1=int(soup.select_one("#main-column > section > div.forecast-days-wrap.clearfix > section.tomorrow-weather > div.precip-table > table > tr.rain-probability > td:nth-child(2)").get_text().replace("%",""))
            rain_rate2=int(soup.select_one("#main-column > section > div.forecast-days-wrap.clearfix > section.tomorrow-weather > div.precip-table > table > tr.rain-probability > td:nth-child(3)").get_text().replace("%",""))
            rain_rate3=int(soup.select_one("#main-column > section > div.forecast-days-wrap.clearfix > section.tomorrow-weather > div.precip-table > table > tr.rain-probability > td:nth-child(4)").get_text().replace("%",""))
            rain_rate4=int(soup.select_one("#main-column > section > div.forecast-days-wrap.clearfix > section.tomorrow-weather > div.precip-table > table > tr.rain-probability > td:nth-child(5)").get_text().replace("%",""))
            
        ## 降水確率基準を超える場合にTrueにする
        if rain_rate2>=RAIN_SD or rain_rate3>=RAIN_SD or rain_rate4>=RAIN_SD:
            is_rain=True
        
        ## 取得要素を送信メッセージのJSON形式に変換
        get_data=f"[{site_name}]\n{date}({day}) {weather}\n最高気温{max_temp}度 最低気温{min_temp}度\n降水確率{rain_rate1}%{rain_rate2}%{rain_rate3}%{rain_rate4}%"
        message={"type":"text","text":get_data}
        
    except:
        ## エラーメッセージの登録
        get_data=f"\n[{site_name}]\n取得に失敗しました"
        print("取得エラー")
        
    finally:
        ## 送信メッセージリストに追加
        messages.append(message)

# API送信--------------------------
def send_message():
    headers={
        "Authorization":f"Bearer {TOKEN}",
        "Content-Type":"application/json"
    }
    
    body={
        "messages":messages
        }
    
    try:
        response=requests.post(ENDPOINT,headers=headers,json=body)
        
    except:
        print("送信に失敗しました。")
    
    finally:
        print(response.status_code)
        print(response.text)