【サーバーレスアーキテクチャ】AWS lambdaとCloudWatch Eventsを組み合わせてCron処理でLambda関数をスケジューリング処理する方法【バッチ/自動化】

ねこじゃすり

ワタオカねこじゃすりライトグレー

created by Rinker

PEPPY(ペピイ)

¥3,850 (2024/04/03 21:33:13時点 Amazon調べ-詳細)

猫を魅了する魔法の装備品！

【最新機種】GoPro hero11 Black

【日本国内正規品】 GoPro hero11 Black

created by Rinker

GoPro(ゴープロ)

¥62,000 (2024/04/03 21:42:08時点 Amazon調べ-詳細)

最新機種でVlogの思い出を撮影しよう！

[ノースフェイス] THE NORTH FACE メンズアウターマウンテンライトジャケット

created by Rinker

THE NORTH FACE(ザノースフェイス)

¥33,430 (2024/04/03 21:42:09時点 Amazon調べ-詳細)

防水暴風で耐久性抜群なので旅行で大活躍です！

ペヤングソースやきそば 120g×18個

created by Rinker

ペヤング

¥2,600 (2024/04/03 21:42:16時点 Amazon調べ-詳細)

とりあえず保存食として買っておけば間違いなし！

レッドブルエナジードリンク 250ml×24本

created by Rinker

Red Bull(レッドブル)

¥4,000 (2024/04/03 21:42:12時点 Amazon調べ-詳細)

翼を授けよう！

モンスターエナジー 355ml×24本 [エナジードリンク]

アサヒ飲料モンスターエナジー 355ml×24本 [エナジードリンク]

created by Rinker

モンスター

¥4,748 (2024/04/03 21:33:15時点 Amazon調べ-詳細)

脳を活性化させるにはこれ！

Bauhutte ( バウヒュッテ ) 昇降式 L字デスクブラック BHD-670H-BK

created by Rinker

Bauhutte(バウヒュッテ)

¥14,935 (2024/04/03 21:42:10時点 Amazon調べ-詳細)

メインデスクの横に置くのにぴったりなおしゃれな可動式ラック！

1 Lambda関数を定期実行しよう
- 1.1 サーバーレスを実現出来るLambda関数
- 1.2 Cronによる定期実行も可能
2 手順
3 終わりに

Lambda関数を定期実行しよう

サーバーレスを実現出来るLambda関数

先日まで、AWS Lambdaに関する記事をご紹介しました。

参考

【サーバーレスアークテクチャ開発】ローカル環境でAWSのLambdaスクリプトをPythonで実装する際に「python-lambda-local」で動作確認する際のインストール方法とやり方【Bot開発にオススメ】

参考

【Python3】コマンドラインから簡単にAWS lambdaに関数をアップロード出来ちゃう「lambda-uploader」のインストール方法と使い方【手順まとめ】

Lambda関数を使えば、サーバーを用意せずにAWSサービスをトリガーに処理を実装出来るので今注目されている技術です。

Cronによる定期実行も可能

そして、もう一つの強みが何と言ってもCron指定により定期実行をスケジューリング出来ることです！

これを知った時、サーバーを用意せずに実現出来ることが素晴らしすぎて感動しました。

また、設定自体もとても簡単に行うことが出来たので、今回は手順をご紹介致します。

手順

前提

サンプルとしては以下の記事で作成したLambda関数を利用します。

参考

【Python3】コマンドラインから簡単にAWS lambdaに関数をアップロード出来ちゃう「lambda-uploader」のインストール方法と使い方【手順まとめ】

しかし、定期実行の場合はeventを取得出来ない為、CloudWatch Logsに以下のようなエラーログが出てしまいます。

START RequestId: 043f221c-84c9-452a-a8a5-4c6a7c4d1171 Version: $LATEST
'url': KeyError
Traceback (most recent call last):
File "/var/task/lambda_function.py", line 4, in lambda_handler
response = requests.get(event['url'])
KeyError: 'url'

