sqsでlambdaを呼び出しているのですが、あまりにも遅い

lambda1->sqs->lambda2と処理をしているのですが、最初のlambda1を実行してからlambda2が完了するまで数時間かかってしまうのですが、原因がわからずどのようにして速度を改善すればいいのかわからないです。
また、lambda1は五分ごとに20~50ほど実行され、queが溜まっていきます。

各lambdaとも実行時間は2分かからないぐらいです。
cloudwatch logsで確認したところlambda1からsqsまではすぐに呼び出され、sqsからlambdaへが時間がかかっているようです、、、
また、lambda1を実行すると利用可能なメッセージには数字は増えず、処理中のメッセージに溜まっていきます。

sqsからlambda2を実行する際に同時実行数の確認をしたのですが、デフォルトの状態でも、個別に設定しても変わりませんでした。

また、デッドレターキューに関して特に設定などしていないんですが、設定したら速度の改善などはあるのでしょうか。。？

sqsへの理解が足りてないことが全ての原因であると理解はしています。。。
まとまってない内容ですが、教えていただけると幸いです。

sqs設定について
最大メッセージサイズ256kb
メッセージ保持期間４日
デフォルトの可視性タイムアウト１時間
配信遅延〇秒
メッセージ受信待機時間〇秒
コンテンツに基づく重複排除　-
高スループット FIFO　-
重複排除スコープ　-
FIFO スループット制限　-

lambda2設定について
sqsトリガーに関して
バッチウィンドウ: 200
バッチサイズ: 60
同時実行数
修飾子 1
タイプバージョン
プロビジョニングされた同時実行 100
ステータス準備完了
詳細 -

sqs送信時のコード


message = {
        	"service"       : service,
        	"id"            : id
        }
        res = send_sqs_message(message)


def send_sqs_message(send_message):
    url = "https://sqs.ap-northeast-1.amazonaws.com/*******/ManagementRequest"
    obj = json.dumps(send_message)
    print("url")
    print(obj)
    try:
        print('===============')
        print('send_sqs_message')
        response = sqs.send_message(
            MessageBody = obj,
            QueueUrl = url,
            DelaySeconds = 0
        )
        print('===============')

    except Exception as e:
        print('=====Error=====')
        print('send_sqs_message')
        print('ERROR:' + str(e))
        print('===============')
        return None

    return response

sqs受け取り時のコード

def lambda_handler(event, context):

    print('event')
    print(event)

    for record in event['Records']:  # 引数；event内の'Records'を配列要素分Loop
        curBody = json.loads(record['body'])  # 'body'内のハッシュ要素をjson形式に変更(※)
        service = curBody["service"]
        table_id = curBody["id"]

175

2021/10/24 05:41

>cloudwatch logsで確認したところlambda1からsqsまではすぐに呼び出され、sqsからlambdaへが時間がかかっているようです、、、 >また、lambda1を実行すると利用可能なメッセージには数字は増えず、処理中のメッセージに溜まっていきます。この辺りのエビデンスとなるログやスクショの記載お願いします。

pro_hro

2021/10/24 06:28

>cloudwatch logsで確認したところlambda1からsqsまではすぐに呼び出され、sqsからlambdaへが時間がかかっているようです、、、 lambda1を実行するとsqsでの処理中のメッセージの数が増えるためそう判断しました。また、lambdaでsqsに送信後lambdaの処理が終わっているのもそう判断した要因の１つです >また、lambda1を実行すると利用可能なメッセージには数字は増えず、処理中のメッセージに溜まっていきます。質問を修正し、添付します。ご確認よろしくお願いします。

175

2021/10/24 06:38

キューの配信遅延時間とメッセージ待機時間の値を確認してみてください

175

2021/10/24 06:42

あれ？「あまりにも遅い」とのことですが、ある程度時間が経つと利用可能なメッセージの数は増えていくのでしょうか？

pro_hro

2021/10/24 06:43

そこらへんの設定も付け加えるべきでしたね、、、追記します。よろしくお願いします。

pro_hro

2021/10/24 06:47

利用可能なメッセージの数に関してなのですが、こちらの数字が０以外の数字になったところをまだ一度も見たことがありません、、、

175

2021/10/24 06:49

メッセージの中身が意図した通りの内容であるか確認してみてください

175

2021/10/24 06:58 編集

以下のrequiredのプロパティが全て存在しますか？https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/SQS.html#sendMessage-property

175

2021/10/24 07:16

あと必要な権限が全て付与されているかの確認もしたほうが良いと思います

175

2021/10/24 07:23

https://confrage.jp/aws%E3%81%AEsqs%E3%81%AE%E4%BD%BF%E3%81%84%E6%96%B9/ こちらの記事が参考になりそうです

pro_hro

2021/10/24 08:10

ありがとうございます。リンク確認させていただきます。 sqsを送信するコード、受け取る際のコードを追記します。権限に関しては時間がかかるとはいえ処理はされているので問題ないと考えているのですが、再度確認してみます。ありがとうございます。

175

2021/10/24 08:25

あー、分かったかも「処理中のメッセージ」はすでにlambda2で処理中のものですね単純にlambda2の実行時間が長いだけではないでしょうか。

pro_hro

2021/10/24 11:55

ありがとうございます。単体で実行すると数分もかからない程度なのですが、同時に実行すると時間がかかるというようなことはあるのでしょうか。。？

175

2021/10/24 16:18 編集

設定値を記載して下さりましたが、lambda2の同時実行数は１でしょうか？あと、バッチサイズを１に変更してみてください。挙動としてはバッチサイズに指定した数までメッセージが増えると、ひとかたまりのメッセージバッチをイベントとしてlambdaを起動するそうです。バッチウィンドウは、バッチサイズまでメッセージ数が増えるのを待機する時間（秒）のようです。

pro_hro

2021/10/25 00:56

ありがとうございます。編集し、様子を見てみます。