amazon-sqs 相关问题

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

Argo 工作流程输入参数以及来自 SQS 负载的值

我想通过从 SQS 事件源的有效负载读取值来触发 Argo 工作流程。 例如,我的工作流程模板接受输入参数“日期”。我需要听 AWS SQS 和 e...

回答 1 投票 0

SNS 订阅:当 StringValue 是 JSON 有效负载时,过滤器会中断

SQS 订阅配置为根据“appId”消息属性过滤消息。仅选择“appId”属性值为“Foo”的消息...

回答 1 投票 0

我可以仅通过 SNS 触发 PagerDuty 事件吗?

当在我的 S3 存储桶中创建前缀为“invalid-files/”的新对象时,我尝试在 pagerduty 中进行分页。我已经为 S3 创建了一个通知配置,并将其发布到我的 SNS 主题。我也...

回答 1 投票 0

从 SQS 驱动的 Pyspark 结构化流检索路径

我有一个 DMS 生成的 s3 数据湖,并设置 SQS 来跟踪生成的文件。现在我想将其流式传输到我的 EMR 集群中,为此我在此处找到了 Spark Streaming s3 连接器 https://git...

回答 1 投票 0

API 网关 -> SQS HTTP POST 消息属性

我有一个 API 网关设置,它发送到 SQS 并触发 Lambda,我试图将消息属性传递到 SQS,但是当我到达邮递员中的端点时,我不断收到 400 错误请求..什么...

回答 2 投票 0

无法编写 JSON:Java 8 日期/时间类型 `java.time.LocalDate`

我正在使用Spring Boot 2.7.4 和 com.fasterxml.jackson.module jackson-module-kotlin ...

回答 3 投票 0

有没有办法订阅Event Bridge事件总线到SNS主题?

我有多个外部发布者在我的服务监听的 SNS 主题上发布内容。我需要将这些消息路由到某种优先级队列(SQS)。 有没有办法让这个图案本土化...

回答 1 投票 0

Redshift 计划查询的成功和失败通知

我能够成功安排红移查询,这不是很花哨。只需简单的截断和加载即可。我还创建了一个 SNS 主题并附加到此查询。我收到一封电子邮件通知...

回答 2 投票 0

Laravel 多个服务器与 AWS 队列一起使用

我有 Laravel 应用程序在两台服务器上运行(使用负载均衡器),我想知道如果我将作业放入 AWS SQS 队列并且两台服务器都订阅了该队列,会发生什么。 有吗

回答 3 投票 0

AWS Lambda 使用 SQS 报告批量项目失败

Lambda 响应是 { "errorMessage": "处理程序返回单个值,但它不实现错误", “错误类型”:“错误字符串” } 参考 aws 文档...

回答 2 投票 0

来自 AWS DLQ 的消息如何被删除?

我是队列新手,所以试图理解这个场景 我有常规的 SQS 队列 A 和 DLQ B 以及 Lambda C。 Lambda C 由 SQS 队列上的消息调用。 不管出于什么原因,如果有什么事,就说吧

回答 1 投票 0

Localstack SQS 缺少操作

我使用相当简单的本地堆栈设置来模拟从 AWS SQS 队列中的读取。当我运行此样板代码时,我收到有关缺少操作的错误。 发生异常:CLR/Amazon...

回答 1 投票 0

sqs 队列有多个 Nodejs 消费者?

我有一个包含数千条消息的SQS队列。由于函数的大小(使用 puppeteer),我无法在 lambda 上使用它们,因此我已将消费者转移到 EC2 实例。由于这是 POC,我做了一个非常好的...

回答 1 投票 0

为什么会提交重复的 AWS 作业

每次文件上传到存储桶时,我的 S3 存储桶都会向 SQS 发送事件。 SQS 触发 lambda 函数,将作业提交到 AWS 作业队列。 每周一次,我的应用程序上传超过 100K 文件到 S3

回答 1 投票 0

AWS SNS SMS 不适用于 eu-west-2,但适用于 eu-west-1

我有一个简单的 SNS 主题,在 eu-west-2 区域有一个 SMS 订阅。 由于某种原因,我在添加号码时始终无法收到沙盒验证码,为此,我尝试了多次

回答 1 投票 0

无法从 AWS Lambda 函数向 SQS 发送消息

我有一个 Lambda 函数,其中包含一些数据,必须将其发送到 SQS 队列。但似乎发送不起作用。没有错误,似乎优雅地继续执行,没有任何m...

回答 1 投票 0

SQS 消息何时通过重驱动策略发送到死信队列?

我有一个 SQS 队列通过重新驱动策略链接到死信队列。地形样本: redrive_policy = jsonencode({ deadLetterTargetArn = aws_sqs_queue.deadletter_queue.arn 最大接收C...

回答 3 投票 0

AWS FIFO 通过 SNS 排队订阅:传递消息组 ID

在我的应用程序中,所有微服务当前都通过 AWS FIFO 队列进行通信。 我目前正在尝试让所有这些队列订阅具有某种过滤条件的 SNS 主题。 在...

回答 2 投票 0

有没有办法动态地将SQS队列分配给@SqsListener方法实现,而不必是静态的?

目前,根据我对这些问题(此处和此处)的理解,在 AWS Messaging for Spring Boot 中,必须将 @SqsListener 注释定义中的队列名称或队列 url 设置为 sta...

回答 1 投票 0

如何在 Spring Cloud AWS SQS 中以编程方式设置消息处理程序?

也许有人对我的以下问题有想法: 我目前正在进行一个项目,我想在其中使用 AWS SQS 与 Spring Cloud 集成。对于接收器部分,我想提供一个 API,其中...

回答 3 投票 0

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