slackのbotに天気を教えてもらう(Python on AWS Lambda + API Gateway)

2016/05/04

slack-apigateway-lambda-weather

slackのbotにAPIの定番ともいえる天気情報を教えてもらいました。

環境は手前味噌ですが「slackのbotをAWS Lambda(Python)+API Gatewayで構築」をご参照ください。

LivedoorのWeather Hack APIを使う

Open Weather MAP APIとか使ってたのですが、国内のサービスの方が日本の天気は精度が高そうでしたので。
その中でもキーとかいらない一番お手軽なAPIがLivedoorのWeather Hack APIでしたので使わせていただきました。

詳しい仕様は「お天気Webサービス仕様」をご確認ください。

投稿に「天気」が含まれている際に天気情報を見に行くようにしました。

city_idは公開されているXMLを見に行けば動的に出来ますがそんなに全国いらないので固定にしています。

import wikipedia
import requests
import json

def lambda_handler(event, context):
    try:
        user_name = event['user_name']
        text = event['text']

        msg = user_name + 'さん '

        if text == '':
            msg += 'はい！'
        elif text.find('おはよ') > -1:
            msg += 'おはようございます！'
        elif text.find('こんにちは') > -1:
            msg += 'こんにちは'
        elif text.find('疲') > -1 or text.find('お先') > -1:
            msg += 'お疲れさまでした！'
        elif text.find('って何') > -1:
            msg += wikipediaSearch(text)
　　　　　　　　　　　　　　　　elif text.find('天気') > -1:
            msg += getWeatherInformation(text)
        else:
            msg += 'その言葉は分からないから調べてみました。:sweat:\n' + wikipediaSearch(text)

        payload={'text':msg}
        return payload
    except Exception as e:
        print(e)
        raise e

def getWeatherInformation(text):
    weather_api_url = 'http://weather.livedoor.com/forecast/webservice/json/v1'
    response_string = ''
    city_id = ''
    if text.find('大阪') > -1:
        city_id = '270000'
    elif text.find('東京') > -1:
        city_id = '130010'
    elif text.find('愛知') > -1 or text.find('名古屋') > -1:
        city_id = '230010'
    else:
        city_id = '270000'
        response_string += '場所がよくわからないもんでとりあえず'

    try:
        params = {'city':city_id}
        response = requests.get(weather_api_url,params=params)
        response_dict = json.loads(response.text)
        title = response_dict["title"]
        description = response_dict["description"]["text"]
        response_string += title + "です。:nerd_face:\n\n"
        forecasts_array = response_dict["forecasts"]
        forcast_array = []
        for forcast in forecasts_array:
            telop = forcast["telop"]
            telop_icon = ''
            if telop.find('雪') > -1:
                telop_icon = ':showman:'
            elif telop.find('雷') > -1:
                telop_icon = ':thunder_cloud_and_rain:'
            elif telop.find('晴') > -1:
                if telop.find('曇') > -1:
                    telop_icon = ':partly_sunny:'
                elif telop.find('雨') > -1:
                    telop_icon = ':partly_sunny_rain:'
                else:
                    telop_icon = ':sunny:'
            elif telop.find('雨') > -1:
                telop_icon = ':umbrella:'
            elif telop.find('曇') > -1:
                telop_icon = ':cloud:'
            else:
                telop_icon = ':fire:'

            temperature = forcast["temperature"]
            min_temp = temperature["min"]
            max_temp = temperature["max"]
            temp_text = ''
            if min_temp is not None:
                if len(min_temp) > 0:
                    temp_text += '\n最低気温は' + min_temp["celsius"] + "度です。"
            if max_temp is not None:
                if len(max_temp) > 0:
                    temp_text += '\n最高気温は' + max_temp["celsius"] + "度です。"

            forcast_array.append(forcast["dateLabel"] + ' ' + telop + telop_icon + temp_text)
        if len(forcast_array) > 0:
            response_string += '\n\n'.join(forcast_array)
        response_string += '\n\n' + description
    except Exception as e:
        response_string = 'すいません。天気検索でエラーを起こしてしまいました。改善出来るように頑張ります。:cold_sweat:\n' + e.message + '\n' + str(e)
    return response_string

import wikipedia

import requests

import json

def lambda_handler(event, context):

try:

user_name = event['user_name']

text = event['text']

msg = user_name + 'さん '

if text == '':

msg += 'はい！'

elif text.find('おはよ') > -1:

msg += 'おはようございます！'

elif text.find('こんにちは') > -1:

msg += 'こんにちは'

elif text.find('疲') > -1 or text.find('お先') > -1:

msg += 'お疲れさまでした！'

elif text.find('って何') > -1:

msg += wikipediaSearch(text)

　　　　　　　　　　　　　　　　elif text.find('天気') > -1:

msg += getWeatherInformation(text)

else:

msg += 'その言葉は分からないから調べてみました。:sweat:\n' + wikipediaSearch(text)

payload={'text':msg}

return payload

except Exception as e:

print(e)

raise e

def getWeatherInformation(text):

weather_api_url = 'http://weather.livedoor.com/forecast/webservice/json/v1'

