Lambda関連のことを調べてみた2023年02月05日

AWS Lambdaに固定IPを付与する時の考慮事項(NAT Gatewayは0.062ドル/時､月約45ドル）

AWSの請求書を見たら想定外に高かったので調べたらNAT Gatewayでした｡
t4g.xlarge（vCPU:4､メモリ:16GB)を借りられる(3年予約)料金じゃないか･･･｡

[](https://gyazo.com/79c797e8431503a4fbc82fd6a53ca65d)

これは､ある外部システムとの連携機能をAWS Lambdaで実装したのですが､IP制限に対応するために固定IPを持たせる必要があったため｡

不覚にも発生する料金はElastic IPだけだと思いこんでました｡涙
反省｡

エンジニアインターン10日目

今日はpythonを使ってスクレイピングをした。Beautifulsoupを使ってDOM要素を取り、得た情報を配列に渡して、DBに保存する仕組みだった。複数のページからスクレイピングをしたかったため、urlを配列に渡して、ページごとに正しい値を取るようにした。lambda上でtestをしてエラーを解決しながら進めた。やはり、初心者だと、エラーを解決するのに時間がかかってしまったり、工夫がまだまだ足りていない。そこで、先輩エンジニアに質問することでエラーに対する工夫の仕方や考え方などを教えていただくことができる。自分で検索して探すことももちろん大切であるが、いつでも質問できて、改善させてくれるような環境を持つこともとても大切であると考えた。そろそろインターンを初めて1か月を立とうとしている自分にもタスクに対する責任感も出てきて、日々成長した姿を証明していきたいと思う。しかし、まだまだ分からないことの方が多い。失敗を恐れず、チャレンジを辞めずに成長していきたい。

AWS Lambda + Python で並列処理

AWS Lambda で Python の multiprocessing を扱おうとしたら少しハマったのでメモしておく。

:::note warn
この記事内のコードはすべて AWS Lambda の Python 3.9 ランタイムで実行する想定で書かれています。
:::

## 例題
例えば、以下のような Lambda 関数があるとする。

“` python:main.py
from time import sleep

def square(n: int) -> int:
“””1秒かけて入力値の2乗を返す関数”””
sleep(1)
return n ** 2

def handler(event, context):
return [square(i) for i in range(5)]
“`

この関数の実行には5秒かかってしまうため、 `square` 関数を並列処理して実行時間を短縮したい。

## asyncio 版
まずはシンプルにイベントループで非同期処理できないか考える。

Python の非同期処理と言えば `a

Lambdaコンテナをローカルでデバッグする方法

## 概要
Lambdaをコンテナ毎デプロイすることができるようになりましたが、
今回は、ローカル環境でデバッグする方法について書き記します。
わざわざデプロイしてクラウド環境上でテストする手間が省けます。

## 方法

ファイル構成は以下となります（ServerlessFrameworkを利用しています）
“`
aws-python-docker-demo
├── Dockerfile
├── README.md
├── app.py
├── requirements.txt
└── serverless.yml
“`

今回デバッグ用に用意したコードはこちらです。
シンプルにリクエストの結果を返却するコードを書いています。

“`app.py
import json
import requests

def handler(event, context):

res = requests.get(“http://example.com”)

response = {
“statusCode”: 200,
“body”: re

ServerlssFramework でLambdaコンテナをデプロイ

## 概要

Lambdaの関数コードをコンテナイメージでデプロイすることができますが、
今回はServerlessFrameworkを使って簡単にクラウド環境にデプロイする手順を書き記します。

## 手順

1.サンプルコードを作成

“`
$ serverless create –template aws-python-docker –path aws-python-docker-demo
✔ Project successfully created in “aws-python-docker-demo” from “aws-python-docker” template (3s)
“`

2.デプロイコマンド実行

“`
$ serverless deploy

Deploying aws-python-docker-demo to stage dev (ap-northeast-1)

✔ Service deployed to stack aws-python-docker-demo-dev (187s)

functions:
hello: aws-py

AWS Lambda(node.js)でyoutube APIを利用してJSON作成した話

## どんな記事
・AWSを使ってyoutube APIにアクセスするLambda関数を作成したときのお話
　node.jsの作成例が少なかったのでこんな感じでうまくいったよが伝われば・・

## 利用技術
・AWS Lambda
・AWS S3
・youtube-node(youtube API) ※google developerに登録する
・node.js 16

## 前提条件
・node.js 16での開発

パッケージのインストール
“`
npm install youtube-node
npm install aws-sdk
“`

## 作成したコード（抜粋）
“`
const AWS = require(‘aws-sdk’);
const s3 = new AWS.S3({‘region’:’＜地域＞’});

const Youtube = require(‘youtube-node’);
const youtube = new Youtube();

exports.handler = function(event, context, callbac

【備忘】Api Gatewayのステージ変数とLambdaのエイリアスが繋がることを理解する

# まえがき
Api GatewayとLambdaで構成されているサーバーレス環境の話。
Api Gatewayの複数のエンドポイントと同じLambda関数を紐付けることができます。
たとえばdev環境とprod環境があってLambda関数がひとつである場合、dev環境への変更がprod環境へも反映されることになります。
dev環境で行った変更をテストした上でprod環境へ反映させたい場合、Api Gatewayのステージ変数とLambdaのエイリアスが役に立ちます。
ネット上にやり方は書いてありましたが、図解が見つけられなかったため、ここに備忘として残したいと思います。
細かい設定値や設定方法はネット上に多く存在したため省きます。

# 図解
いきなり結論ですが、Api Gatewayのステージ変数とLambda関数のエイリアスのつながりは以下のようになります。
Lambda側ではエイリアス名を設定し、Api Gateway側ではステージ変数を設定することで、連携できるようになります。
![image.png](https://qiita-image-store.s3.ap-nort

Lambda関数からAmazon SQSにデータを送信する時ハマったこと

# はじめに
Lambda関数からAmazon SQSにデータを送信する時、ハマったことがあったので備忘録として残しておく。

# 前提条件
– Lambda関数からAmazon SQSにデータを送信する
– Lambda関数はVPC内のプライベートサブネットに設置している
– Lambda関数のIAMロールはAmazon SQSに対してフルアクセス権限を付与している
– Lambda関数はNode.jsで作成

# 起こったこと
上記前提条件のもとLambda関数を実行するとタイムアウトしてしまった。
そのときのソースと実行結果はこちら
AWS公式サンプルソースのほぼコピペ
https://docs.aws.amazon.com/ja_jp/sdk-for-javascript/v2/developer-guide/sqs-examples-send-receive-messages.html

“`js
var AWS = require(‘aws-sdk’);
AWS.config.update({region: ‘ap-northeast-1’});

var sqs = n

AWS lambdaでEmacs key bindingを使う

# きっかけ
MacBookでAWS Lambdaでコーディング中

「下の行に移動しよう。`ctrl` + `N`を連打っと。」

（新しいファイルが大量に作成された）

「おいいぃぃぃぃい！！！！」

# やったこと
LambdaのPreferenceを起動
– 歯車アイコンをクリック

画像のように「Emacs」を選択。
![image.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/2950855/2e06a2

【EC2】Lambdaから時刻指定でEC2を自動起動・停止を時刻実現する

# EC2の自動起動・停止を実現したい！

https://qiita.com/YujiHamada3/items/3caccdaded527548432b

上記記事の改良版です。上記記事では自動起動・停止をhour単位でしか指定できず、一日に一度しか指定できませんでした。
それに加えて今回は
– 時刻まで指定できる（10分ごと）
– 複数時刻を指定できる
– 平日指定できる

の機能を追加しました。
今回はLambdaを何度も呼び出したくないので10分ごとにしましたが、Lambdaを毎分呼び出せば、分指定までできるようになります。

# EC2のタグの設定

タグはこの様に設定します。
これだと
平日16時30分に起動して16時40分に停止する。
平日16時50分に起動して17時00分に停止する

【別アカウントのLambda】を実行可能なLambdaをNode18 + AWS SDK for JavaScript v3で構築してみる

## 先に結論だけ知りたい人のために （クロスアカウントでLambdaからLambdaをコールする方法）

この記事の要点を列挙するよ。

– 実行環境がNode18のLambdaにはAWS SDK for JavaScript v3が最初からインストールされていて便利だよ
– Invoke APIで別アカウントのLambdaをコールするよ
– コールされる対象の【別アカウントのLambda】には、リソースベースのポリシーが必要だよ
– コールする側のLambdaには、アイデンティティベースのポリシーが必要だよ

“`json:コールされる対象の【別アカウントのLambda】に付与するリソースベースのポリシー
{
“Version”: “2012-10-17”,
“Id”: “default”,
“Statement”: [
{
“Sid”: “[任意の名前]”,
“Effect”: “Allow”,
“Principal”: {
“AWS”: “arn:aws:iam::[呼び出す側のAWSアカウントI

VPCアクセス可能なlambda関数をamplifyで作成する方法 発展版 ~ env毎にVPCを切替可能とする

先に以下の記事を投稿しました

https://qiita.com/kujiraza/items/458629d5a3d210ad45ad

この記事ではamplifyで1つのenvしか用いない前提で記載しています。
本記事ではこの記事（以降元記事と記載します）を発展させて、envを複数用意した場合にenv毎に別のVPCに接続するための手順を記載します。

# やること

[元記事の手順](https://qiita.com/kujiraza/items/458629d5a3d210ad45ad#%E6%89%8B%E9%A0%86)をベースとして、以下の部分を変更してlambdaを作成します。

– セキュリティグループIDとサブネットグループIDをパラメータ化し、値は別ファイルに設定する
– 値の設定先としてenv毎にパラメータを指定できる`amplify/team-provider-info.json`を使用する

# 前提

`amplify add env`により、devに加えてstgを作成済みとします。 これ以外は[元記事の前提](https://qiita.com/ku

VPCアクセス可能なlambda関数をamplifyで作成する方法

欲しい情報にたどり着くまでに苦労したので残しておきます。

# やること

amplifyで作成したバックエンド用lambda関数に対して、コンソール画面からVPCの設定を変更すると、`amplify push` や `amplify publish`コマンドを実行するタイミングでVPCの設定が消えてしまいます。
そこで本記事では、lambdaのコンソール画面をいじらずにamplifyのみでVPC設定を行い、上記のような場合でも設定が消えないようにするための手順を記載します。

# 前提

– amplifyのバージョン: 10.6.2
– amplifyプロジェクト名： vpctestapp ※作成済み
– 接続先VPCにプライベートサブネット3つとセキュリティグループを1つ作成済み
（パブリックサブネットへの接続は試していません）
– amplifyを実行できるよう設定したcloud9を利用

以上の環境でlambda関数`vpclambda`を新規追加する場合を想定して、手順を記載します。

# 手順

1. 【事前準備】lambdaの新規作成
1. lambdaのテンプレ

Amazon Timestreamからboto3でデータを取得する

# はじめに
[センサからのデータをAmazon Timestreamに格納した](https://qiita.com/ckw-1227/items/82f3bc0d6c2e689411a5)ので、今度はデータを取り出したい。
データの取得方法をLambdaでpython3.9/boto3を使って確認する。

# Timestreamテーブル内のデータ
Timestreamは各項目(メジャー)ごとに1レコードを使う形で格納される。
今回の例ではセンサの位置情報（lat/lon）、温度(temp)、湿度(humi)が格納されている。時間間隔は基本的に3分毎。
| simId(ディメンション) | timestamp(ディメンション) | measure_name | time | measure_value::double |
|:-:|:-:|:-:|:-:|:-:|
| sim_id | 1674918682708 | lat | 2023-01-28 15:11:24.416000000 | 35.1 |
| sim_id | 1674918682708 | lon

AWS EventBridge S3にファイルが格納されたことを起点にlambda関数を実行する（EventBridge）

# 概要

– S3にファイルがアップロードされたことを起点にlambda関数を実行するためにEventBrigdeで必要な設定をまとめる。

# 情報

– EventBridgeに関しての簡単な情報は下記にまとめてある。

https://qiita.com/miriwo/items/ea12cdba9a1856cf6bd8

# 設定

## S3の設定

1. 新規でバケットを作成し、「look」フォルダを作成する。
1. 当該バケットの「プロパティ」のタブに移動する。
1. 「Amazon EventBridge」の設定部分まで移動し「編集」をクリックする。
1. ラジオボタンでONを選択して「変更の保存」をクリックする。

![test-s3-upload-event-bu

AWS SDK V3 のSQS(Simple Queue Service)で、いくつか動作確認した話（AWS SDK V2 → V3 移行Tips）

# はじめに

https://qiita.com/Syoji_Yonemoto/items/09883e57643583ef39af

引き続いて、今度は、SQS（Simple Queue Service）についても確認しました。
やはり初回（Firehose）の運が悪かっただけで、基本は互換できてそうだという感触になりつつありますが、自分のメモも兼ねてるので確認できた範囲をまとめていきます。

# 結論
SQS（Simple Queue Service）に関しては、私が普段使うメソッド群については、問題ありませんでした。

# V2 と同じ使い方で問題なく動作確認できたメソッド

+ sendMessage
+ receiveMessage
+ deleteMessage
+ getQueueAttributes

# 余談（雑多な感想）
受信・送信・削除・状態確認、一通りLambdaからSQSを活用する際に利用するAPIは試しましたが、V2の時と変わらぬ使い方ができて良かったです。

https://qiita.com/Syoji_Yonemoto/items/e619d

Pythonコードの中に記載されたHTMLテキストをブラウザで表示する(Api Gateway,Lambda)

# 書くきっかけ
Pythonコードの中に直書きしたHTMLを、クライアントからリクエストがあったときにブラウザで表示するコードを書いてみました。
自分の話で恐縮ですが、ちょっとApi GatewayとLambdaのテストをしてみたいと思ったときに、HTMLレスポンスが返せる簡単なLambda関数を用意したくなります。
そういった際に使えるのではと考えました。
# 使うもの
AWSで以下のものを使います。
* Api Gateway
* Lambda (Python 3.9)

# やってみる
## Lambda
以下の設定値でLambda関数を作成しました。ほかはデフォルトの設定値です。
| 項目 |設定値|
|:———–|:———–|
|関数名|htmlResponseFunc|
|ランタイム|Python 3.9|
|ハンドラ|lambda_function.lambda_handler|
|アーキテクチャ|x86_64|

## コード
`string`型でHTMLを記述し、それを`bytes`型に変換するところがポイントだと思います。
“`pyt

【Python】AWS SAMでLambdaの外部モジュールのバージョンを固定する

# はじめに
外部モジュールを使用するLambdaではモジュールをアップロードする必要があります。
AWS SAMを使うと簡単にソースコードとモジュールを一緒にアップロードする事が可能です。
AWS SAMである関数に久しぶりにdeployを行った時に、モジュールのバージョンを固定する必要がありました。

# やらかし先生
RDSに接続するPythonのLambdaで `pymsql`を使用しています。
RDS接続には関与しない変更を行いデプロイしたところ、RDSへの接続がエラーになりました:scream:

原因としては`pymysql`のバージョンが0.9系から1.0系に変更されていたため、同じ構文では接続が出来なくなっていました。
そのため`pymysql`のバージョンを0.9系に固定する回避策を行いました。

# モジュールのバージョン固定方法
## 結論
**requirements.txt** でバージョンを明記します

“`
例 pymysqlを0.9.3のバージョンを指定したい時
pymysql == 0.9.3
“`

## 記述方法について
上記の指定方法はAW

[AWS]Lambdaに送られるIot topicのpayloadにtopic名を含める方法

# はじめに
LambdaをトリガーするIot topic ruleのtopic名を取得する必要があったので、そのやり方について調べてみました。

# やりたいこと
Iot topicへのメッセージ発行をトリガーにLambda関数を実行し、そのLambda関数のhandlerのeventに渡されるpayloadに、該当topicのtopic名を含めたい。

図で表すとこのようなイメージ

# やり方
結論から言うと、topic ruleのクエリでtopic()関数を使うことで実現可能です。

試しにIot topic ruleを作成し、Lambdaトリガーを設定してみます。
Iot Core管理コンソールを開き、「メッセージのルーティング > ルール」をクリックします。
「ルールを作成」をクリックします。
![image.png](https

AWS RDSのインスタンス追加時にクラスターのタグを引継ぐ

# TODO
* コンソール上、急ぎリーダーを追加すると、タグ登録漏れに気付かない。
* 別途タグ未登録監視をしているが、できれば監視を減らしたい。

# 対策
* LambdaでRDSのCreateイベントを拾い、タグ登録する

# Lambda
“`python:lambda_handler Python3.9
import json
import boto3
from botocore import response

def lambda_handler(event, context):
tagkey = “project” #必須タグ
dBClusterIdentifier = event[“detail”][“responseElements”][“dBClusterIdentifier”]
dBInstanceArn = event[“detail”][“responseElements”][“dBInstanceArn”]

client = boto3.client(‘rds’)
response = client.de