END RequestId: 043f221c-84c9-452a-a8a5-4c6a7c4d1171
REPORT RequestId: 043f221c-84c9-452a-a8a5-4c6a7c4d1171	Duration: 1.51 ms	Billed Duration: 100 ms Memory Size: 128 MB	Max Memory Used: 32 MB

START RequestId: 043f221c-84c9-452a-a8a5-4c6a7c4d1171 Version: $LATEST

'url': KeyError

Traceback (most recent call last):

File "/var/task/lambda_function.py", line 4, in lambda_handler

response = requests.get(event['url'])

KeyError: 'url'

END RequestId: 043f221c-84c9-452a-a8a5-4c6a7c4d1171

REPORT RequestId: 043f221c-84c9-452a-a8a5-4c6a7c4d1171 Duration: 1.51 ms Billed Duration: 100 ms Memory Size: 128 MB Max Memory Used: 32 MB

ですので、lambda_function.pyを以下のように修正しておきましょう。

import requests
 
def lambda_handler(event, context):
    response = requests.get('https://blogenist.jp')
    return 'Status : %d' % response.status_code

import requests

def lambda_handler(event, context):

response = requests.get('https://blogenist.jp')

return 'Status : %d' % response.status_code

トリガーの作成

まずはLambda関数の設定画面を開き、設定タブを選択した状態でDesignerのCloudWatch Eventsを選択します。

すると、下部エリアがトリガーの設定画面になるので新規のルール作成を選択し、ルール名・ルールの説明を入力したら、ルールタイプをスケジュール式にチェックを入れ、スケジュール式にcron形式を入寮します。

今回は試しに1分ごとに起動したいのでcron(0/1 * * * ? *)と入力しましょう。

そして、トリガーの有効化にチェックを入れたら追加ボタンをクリックしましょう。

CloudWatch Eventsがセットされていることを確認して保存ボタンをクリックします。

正常に保存されたらスケジュールに則ってLambda関数が実行されるはずです。

確認

では、CloudWatch Logsを覗いてみましょう。

10:24:16
START RequestId: fb9f45e6-19e9-43a4-98bd-60dc4a6bacd6 Version: $LATEST
START RequestId: fb9f45e6-19e9-43a4-98bd-60dc4a6bacd6 Version: $LATEST

10:24:16
END RequestId: fb9f45e6-19e9-43a4-98bd-60dc4a6bacd6
END RequestId: fb9f45e6-19e9-43a4-98bd-60dc4a6bacd6

10:24:16
REPORT RequestId: fb9f45e6-19e9-43a4-98bd-60dc4a6bacd6	Duration: 257.63 ms	Billed Duration: 300 ms Memory Size: 128 MB	Max Memory Used: 32 MB
REPORT RequestId: fb9f45e6-19e9-43a4-98bd-60dc4a6bacd6	Duration: 257.63 ms	Billed Duration: 300 ms Memory Size: 128 MB	Max Memory Used: 32 MB	

10:25:16
START RequestId: f7a91c50-8ea0-4780-ab21-ca398443de1c Version: $LATEST
START RequestId: f7a91c50-8ea0-4780-ab21-ca398443de1c Version: $LATEST

10:25:17
END RequestId: f7a91c50-8ea0-4780-ab21-ca398443de1c
END RequestId: f7a91c50-8ea0-4780-ab21-ca398443de1c

10:25:17
REPORT RequestId: f7a91c50-8ea0-4780-ab21-ca398443de1c	Duration: 272.58 ms	Billed Duration: 300 ms Memory Size: 128 MB	Max Memory Used: 32 MB
REPORT RequestId: f7a91c50-8ea0-4780-ab21-ca398443de1c	Duration: 272.58 ms	Billed Duration: 300 ms Memory Size: 128 MB	Max Memory Used: 32 MB