response_string = ''

city_id = ''

if text.find('大阪') > -1:

city_id = '270000'

elif text.find('東京') > -1:

city_id = '130010'

elif text.find('愛知') > -1 or text.find('名古屋') > -1:

city_id = '230010'

else:

city_id = '270000'

response_string += '場所がよくわからないもんでとりあえず'

try:

params = {'city':city_id}

response = requests.get(weather_api_url,params=params)

response_dict = json.loads(response.text)

title = response_dict["title"]

description = response_dict["description"]["text"]

response_string += title + "です。:nerd_face:\n\n"

forecasts_array = response_dict["forecasts"]

forcast_array = []

for forcast in forecasts_array:

telop = forcast["telop"]

telop_icon = ''

if telop.find('雪') > -1:

telop_icon = ':showman:'

elif telop.find('雷') > -1:

telop_icon = ':thunder_cloud_and_rain:'

elif telop.find('晴') > -1:

if telop.find('曇') > -1:

telop_icon = ':partly_sunny:'

elif telop.find('雨') > -1:

telop_icon = ':partly_sunny_rain:'

else:

telop_icon = ':sunny:'

elif telop.find('雨') > -1:

telop_icon = ':umbrella:'

elif telop.find('曇') > -1:

telop_icon = ':cloud:'

else:

telop_icon = ':fire:'

temperature = forcast["temperature"]

min_temp = temperature["min"]

max_temp = temperature["max"]

temp_text = ''

if min_temp is not None:

if len(min_temp) > 0:

temp_text += '\n最低気温は' + min_temp["celsius"] + "度です。"

if max_temp is not None:

if len(max_temp) > 0:

temp_text += '\n最高気温は' + max_temp["celsius"] + "度です。"

forcast_array.append(forcast["dateLabel"] + ' ' + telop + telop_icon + temp_text)

if len(forcast_array) > 0:

response_string += '\n\n'.join(forcast_array)

response_string += '\n\n' + description

except Exception as e:

response_string = 'すいません。天気検索でエラーを起こしてしまいました。改善出来るように頑張ります。:cold_sweat:\n' + e.message + '\n' + str(e)

return response_string

※Wikipediaの検索は別記事「slackのbotにWikipediaを調べてもらう(Python on AWS Lambda + API Gateway)」をご参照ください。

結果は絵文字を使って直感的に分かればいいな〜って感じにしてます。

weather-slack

@yamamanx

開発ベンダー5年、ユーザ企業システム部門通算9年、ITトレーナー1年目のSoftware Engineerです。
質問はコメントかSNSなどからお気軽にどうぞ。
出来る限りなるべく答えます。

このブログの内容/発言の一切は個人の見解であり、所属する組織とは関係ありません。

また、勉強会やイベントのレポートは自分が気になったことをメモしたり、聞いて思ったことを書いていますので、登壇者の意見や発表内容ではありません。

- AWS apigateway, AWS, bot, lambda, slack

: AWS Well-Architected フレームワークによるクラウドベストプラクティスのセッションを聞いたので自アカウントの環境を確認してみる

AWS Summit Tokyo 2017で「AWS Well-Architec …

: TwilioからのリクエストをAPI Gateway+LambdaでTwimlを返して処理する

Twilioで着信した時のリクエスト先としてTwimlをWebサーバやS3で用意 …

: EC2とRDSのMySQLを他のAWSアカウントへ移設する

他のAWSアカウントへシステムごと移設した場合の手順です。構成はEC2とRDS …

: Amazon Linux にnodejsとmongoDBをインストールする

EPEL リポジトリを利用してnodejsとnpmをインストールする [cray …

: 「JAWS-UG in AWS Cloud Roadshow 2017 大阪」で運営をしました

AWS Cloud Roadshow 2017 大阪のナイトイベントで、「JAW …

: RedmineをELB(ALB)でAutoScalingグループへ負荷分散

高可用なRedmineを作るためのELBの設定です。高可用なRedmine R …

: Amazon Cognito User Poolsのデモをしてみました

AWS Summit 2016 Tokyoのアップデートおっかけ会をJAWS-U …

: 再会の日 ~re:Union 2018 Osaka by JAWS-UG~

8/5は大阪でre:Unionでした。「再会」と名うったこのイベントは、6月に …

: Amzon Linux のApacheでRedmineとWordPressをバーチャルホストで共存する

EC2とRDSを節約しようと思いまして、Redmineを動かしてるとこに検証用W …

: RDS + VPC + Lambda + API Gateway + CloudFront + WAF + ACMでAPIを構築する

RDSのMySQLの情報を与えられたリクエストをキーにしてjsonで返すAPIを …

PREV: slackのbotにWikipediaを調べてもらう(Python on AWS Lambda + API Gateway)
NEXT: JAWS-UG Osaka 第14回勉強会「DIY」〜自社内システムを作る側からの物申す〜に参加、運営、登壇しました

slackのbotに天気を教えてもらう(Python on AWS Lambda + API Gateway)

LivedoorのWeather Hack APIを使う

ad

ad

関連記事