AWS Lambda 函数查询 SQS 消息 Id 和 Api 网关

Question

调用我的 Api Gateway 的 url 会触发一个 Lambda 函数，该函数插入在 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 网关来接收这个 参数并将其传递给 Lambda 函数？

Answer 1

SQS 不是数据库，您不能“查询”它。如果您需要通过某个键检索消息，则最好使用键值存储。 ElastiCache Redis 和 DynamoDB 都非常适合此类工作。