amazon-sqs 相关问题

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

AWS lambda SQS 不允许每次调用处理 1 条消息

我正在尝试建立我最初认为是一个简单的管道。 我有 2 个 SQS 队列和 2 个 lambda,它们应该按顺序工作。 问题是我的 lambda 做了繁重的工作,所以我想要 1 条消息

回答 1 投票 0

AWS SQS DLQ 消息加密

发送和检索消息选项允许从 sqs dlq 检索消息。 SSE 已启用,但消息正文以纯文本显示。有没有办法阻止有权限的用户重新驱动

回答 1 投票 0

生命周期事件中的 AWS 事件通知延迟

我已配置生命周期事件以从我的 s3 存储桶中删除该文件, 我还设置了事件通知, 事件类型:对象过期,以 SQS 队列作为目的地 目的地类型 : SQS Qu...

回答 1 投票 0

如何让多个消费者从单个AWS SQS队列接收相同的消息?

我有一个订阅 SNS 主题的 AWS SQS 队列。该队列当前有两个消费者: 使用 io.awspring.cloud.sqs.annotation 包中的 @SqsListener 的 Java 类。 事件桥...

回答 1 投票 0

我如何在现有的nodejs服务器上使用sqs消息

我想在SQS收到新消息时接收并触发电子邮件,现在我已经运行了nodejs服务器,我怎样才能让它工作?我真的不想触发该功能。但我想要那个...

回答 4 投票 0

sst开始“TypeError:getAwsCredentials不是函数”

我删除了 /node_modules 和 /package-lock.json 并进行了 npm install。 之后,当我执行 npx sst start 时,我收到此错误: 类型错误:getAwsCredentials 不是函数。 怎么解决这个问题?

回答 2 投票 0

访问SQS“DeleteMessageBatch”

我正在尝试设置 IAM,以便服务可以从另一个服务访问 SQS 队列。不幸的是,我在访问“DeleteMessageBatch”时遇到问题 我查看了 IAM 提供的内容,但没有看到...

回答 2 投票 0

SQSlistener 未接收消息

我能够从 springboot 向 SQS 队列发送消息,但无法使用 sqslistener 注释接收消息,有人可以帮忙吗? 公共无效发送(字符串消息){ 队列消息模板。

回答 6 投票 0

Erlang 服务器 SQS 实现

我想通过erlang的公共库erlcloud访问SQS服务。到目前为止我有以下内容: ` -模块(服务器)。 -export([开始/0,循环/1,handle_sqs_request/1]). 开始()->...

回答 1 投票 0

避免在节点上使用 localstack 设置 AWS 凭证进行本地开发

使用节点的aws-sdk,我正在初始化sqs sqs = 新 AWS.SQS({ 区域:“us-east-1”, }); 在产品环境中,这非常有效,因为运行它的角色具有所需的权限...

回答 2 投票 0

用作 AWS EventBridge (CloudWatch Events) 目标时如何指定 SQS 消息属性?

我想使用 AWS EventBridge (CloudWatch Events) 按预定义的计划向 SQS 发送消息。消息正文无关紧要,但它确实需要几个消息属性。 在创建...

回答 2 投票 0

用作 CloudWatch Events 目标时如何指定 SQS 消息属性?

我想使用 AWS CloudWatch Events 按预定义的计划向 SQS 发送消息。消息正文无关紧要,但它确实需要几个消息属性。 在创建此活动时...

回答 2 投票 0

具有 SQSEvent 和大批量大小的 Lambda 调用多个实例,每个实例处理几个项目

一点背景, 我正在使用 Serverless 和 .Net 创建带有 SQS 触发器的 lambda。 事件触发器设置批量大小为 10k 和等待时间(批量窗口即 MaximumBatchingWindowInSeconds...

回答 3 投票 0

如何确保数据修改事件以正确的顺序传递到SQS或Kinesis?

我们假设以下情况: 有一个后端服务,它具有用于“插入”、“更新”和“删除”请求的 CRUD 端点。 每个端点更新关系...

回答 1 投票 0

SNS 到 Lambda 与 SNS 到 SQS 到 Lambda

我正在尝试了解我的工作流程中是否需要 SQS,如果有人可以帮助解释的话。在我的应用程序中,当采取操作时,它会将信息提交到 SNS 主题,该主题调用 Lambda 进行一些处理。 ...

回答 6 投票 0

来自 Eventbridge 的动态消息组 ID

这里有人设法将SQS的消息组ID设置为动态吗? 我们通过 AWS Eventbridge 集成从 Shopify 商店接收更新。每当销售高峰时...

回答 1 投票 0

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

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