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

最後までお読みいただきましてありがとうございました！
【PR】「AWS認定試験対策 AWS クラウドプラクティショナー」という本を書きました。

@yamamanx

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

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

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

- AWS apigateway, AWS, bot, lambda, slack

: PyCharmにAWS CloudFormationプラグインをインストールして入力補完してみる

JetBrainsのPython統合開発環境(IDE)のPyCharmを1年ちょ …

: kintoneでEveryoneに権限が設定されているアプリをAWS Lambdaで一括チェックする

こないだ、kintone Cafeでユーザーが自由に作成している環境だと、どんな …

: JAWS DAYS 2018 「Cost-Driven AWS クラウドアーキテクチャデザインとコスト最適化方法 – Cost-Driven AWS Cloud Architecture Design : The Lean Startup on AWS」を聞きました

以下は、思ったことや気になったことをメモしていますので、必ずしも登壇者の発表内容 …

: AWS EC2 Amazon Linux にEC-CUBE3をnginx+MySql環境へインストール(手順検証中)

目次 EC2インスタンスを作成する各パッケージのインストールEC-CUBEインス …

: Selenium, Headless ChromeとAWS Lambdaで夜な夜なスクレイピング

このようなアーキテクチャで、Alexaスキルの開発を進めていまして、元となる情報 …

: ECR(Amazon Elastic Container Registry)にコンテナイメージをアップロードする

「Pandocサーバーのコンテナイメージを作成する」で作成したイメージをAWS …

: SendGridのイベントをAPI Gateway -> Lambda(Python) -> DynamoDBに格納する

SendGridのメールイベントログはコンソールで確認出来るのは直近7日分で一括 …

: AWS CloudWatch LogsエージェントでAmazon EC2上のNginxのaccess.log , error.log , php-fpm error.log , Linuxのmessages , secureログを収集する

目次参考ページEC2用のIAMロールを作成するEC2に CloudWatch …

: Amazon Aurora Serverless 課金確認

Amazon Aurora Serverlessを使い始めてみましたの記事で書い …

: AWS Summit 2016 Tokyoに参加してきました (Day2)

馬込は非常に良い天気です。泊まっている部屋が2Fでしたので窓を明けると歩いてい …

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

関連記事