处理SQS事件的函数的预期响应是什么？
处理SQS事件的函数的预期响应是成功处理该事件并返回一个成功的响应码。在处理SQS事件的函数中，通常会执行一些业务逻辑，如读取消息内容、处理消息、更新数据库等操作。函数的预期响应应包括以下几个方面：
- 确认接收：函数应首先确认接收到SQS事件，并返回一个成功的响应码，如200 OK。这表示函数已成功接收到事件并开始处理。
- 处理事件：函数应根据业务需求，对接收到的SQS事件进行处理。这可能包括解析消息内容、执行相应的业务逻辑、调用其他服务或函数等操作。
- 错误处理：如果在处理过程中发生错误，函数应捕获并处理这些错误。错误处理可以包括记录错误日志、发送通知、回滚操作等。同时，函数应返回一个错误的响应码，如500 Internal Server Error，以指示处理过程中出现了问题。
- 完成处理：当函数成功处理完SQS事件时，应返回一个成功的响应码，如200 OK。这表示函数已成功处理该事件，并可以继续处理下一个事件。
需要注意的是，处理SQS事件的函数应具备一定的容错能力，能够处理重复事件、处理超时事件、处理并发事件等情况。此外，函数的性能和可伸缩性也是需要考虑的因素，可以通过使用腾讯云的相关产品来提高函数的性能和可靠性，如云函数 SCF（Serverless Cloud Function）和消息队列 CMQ（Cloud Message Queue）等。
更多关于腾讯云相关产品的信息，可以参考腾讯云官方文档：
- 云函数 SCF：https://cloud.tencent.com/product/scf
- 消息队列 CMQ：https://cloud.tencent.com/product/cmq
相关·内容
在我的sls项目中，我使用设置了sqs的脱机使用，如下所示。
npm已安装无服务器-脱机-sqs作为dev依赖项
在serverless.ts插件部分中包括无服务器离线后的sqs。
为队列添加了自定义配置，
"serverless-offline-sqs": {
autoCreate: true,
apiVersion: "2012-11-05",
endpoint: "http://localhost:9324",
region: "us-east-1",
浏览 13提问于2021-12-14得票数 0
回答已采纳
考虑到某些事件源1，以及单个Lambda可能对多记录事件源(例如SQS、SES)和单个请求事件源(例如API )都可用，是否有人有用相同的Lambda处理单个API请求和多个记录SQS或其他源事件的示例？
这比限制批处理大小要复杂一些，因为来自不同服务的事件对象并不总是有一个记录列表，例如，API网关发送一个请求对象事件有效负载，而不是一个记录列表。
我已经找到了如何基于eventSource键解析事件；但是，我不明白Lambda如何响应多个记录事件。
每个事件记录是否有一个调用记录，或者是否有一个调用记录，即Lambda代码是每批运行一次还是多次运行？
是我的Lambda代码负责形成调用记录
浏览 2提问于2020-10-21得票数 1
回答已采纳
我一直在试着读这篇文章，但是我得到的信息要么是矛盾的，要么就是我不太明白为什么没有冲突。
我使用CDK在vpc中设置lambda，并将SQS队列作为事件源。SQS队列将订阅不同AWS帐户中的SNS主题。现在，我的问题就在SQS/Lambda交互之后。
我希望Lambda能够轮询/接收来自SQS队列的消息，而无需经过公共互联网。起初，我认为这需要vpc /安全组设置才能访问SQS端点。但我读到了另一篇文章，其中有人说lambda计票器本身没有运行在您的lambda的VPC中，所以没有任何vpc配置适用于它。如果是这样的话--轮询者是否只在AWS的私有“全球基础设施”中运行？
但这只是轮询--我还
浏览 4提问于2022-05-28得票数 1
回答已采纳
1回答
从SQS响应中获取数据
、、、
我有一个大约20个API的列表，等于20个SQS。例: API名称: XXX_API_NAME1 & Same : YYY_SQS_NAME1与其余19个API的命名约定相同
在这里，如果上面的API中有任何失败，它将调用它，它将向其各自的SQS发送消息。
现在，我需要从SQS中获取信息，比如API名称、SQS名称和时间戳，并需要将这些信息作为电子邮件发送给收件人。
我已经为一个SQS编写了触发lambda来接收下面的消息，
sqs = boto3.resource("sqs")
queue = sqs.get_queue_by_name(QueueName='
浏览 0提问于2019-07-11得票数 0
回答已采纳
2回答
使用SQS或SNS发送电子邮件
、、、、
我有一个web应用程序，应该发送电子邮件给管理员用户时，在应用程序发生了一些事情。例如，注册了一个新用户。
我想避免在应用程序中构建/发送电子邮件的逻辑。我更希望应用程序在队列中发布一条消息，然后，有另一个系统侦听并正确地响应以发送电子邮件。
流量会是这样的。
应用程序在队列中发布消息(SQS还是SNS??)
lambda函数是触发器。Lambda读取消息并调用SES。
SES发送电子邮件
我不确定这是不是最好的方法。我读到了SQS和Lambda之间的差距。用SNS会更好吗？
正确的流程是什么？
App -> SQS -> Lambda -> SES
或
浏览 5提问于2016-06-28得票数 8
我已经部署了一个AWS函数，它在SQS队列接收到消息时触发。该函数向Rest发出请求，如果响应不确定，则需要再次处理SQS消息。
这就是我需要将消息重新发送到队列的原因，但我倾向于以编程方式删除SQS消息，尽管我无法找到如何配置SQS。我尝试过邮件保留，但似乎触发事件会导致消息被删除。
其他可能的选项可能是在S3中备份消息或将其保存在DynamoDB中，但我想知道是否有更好的选择。
对这个问题的任何见解都会很有帮助。
浏览 0提问于2019-05-19得票数 7
我创建了一个微服务体系结构，其流程如下：
Api调用-> Api网关-> Eventbridge -> SNS -> Lambda
其原因是使用SNS而不是sqs来解耦真正的无服务器计算的应用程序，而不需要lambda连续轮询SQS、pub子而不是推送轮询。
问题在于，尽管执行很好，lambdas按预期运行，但用户或应用程序收到的返回是事件桥响应。我找不到任何关于事件桥如何通过API网关处理http请求响应的文档。
有没有人有什么想法或文件能把我推向正确的方向。
谢谢!
浏览 5提问于2022-08-25得票数 1
回答已采纳
我在lambda中设置了一个sqs触发器
batch size : 3
batch window : 300 seconds
concurrency: 1
将SQS队列设置为
visiblity timeout: 3 minutes
这里的想法是一次处理3个文件。
这就是lambda代码的样子。
def lambda_handler(event, context):
maximum_jobs = 3
sqs_client = boto3.client(
'sqs'
)
for i in range
浏览 2提问于2021-02-15得票数 2
回答已采纳
我已经创建了一个爬虫，当在S3上添加新对象时，它会从SQS中提取消息，但是当它运行消息“接收到的目标的唯一事件数为0”时，就会打印出预期的表。当我从爬虫设置中删除S3事件时，将成功地创建表。
执行日志：
BENCHMARK : Running Start Crawl for Crawler [crawler_name]
INFO : The crawl is running by consuming Amazon S3 events.
INFO : The number of messages in the SQS queue arn:aws:sqs:[myqueue] is 17
INFO
浏览 4提问于2022-01-21得票数 0
这里的Java 8使用AWS编写了一个Java，它应该响应发送到SQS队列的消息而执行。
在理想的情况下，将为发送到SQS队列的每个记录调用/执行一个和唯一的lambda实例。因此，如果向队列发送5条消息，则5个lambda将触发(或者--取决于我的lambda配置--我可以设置一个最大的并发lambda，在这种情况下，我的期望是等待下一个可用的lambda消息。
这不是一个很难的要求，只是一个理想。
我注意到在com.amazonaws.services.lambda.runtime.events.SqsEvent类中，有一个getRecords() : List<SQSMessage
浏览 7提问于2020-03-26得票数 4
回答已采纳
3回答
这很可能是非常简单的事情，但由于某种原因，在可见性超时之后，我的SQS消息不再可用。至少这就是我所想的，因为使用lambda没有日志条目，表明已经触发了任何重试。
我的用例是，另一个lambda正在用JSON实体来输入SQS队列，然后需要发送这些实体。有时候，需要发送的数据太多，以至于接收端使用HTTP 429进行响应。
我的发送lambda (HTTPS上的JSON)只在服务使用HTTP200响应时才从队列中删除消息，否则我就不会对receiptHandle做任何操作，我认为应该将消息保留在队列中。
无论如何，当请求被服务拒绝时，该消息不再可用，因此不再尝试发送，并且永远丢失。
传入SQS的
浏览 17提问于2022-01-19得票数 1
回答已采纳
我对AWS比较陌生，如果要正确设计AWS Lambda，我就很难理解以下场景：
SQS消息正在写入AWS正在侦听的特定队列中，并在其上具有触发器。
读取sqs消息上的AWS lambda将其进一步传递到多个目标，如SNS/DynamoDB/另一个SQS查询。
这个设计可以吗？我应该将每个目标分离成单独的AWS lambda，还是应该是其中的一部分？
AWS目的地在这方面的作用是什么？我应该为每个amazon服务创建一个单独的目的地吗?或者AWS目标的目的是不同的？(比如处理成功/失败方案？)
不确定这是否重要，但我计划使用C#语言编写此解决方案。
浏览 3提问于2020-02-10得票数 0
回答已采纳
1回答
我已经创建了一个SQS队列，现在我想从我的lambada函数读取数据。我已经将触发器从SQS配置到这个lambada函数。 当我将消息放入SQS队列时，当我单击Flight.But函数中的测试时，它会显示1条消息。 错误 {
"errorMessage": "module initialization error"
} 我正在使用下面的boto3 import boto3
sqs = boto3.client('sqs')
queue_url = 'https://sqs.us-east-1.amazo
浏览 22提问于2019-03-06得票数 0
回答已采纳
2回答
我有一个Symfony2应用程序，在某些情况下，它必须发送超过10.000个推送和电子邮件通知。
我开发了一个SQS流，一些工作人员轮询队列以发送电子邮件和移动推送通知。
但现在，我遇到了一个问题:在请求/响应周期中，当我需要向SQS发送此任务/作业(可能不是该数量)时，此任务本身会消耗大量时间(通常会达到响应超时)。
我是否应该在后台处理此任务(我需要发回一个快速响应)？在这种情况下，如何处理可能出现的错误？
注意: Amazon SQS可以在一次请求中接收10条消息，我已经在使用这种方法。也许我应该建立一个简单的SQS消息与许多通知作业(最大。256K)向SQS发送更少的HTTP请求？
浏览 0提问于2016-02-19得票数 3
目前，我正在从我们的后端汇集AWS SQS，并在收到有效负载后执行业务逻辑。
我想将其转移到AWS Lambda，并开始通过SQS/SNS实现业务逻辑的自动化。
由于我无法订阅AWS SQS事件，使用Lambda (node.js)实现SQS池化的最佳实践是什么？
浏览 1提问于2018-02-20得票数 2
3回答
我知道，这听起来很奇怪，但是我的AWS SNS =有问题。
我有lambda函数，它向AWS发送消息。另外，我有几个SQS作为我的SNS的订阅。另外，我有用于SNS和SQS的死队列。并为SNS (传递和错误)打开日志记录(100%)。
在大多数情况下，我的架构正在按预期工作- Lambda正在向SNS发送消息。
我在Lambda日志(boto3 / SNS客户端)中看到来自sns的成功响应(boto3/ SNS客户端)我在SNS日志中看到成功的日志我能够在SQS中获得我的消息
但有时兰博达和SNS之间会有问题，因为：
我在兰博达看到了成功的回应，比如：
{'MessageId&
浏览 2提问于2021-04-29得票数 1
1回答
我正在尝试让Alexa技能调用一个向SQS队列发送消息的lambda函数。基本上，本指南所做的是
我让skill和lambda函数工作，当我执行skill时，我得到了在lambda函数中创建的正确响应。然而，有时队列会获取消息，而有时则不会，它看起来完全是随机的。是否存在可能导致消息被丢弃/忽略的原因？
浏览 0提问于2018-09-25得票数 1
1回答
因此，我将一些条目放入SQS队列中，该队列被设置为Lambda的事件源，此流程运行良好。一旦条目进入SQS队列，lambda就会处理它。到目前一切尚好。
但是我有一种情况，我想让条目在SQS中停留3-4天，然后让lambda处理它们。
基本上，如果我看到这个okey，我的SQS队列中有100个条目，现在已经有4天了。我想让lambda耗尽它们并运行一些逻辑。有没有可能，请给我指点一下？
浏览 2提问于2020-07-02得票数 0
2回答
如何使用AWS实现死信队列
、、、、
我试图为失败的lambda事件实现一个死信队列。我创建了一个SQS队列和两个lambda。一个lambda只抛出一个错误，另一个侦听SQS队列，并在队列收到消息并将事件记录到Cloudwatch时触发。
在AWS管理控制台中，我可以看到.function lambda (抛出错误的那个)配置了一个死信队列。
我能够看到.dispatcher函数(监听SQS的函数)配置正确，如果我向SQS队列发送消息，我还可以看到Cloudwatch日志显示它正按预期被触发。
尽管所有的配置似乎都是正确的，但我无法让.function在事件失败时将事件发送到SQS，以便触发.dispatcher lambda。
浏览 16提问于2022-08-20得票数 -1
回答已采纳
我现在有一个由SQS队列触发的简单Lambda，并打印出触发它的事件。它与CFN一起部署，定义为：
PrintMessage:
Type: AWS::Lambda::Function
Properties:
Handler: index.handler
Runtime: python3.8
FunctionName: !Sub printMessage-${Environment}
MemorySize: 1024
Role: !Sub arn:aws:iam::${AWS::AccountId}:role/servi
浏览 1提问于2021-08-11得票数 2
回答已采纳
1回答
我的Lambda执行数与SQS消息的数量不匹配。我希望对我的SQS队列中的1条消息执行1 lambda。
我的SQS队列有83条消息要处理，但是当所有处理完成时，我的cloudwatch日志在日志组中只有44条日志。为什么我一半的信息看起来都迷路了？lambda是nto超时，而正在执行的则是在超时之前完成它们的处理，并且只处理一条消息。还有更多的设置需要我去弄清楚吗？
我的地形代码：
resource "aws_lambda_event_source_mapping" "event_source_mapping" {
batch_size =
浏览 4提问于2022-05-09得票数 1
回答已采纳
3回答
SQS -我需要在批响应中获得更多消息。
我已经设置了SQS队列，在该队列上我正在处理其他太大的库存数据。它一次只给出10条消息，这不符合我的要求。我在PHP中使用它。有没有人与之合作并取得了成就？
我参考了很多指南，得到了一些使用长轮询的想法。但是有谁能给出一些提示如何做到这一点？我已经做了非常基础的SQS。
我希望每天基于SQS响应的数千个数据。
浏览 1提问于2019-08-08得票数 1
1回答
我正在使用一个无服务器API，并且我有一个从sqs队列触发的lambda函数，批处理大小为1，这意味着我的意图是在我向队列发送消息时立即触发lambda，它工作得很好，但当我第一次部署该函数时，它没有触发，并且当我第二次请求它发送第一条消息时，它总是比我发送的消息晚一条。我已经附上了我的代码，不确定我在这里错过了什么，任何帮助都是感激的。 serverless.yml iamRoleStatements:
- Effect: "Allow"
Action:
- "sqs:SendMessage"
- "sqs:Rec
浏览 19提问于2019-05-10得票数 2
我有lambda使用SQS事件作为输入。SQS队列也有一个DLQ。lambda函数调用下游的Restful (调用此操作DoPostToAPI())，我需要确保lambda函数尝试在上调用DoPostToAPI() 至少2次(在消息进入DLQ之前)
为了完成上述要求，我需要设置哪些Lambda重试和SQS重驱策略？
我需要100%确定到达DLQ的消息只是因为它们试图被发送到下游API DoPostToAPI() 2次，并且如果可能的话，由于任何其他原因消息不会到达DLQ。
对我来说，消息只有在尝试操作时才能到达DLQ，而不是出于其他原因(例如，我不希望消息纯粹由于节流而到达DLQ，因为DoPo
浏览 2提问于2020-08-07得票数 0
我有一个用java编写的lambda函数，具有handle方法签名，如下所示：
public String handleRequest(SQSEvent sqsEvent, Context context){ //Todo }
我的lambda函数接受SQS事件作为请求并处理逻辑。
如果me lambda函数以某种方式失败，我希望通过手动提供所需的输入数据来再次触发它。我的方法是创建一个新的lambda函数，它将调用我的主lambda函数。我将使用具有所需参数的APIGateway触发我的新lambda。
如何创建我们自己的SQS事件对象，将其作为请求体传递给我的主lambda？SQ
浏览 2提问于2020-06-14得票数 0
回答已采纳
我有一个由SQS触发的AWS Lambda。几十个lambda将把消息推送到SQS。所以我想知道当SQS被消息淹没时，它会自动触发lambda来创建它的多个实例并处理这些消息吗？或者我还需要配置其他东西吗？谢谢
浏览 0提问于2020-06-07得票数 1
在这种情况下，我使用Amazon + SQS来处理域事件。
基本上，在域事件上，我向SNS发布了一条消息，并且订阅了两个SQS队列。由于我注意到SQS支持FIFO，但SNS不支持FIFO，所以我试图找到一个解决方案，如何同时将消息A传递到多个SQS队列？
到目前为止我拥有的
将消息A发布到SNS
将消息A分发给SQS 1和SQS 2
我现在所能想到的就是
将消息A发布到SQS A
使用代码从SQS中提取消息A并将其发布到SQS 1和SQS 2
不是我想要的原子过程..。
除了这种方法之外，还有别的办法吗？
浏览 5提问于2020-07-13得票数 0
我的SQS触发lambda函数。SQS发送了4条消息，但是lambda调用了两次。并发性是“无保留帐户并发性& 1000”。什么会出错？
浏览 3提问于2022-03-23得票数 -1
2回答
序言:我正试图为我认为是一个非常常见的用例提出一个建议，我想使用的SWF和SQS来实现我的目标。也许还有其他的服务能更好地与我所做的相匹配，所以如果你有建议的话，请随时把它们扔掉。
问题：最基本的需求是客户端(移动设备、web服务器等)。发布一条将异步处理的消息，而不对客户端作出响应--非常基本。
预期的实现是客户端将消息发送到预先确定的SQS队列。此时，客户端就完成了。我们还将有一个已定义的SWF工作流，负责从队列中提取消息，并(经过一些操作后)将其放置在Dynamo中--同样，所有这些都相当简单。
不过，我似乎不明白的是，如何启动工作流。从我所读到的情况来看，工作流并不意味着是一个不确定的
浏览 8提问于2013-12-12得票数 5
回答已采纳
2回答
我想知道如何配置AWS、SNS和SQS来处理后台任务。
我想有三种方法。
选项1。名为使用者的函数可以通过从队列接收任务来执行工作人员。
选项2。将所有任务发送到SNS。一个工人和一个SQS从SNS接收和工作。
选项3。直接将任务从应用程序转发到一个SQS和一个lambda。
最大的问题是是在应用程序中直接调用Lambda，还是使用SQS或SNS使用任务使用者。
我的想法来自
浏览 1提问于2021-04-08得票数 0
回答已采纳
1回答
我想在AWS基础设施上作为守护进程运行一个进程，该进程负责读取AWS SQS队列并创建一些进程。
我的第一种方法是使用部署在ECS container服务上的docker容器。所以我会在while true loop上，睡几秒钟。使用它，我可以控制两次处理之间的睡眠时间，所以如果我的SQS队列已满，我可以减少睡眠时间。所以
我知道可以使用AWS Lambda作为cron作业，但我无法控制cron时间(减少或增加sqs大小的响应)。
AWS Lambda方法更简单，不需要“任何”基础设施，但灵活性较差。有人知道另一种方法吗？
浏览 21提问于2016-09-04得票数 1
下面的代码调用SNS，但我希望SQS也调用它。我们可以使用多个主体和源Arn吗？我也试过了，但没有用-
LambdaPermissionMainSNS:
Type: AWS::Lambda::Permission
Properties:
Action: lambda:InvokeFunction
FunctionName: !GetAtt LambdaFunctionMain.Arn
Principal: sns.amazonaws.com
SourceArn: !Ref SNSTopic
LambdaPermissionMain
浏览 0提问于2019-05-14得票数 0
回答已采纳
如果有人能帮我解释的话，我想弄清楚我是否需要工作流程中的SQS。在我的应用程序中，当一个动作被执行时，它会向SNS主题提交信息，SNS主题调用Lambda来做一些处理。这是很好的工作，因为它是。
当我在网上进行研究时，人们似乎也在这个堆栈中使用SQS，其中SNS会将信息放在SQS上，然后SQS将调用Lambda。
我想我想要理解的是在这里需要SQS。那会增加什么价值？换句话说，直接从SNS调用Lambda会带来什么损失？
浏览 22提问于2017-03-07得票数 73
回答已采纳
通过lambda成功处理SQS消息。下面是处理然后执行回调的代码：
exports.handler = function(event, context, callback) {
handleSQSMessages(context,event, function () {
const response = {
statusCode: 200,
body: JSON.stringify({
message: 'SQS event processed.',
input: event,
浏览 0提问于2018-11-22得票数 4
2回答
根据，如果我想创建一个lambda函数来将数据从SQS发送到S3，那么每条SQS消息都将存储在一个单独的S3对象中(我假设这是因为每次收到消息时都会触发lambda函数)
例如，是否有任何方法将SQS在过去24小时内接收到的所有消息发送给同一个S3对象？
编辑
这可能是从队列接收消息并将其发送到S3的代码。
var receiveMessageRequest = new ReceiveMessageRequest { QueueUrl = myQueueUrl };
var receiveMessageResponse = sqs.ReceiveMessageAsync(receiveMes
浏览 0提问于2018-10-18得票数 0
回答已采纳
2回答
我使用以下3种服务: Amazon S3、Amazon SQS和AWS Lambda。
为CSV和EXCEL文件创建相同的配置(处理EXCEL文件的lambda函数只是将它们转换为CSV文件并将它们重新上传到S3，以便其他lambda函数处理它们)。
AWS Lambda配置：
内存: 1024 MB
超时:6分钟
保留并发性:1(对于当前的测试，我不需要多个并行函数)
重试尝试:0
DLQ:目前没有配置(稍后将添加)
对于亚马逊S3：
在's3:ObjectCreated:*‘事件上，S3向已配置的SQS队列发送消息。SQS队列上有一个Lambda触发器。
浏览 4提问于2021-01-22得票数 0
回答已采纳
3回答
我有一个Lambda，它需要将消息发送到另一个Lambda以执行某些操作。在我的特殊情况下，它向Lambda传递一条消息，以便它执行HTTP请求并刷新缓存条目。
目前，我依靠AWS SDK发送SQS消息。这个机制运行得很好。我担心的是，SQS send方法调用平均需要大约50ms才能完成。考虑到我在Lambda中，我无法在后台执行此操作，并期望在Lambda返回和冻结之前完成此操作。
如果我需要进行多个SQS send调用，这就更加复杂了，这是特别糟糕的，因为Lambda负责响应低延迟的HTTP请求。
在AWS中，有没有什么替代方案可以用于Lambdas之间的通信，而不需要同步API调用，并且
浏览 0提问于2020-03-15得票数 1
2回答
我正在尝试找出从特定端点读取JSON文件，然后将该对象保存/发布到AWS S3的最佳方法。我已经通过创建了一个带有模拟响应的模拟端点，我想知道将其'POST‘到S3存储桶的最佳方式是什么。每周都会提供新的JSON文件，我在想，也许可以使用Lambda AWS和API Gateway。这是一个可行的方法吗？我还想探讨启用事件触发器方式来拉取数据或调度程序的可能性。你有什么推荐的？我知道AWS SQS是一个选项，但是如何将获取的JSON文件发送到队列？
谢谢，任何资源或建议都非常受欢迎。我正在寻找潜在的方法。
浏览 11提问于2019-07-30得票数 1
回答已采纳
3回答
嗯，我在一段时间前通过使用AWS构建了一个无服务器应用程序。我当前的应用程序流程如下：
API Gateway (1) → Lambda Function (2) → SQS (3) → Lambda Function (4) → DynamoDB (5)
现在，有一些考虑因素：
客户端将向我的API (1)发送请求。
有一个lambda函数(2)附加到API事件，因此它将接收API请求并处理它。
现在，这里是问题进入的地方。在处理请求之后，必须在DynamoDB (5)处插入此处理的结果。目前，我将其发送到SQS (3)，并返回客户端发送的HTTP请求的响应。
尽管请求已经完
浏览 0提问于2019-04-23得票数 1
回答已采纳
有什么方法可以让我设置一个API网关，->，SQS，->，Lambda？让Lambda向客户端返回API网关响应。我已经有了-> SQS。如果SQS中有队列，就会触发Lambda函数。唯一的问题是，如何让我的Lambda将API网关响应返回到客户端？
SQS
const sqs = new sqs.Queue(this, 'sqs', {
visibilityTimeout: cdk.Duration.seconds(60),
queueName: 'sqs',
});
sqs.grantSendMessages(customRo
浏览 6提问于2022-08-15得票数 -1
回答已采纳
我们使用arrives和NodeJS创建了两个lamdba函数，一个是发送方，另一个是接收方，在这两个函数之间有一个标准SQS，它接收来自发送方lambda的数据，如果有任何消息到达SQS，它会自动触发接收方lambda函数。
在这里，我们能够成功地将所有消息从发送方lambda发送到SQS(如日志所示)，但在接收方lambda，我们并没有得到所有的消息。
为了测试这个场景，我从邮递员那里发送了1000条消息，并测试发件人是否将所有消息完美地发送到SQS，但是接收方只接收到其中的986条随机消息，其中有些随机消息被遗漏了。
I也尝试了SQS类型来代替标准的FIFO，但是lambda.不支持它。
浏览 5提问于2019-09-21得票数 2
2回答
从中轮询消息的最佳方法是什么？我想在消息进入队列后立即处理它们，并且不想每秒钟轮询一次，除非这是唯一的选择？
setInterval(run(), 1000);我得到了错误
const run: () => Promise<void>
//---------------------------------
No overload matches this call.
Overload 1 of 2, '(callback: (...args: any[]) => void, ms: number, ...args: any[]): Timeout',
浏览 4提问于2021-01-16得票数 1
回答已采纳
我想使用向SQS发送消息，然后需要触发Lambda。在Lambda内完成计算之后，我需要将结果传递回API。换句话说，类似这样的事情：
Get request --> Gateway API --> SQS --> Lambda --> (back to the same SQS?) --> Gateway API
我设置了所有必要的权限，这意味着我可以调用Gateway API并向SQS发送消息，然后将消息发送给Lambda (我可以在Cloudwatch中看到Lambda收到了消息)。但是，我不能让Lambda响应返回到Gateway API.
有人有关于这
浏览 6提问于2021-02-24得票数 3
回答已采纳
我有一个lambda函数，它的触发器是SQS。当lambda执行时，它会抛出一个错误或不抛出错误。它将把作业放回队列中，并创建一个循环，您肯定知道AWS账单:)
我是否应该在lambda函数中返回一些内容，让SQS知道我得到了消息(完成了任务)？我该怎么写这条信息呢？据我所知，我们在SQS中没有ack和nack。
如果任何作业失败，SQS配置中是否有任何选项只能重试N次？
浏览 3提问于2021-11-20得票数 2
回答已采纳
我使用一个AWS SQS发送电子邮件。侦听器接收电子邮件的json并直接处理它。现在，我还需要再发送一种消息类型(比如otp或告警)，它们将有自己的json结构。
我是否可以使用相同的SQS队列来发布这些不同类型的消息，因为我的容量非常低，或者应该继续为每个消息类型创建多个SQS队列。
浏览 20提问于2022-04-28得票数 0
我正在使用AWS Lambda函数来处理队列中的消息，它工作正常。但是当消息可用或添加到SQS队列中时，我需要执行这个Lambda函数。
是否有可能触发基于SQS的Lambda函数? queue.Please建议一种实现此目标的方法。
浏览 2提问于2016-12-14得票数 6
我将消息发送到SQS，它应该将消息发送到事件桥，而事件桥将触发lambda。
我可以看到在SQS中接收到的消息，但不知怎么的，它并没有将它们发送到Eventbridge。
这是我的无服务器配置
service: mysendemail
projectDir: ../
frameworkVersion: "3"
package:
individually: true
plugins:
- serverless-offline
provider:
name: aws
runtime: nodejs16.x
region: eu-west-1
time
浏览 5提问于2022-11-17得票数 -1
回答已采纳
我目前正在使用用Javascript编写的Lambda函数，这个函数是用SQS事件源设置的，可以自动从SQS队列中提取消息，并对消息内容进行一些基本处理。我无法显示代码，但lambda函数的执行摘要基本上是：
对于批处理中的每个消息，它作为事件的一部分接收：
它将主体(即JSON字符串)解析为Javascript对象。使用getObject.It从对象中列出的对象中读取对象的使用put.If将记录放入DynamoDB表，没有错误，它删除了使用deleteMessage.从队列中处理的单个SQS消息
这个SQS队列体积很大，接收大量消息，定期积累数百万条消息。Lambda通常能够同时处理数十万条
浏览 10提问于2020-03-26得票数 10
3回答
我已经建立了一个使用Lambda和SQS的小型无服务器应用程序。在我的例子中，每当消息被添加到SQS队列中时，我都希望触发，lambda。
函数在我的serverless.yml中
functions:
collectGame:
handler: js/collect.collectGame
memorySize: 128
timeout: 10
events:
- sqs:
arn:
Fn::GetAtt:
- gameRequestQueue
- Arn
浏览 0提问于2018-08-21得票数 6
回答已采纳
我已经设置了一个如下所示的系统: lambda1 -> SQS -> lambda2
Lambda1将向SQS发送许多消息(所有消息都在几秒钟内)。然后，我设置了SQS队列和lambda2之间的事件源映射，MaximumBatchingWindowInSeconds为180秒，BatchSize为500。考虑到这种设置，我预计lambda2只会被触发一次(对于在180秒内从lambda1发送的最多500条消息)。但是观察到的行为(基于lambda2的cloudwatch日志数量)似乎是每条消息一个触发器(传递给handler的SQSEvent只包含一条记录)。不过，180秒的Max
浏览 0提问于2020-12-18得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
