amazon-sqs 相关问题

Amazon Simple Queue Service(Amazon SQS)提供可靠,高度可扩展的托管队列,用于在计算机之间传输消息。

Lambda将ErrorMessage添加到SQS消息

我有一个基本的SQS队列触发Lambda与重启策略,以便在重试5次后向DLQ发送失败的消息。我读到Lambda应该将有关错误的消息属性添加到消息中......

回答 1 投票 0

当消息发布到SQS时,如何在延迟时触发lambda?

我有一个lambda配置为在将消息发布到SQS队列时触发。以下是用于部署的SAM模板。 MyQueue:类型:AWS :: SQS :: Queue属性:...

回答 2 投票 0

如何从Lambda中批量处理特定SQS消息?

我有一个带有SQS触发器的Lambda。当它被击中时,来自SQS的一批记录进来(我认为通常一次大约10个)。如果我从处理程序返回失败的状态代码,则所有10条消息......

回答 2 投票 0

Sqs Akka Stream内存不足

下面的代码在运行15分钟内(EC配置xms 1024 xmx2G)在EC2实例上抛出OOO,但在intellij上运行时不会抛出任何错误。 SqsSource(queueUrl,// parallelism = maxBufferSize / ...

回答 2 投票 1

每当0 kb文件上传到s3时,是否可以通过SNS或SQS发送电子邮件通知?

每当上传到s3存储桶客户端的0 kb文件或无效文件必须通过SNS或SQS收到电子邮件通知时。是否可以不使用Aws Lambda ???提前致谢!!!!!

回答 1 投票 1

亚马逊SQS超过2GB的数据

使用SQS对来自客户端的一些上传进行排队。我收到以下错误:com.amazonaws.services.sqs.model.AmazonSQSException:一个或多个参数无效。原因:......

回答 1 投票 0

仅在收集固定数量的数据后执行AWS Lambda(具有多个数据)

我想在收集固定数量的数据之后执行具有多个数据的lambda函数。例如,固定金额将仅考虑特定数量的消息,或者......

回答 2 投票 0

Spring Integration + SQS - 异常重试不起作用

我正致力于将Spring Integration与AWS SQS队列集成。当我使用@ServiceActivator注释的方法抛出异常时,我遇到了问题。似乎在这种情况下,消息是......

回答 1 投票 1

Spring云中的轮询线程行为

关于轮询线程的行为方式,我有一点疑问。让我们假设一个场景,我每次轮询收到的maxNumberOfMessages是10.我们正在使用DEFAULT_WAIT_TIME = 20秒。我想要 ...

回答 1 投票 0

Celery在日志中出现SQS错误

我正在使用Celery与Amazon SQS,我在日志中看到了大量这些内容:[2013-06-19 19:03:42,890:ERROR / MainProcess]池回调引发异常:KeyError('8a8fe51c-b69f-498e- 95c1-f037e2f2d4a8' ,...

回答 1 投票 1

为什么'reservedConcurrency'不限制并发机上消息的数量?

我试图限制并行运行的并发函数的数量。我的lambda的触发器是SQS队列中的消息,你可以在我的serverless.yml中看到:receiver:handler:src / ...

回答 1 投票 0

Spring引导JMS Listener - org.springframework.jms.config.JmsListenerEndpointRegistry.isAutoStartup()Z

我已经设置了一个JmsListener来读取sqs队列中的消息。我真的创建了一个类似下面的配置类来设置ConnectionFactory和JMSTemplate @Configuration @EnableJms公共类...

回答 1 投票 0

一种将数据从一个S3复制到另一个S3存储桶的自动方法

将数据从一个s3连续复制到另一个s3存储桶的最佳方法是什么?我知道S3支持事件通知并将它们发送到lambda,SNS和SQS,但我不确定会是什么......

回答 1 投票 0

AWS,SQS,计算10条消息的visabilityTimeout

我有代码:val messageRequest = new ReceiveMessageRequest()。withQueueUrl(queueUrl).withVisibilityTimeout(8000).withMaxNumberOfMessages(10)val messages = sqs.receiveMessage(messageRequest)....

回答 1 投票 0

AWS SQS死信队列通知

我正在尝试设计一个基于SQS,Lambda和SNS的小型消息处理系统。如果失败,我希望将消息排入死信队列(DLQ)并将webhook排入...

回答 1 投票 1

在AWS SQS中缺少s3事件

我有一个AWS Lambda函数,它应该由来自Simple Queue Service SQS的消息触发。当新的json文件写入我的s3存储桶时,该SQS应该会收到通知,或者......

回答 1 投票 0

Poller将阅读Amazon SNS主题

我们是否可以为SNS主题设置一个轮询器,它可以定期获取SNS主题的所有消息,就像我们可以用于SQS一样?

回答 1 投票 0

多个SQS队列与1个SNS主题

我们今天就最佳解决方案进行了辩论,双方都没有达成协议。我们有一个摄取“消息”的产品。每当我们收到新消息时,我们都需要将此数据发送到3 ...

回答 2 投票 1

使用AWS SQS的最有效方式(使用Golang)

使用AWS SQS(简单队列服务)时,您需要为服务的每个请求付费(推,拉,...)。每个可以发送到队列的消息最多为256kb。为了省钱,我......

回答 2 投票 0

我想在sqs队列上监视消息在队列中的时间长度?

我想监视sqs队列消息,即从队列中弹出消息之前需要多长时间。我已经调查了云表的所有可用api,但我找不到任何相关的人。任何 ...

回答 1 投票 -2

© www.soinside.com 2019 - 2024. All rights reserved.