当前位置: 首页 > 知识库问答 >
问题:

当消息出现在SQS队列中时,触发AWS中的Lambda函数

弓玉书
2023-03-14

共有1个答案

徐兴昌
2023-03-14

不直接支持从SQS队列调用Lambda函数。您可以在这里看到可用触发器的列表:http://docs.aws.amazon.com/lambda/latest/dg/invoking-lambda-function.html

可能的解决办法:

  1. 用Kinesis或Dynamodb替换SQS队列。两者都可以在更新时触发Lambda函数。
  2. 在SQS前注射SNS。SNS可以向SQS添加项并触发Lambda函数。
    null
 类似资料:
  • 我有一个触发Lambda函数的SQS队列。我正在尝试解析SQS消息并提取相关数据。我特别尝试提取s3对象键和s3 bucket arn。 我当前的Lambda函数: CloudWatch中显示的我的SQS消息: 最后一个错误是: 我还尝试了objectKey=record['Records][0]['s3']['object']['key']。谢谢

  • 当消息到达SQS时,如何触发AWS Lambda函数(Python),并将消息传递给HTTPendpoint,在处理API中的数据后,从SQS队列中删除消息?如何在Python lambda中实现这一点?

  • 我有一个S3 bucket上传通知,将消息放入SQS队列。SQS队列触发lambda函数。我试图从触发lambda函数的SQS消息中提取上传的文件名。我的SQS事件记录在打印到CloudWatch日志时如下所示: 使用此代码: 使用['s3]['object]['key']访问文件名“activity1”。有效负载字符串上的“png”显示以下错误: 如何从lambda函数访问文件名?

  • 我有一个lambda函数,负责检查服务器状态。当SQS收到新消息时需要调用它,并且不允许在SQS中更改任何内容。我尝试使用SQS Lambda触发器,但它会将消息推送到Lambda函数中= 我正在寻找处理这个问题的方法。我尝试使用CloudWatch来处理这个问题,但我不知道这是否可能?当SQS收到新消息时,Cloudwatch如何触发Lambda函数? 提前谢谢。

  • 但是,如果我的Lambda不期望任何输入,它将自己转到SQS并拉出消息,有输入有意义吗?我是否可以让它无效,或者甚至完全使用其他方法签名(当然,在本例中不实现那个接口)?

  • 我已经部署了一个AWS Lambda函数,它在SQS队列接收到消息时触发。该函数向Rest API发出请求,如果响应不是Ok,则需要再次处理SQS消息。 这就是为什么我需要将消息重新发送到队列,但我更愿意以编程方式删除SQS消息,尽管我找不到如何配置SQS。我尝试过消息保留,但似乎触发器事件会导致消息被删除。