feedlyでタグ付けした記事を自動でメール配信する

2016/01/30

feedly-lambda-python

feedlyを使っていて、良記事や知っておいて欲しい記事とかを部門とかチームとかにまとめて配信するのですが、これも手でやってると結構面倒なので、APIを使って毎日自動配信する事にしました。

公式のAPI情報はこちらです。
http://developer.feedly.com/v3/

コードはGitHubで公開しています。
feedly-mail

トークン

https://cloud.feedly.com/v3/auth/devのリンク先で普段ログインしている方法でログインします。

facebookとGoogleの場合はメールで、Twitterの場合はダイレクトメッセージでURLが届きますのでそれをクリックします。

これでアクセストークンがとれるのでUSER IDと一緒に記録しておきます。

各パラメータ

各パラメータは下記を設定します。
私の場合はGmailで送信しています。

ADDRESS = SMTPメールアドレス
PASSWARD = SMTPパスワード
SMTP = SMTPサーバホスト名かIPアドレス
PORT = SMTPポート
to_addr = 宛先メールアドレス
to_ccs = [CCがあれば配列で]
WEATHERMAP_CITY = 天気が知りたい都市名
WEATHERMAP_API_KEY = OpenWeatherMap APIのアクセスキー
FEEDLY_TOKEN = Feedlyのトークン
FEEDLY_USER_ID = FeedlyのユーザーID(メールアドレスではない)

ADDRESS = SMTPメールアドレス

PASSWARD = SMTPパスワード

SMTP = SMTPサーバホスト名かIPアドレス

PORT = SMTPポート

to_addr = 宛先メールアドレス

to_ccs = [CCがあれば配列で]

WEATHERMAP_CITY = 天気が知りたい都市名

WEATHERMAP_API_KEY = OpenWeatherMap APIのアクセスキー

FEEDLY_TOKEN = Feedlyのトークン

FEEDLY_USER_ID = FeedlyのユーザーID(メールアドレスではない)

メール送信

smtplibでメールを送信します。

def create_message(from_addr, to_addr, subject, body, to_ccs, encoding):
    msg = MIMEText(body ,'plain', encoding)
    msg["From"] = from_addr
    msg["To"] = to_addr
    msg["Cc"] = ",".join(to_ccs)
    msg["Date"] = formatdate()
    msg["Subject"] = Header(subject, encoding)
    return msg

def send(from_addr, to_addrs, msg):
    smtpobj = smtplib.SMTP(SMTP, PORT)
    smtpobj.ehlo()
    smtpobj.starttls()
    smtpobj.ehlo()
    smtpobj.login(ADDRESS, PASSWARD)
    smtpobj.sendmail(from_addr, to_addrs, msg.as_string())
    smtpobj.close()

def create_message(from_addr, to_addr, subject, body, to_ccs, encoding):

msg = MIMEText(body ,'plain', encoding)

msg["From"] = from_addr

msg["To"] = to_addr

msg["Cc"] = ",".join(to_ccs)

msg["Date"] = formatdate()

msg["Subject"] = Header(subject, encoding)

return msg

def send(from_addr, to_addrs, msg):

smtpobj = smtplib.SMTP(SMTP, PORT)

smtpobj.ehlo()

smtpobj.starttls()

smtpobj.ehlo()

smtpobj.login(ADDRESS, PASSWARD)

smtpobj.sendmail(from_addr, to_addrs, msg.as_string())

smtpobj.close()

天気情報の取得

記事情報だけもなんだか味気ないのでついでに天気情報も送信します。
OpenWeatherMAP APIで現在の指定した都市の天気情報を取得します。

def weather_string():
    response_weather = requests.get("http://api.openweathermap.org/data/2.5/weather?q=" + WEATHERMAP_CITY + "&appid=" + WEATHERMAP_API_KEY)
    weather_data = json.loads(response_weather.text)
    condition_code = weather_data["weather"][0]["id"]
    return condition_string(condition_code)

def weather_string():

response_weather = requests.get("http://api.openweathermap.org/data/2.5/weather?q=" + WEATHERMAP_CITY + "&appid=" + WEATHERMAP_API_KEY)

weather_data = json.loads(response_weather.text)

condition_code = weather_data["weather"][0]["id"]

return condition_string(condition_code)

天気情報のコードを日本語に直しています。

def condition_string(condition_code):
    return_str = "分かりません。"
    if condition_code == 200:
        return_str = "軽い雷雨です。"
    elif condition_code == 201:
        return_str = "雷雨です。"
    ~中略~
    return "今の天気は" + return_str

def condition_string(condition_code):

return_str = "分かりません。"

if condition_code == 200:

return_str = "軽い雷雨です。"

elif condition_code == 201:

return_str = "雷雨です。"

~中略~

return "今の天気は" + return_str

実行関数

AWS Lambdaで実行していますのでこのように書いています。

def lambda_handler(event, context):
    try:
        now = datetime.now()
        subject = "ここ1週間の気になった記事です - " + now.strftime("%Y/%m/%d")
        body = "皆様\nおはようございます。xxです。\n\n" + weather_string() + "\n\n1週間以内の気になった記事を共有します。\n\n通勤中や寝る前などお暇な時にぜひどうぞ。\n新着記事から順に上に表示しています。\n\n"

        last_week_time=now-timedelta(7)
        unix_time = int(time.mktime(last_week_time.timetuple()))*1000

        headers = {'Authorization': FEEDLY_TOKEN}

        response_stream = requests.get('https://cloud.feedly.com/v3/streams/contents?streamId=user/' + FEEDLY_USER_ID + '/tag/global.saved&count=100&newerThan=' + str(unix_time), headers=headers)
        stream_data = json.loads(response_stream.text)

        stream_data_array=stream_data["items"]
        for stream in stream_data_array:
            tag_string=""
            tag_div=""
            for tag in stream["tags"]:
                if tag["label"] != "" and tag["label"] != "global.read":
                    tag_string = tag_string + tag_div + "[" + tag["label"] + "]"
                    tag_div = ","
            body = body + tag_string + "\n" + stream["title"] + "\n" + stream["alternate"][0]["href"] + "\n\n"

        msg = create_message(ADDRESS, to_addr, subject, body, to_ccs, 'utf-8')
        send(ADDRESS, [to_addr], msg)

    except Exception as e:
       print(e)
       raise e

def lambda_handler(event, context):

try:

now = datetime.now()

subject = "ここ1週間の気になった記事です - " + now.strftime("%Y/%m/%d")

body = "皆様\nおはようございます。xxです。\n\n" + weather_string() + "\n\n1週間以内の気になった記事を共有します。\n\n通勤中や寝る前などお暇な時にぜひどうぞ。\n新着記事から順に上に表示しています。\n\n"

last_week_time=now-timedelta(7)

unix_time = int(time.mktime(last_week_time.timetuple()))*1000

headers = {'Authorization': FEEDLY_TOKEN}

response_stream = requests.get('https://cloud.feedly.com/v3/streams/contents?streamId=user/' + FEEDLY_USER_ID + '/tag/global.saved&count=100&newerThan=' + str(unix_time), headers=headers)

stream_data = json.loads(response_stream.text)

stream_data_array=stream_data["items"]

for stream in stream_data_array:

tag_string=""

tag_div=""

for tag in stream["tags"]: