AWSラムダ関数クエリSQS MessageIdとApiGateway

Question

私のApiゲートウェイのURLを呼び出すと、SQSで渡されたメッセージを挿入してキュー内のメッセージのIDを返すラムダ関数がトリガされます。 これで、API Gatewayの別のリソースを作成し、別のLambda関数を使用してキュー内のすべてのメッセージを出力しました。これは関数です：

import boto3 
import json 

def lambda_handler(event, context): 

    sqs = boto3.resource('sqs') 
    queue = sqs.get_queue_by_name(QueueName='<queue_name>') 

    messages = set() 
    for m in range(0, 9): 
     msg_list = queue.receive_messages() 
     for msg in msg_list: 

      messages.add(msg.body) 

    return list(messages) 

どのように関数を変更して、指定したIDのメッセージのみを取得できますか？ この パラメータを受信し、それをラムダ関数に渡すようにApiゲートウェイを設定するにはどうすればよいですか？

Answer 1

SQSはデータベースではありません。あなたはそれを「照会」できません。あるキーでメッセージを取得する必要がある場合は、キーと値のストレージを使用する方がよいでしょう。 ElastiCache RedisとDynamoDBはどちらもこの種の作業に最適です。