Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
每次在我的 AWS SQS 目标上推送通知时如何触发事件?
我正在将 AWS SQS 用于 Amazon MWS 订单 API 每当有人从已将我添加为其开发人员的卖家帐户订购时 亚马逊都会将通知发送到我的 AWS SQS 应用程序 我可以从那里提取通知 但为此 我必须创建一个调度程序来提取通知 我是
amazonwebservices
awslambda
amazonsqs
amazonmws
AWS Lambda 调用错误未触发 SQS 死信队列
我有一个 AWS Lambda 函数 它订阅 DynamoDB 流并配置了SQS 死信队列 DLQ https docs aws amazon com lambda latest dg dlq html 我可以看到管理控制台中配置了正确的队
amazonwebservices
amazondynamodb
awslambda
amazonsqs
基于 SQS 队列大小的自动缩放
我已将这些命令组合在一起 以根据 SQS 队列大小自动缩放 EC2 实例 我已运行所有命令 我的队列有 10 条消息 但尚未启动单个实例 我想弄清楚我的 cloudwatch 警报正在侦听哪个 SQS 队列 此外 我们还感谢任何有助于识别问
amazonwebservices
amazonec2
amazonsqs
autoscaling
SQS - 通过 ID 获取消息
我是否可以使用 Amazon PHP SDK 根据消息 ID 从 SQS 队列获取消息 我是否必须获取队列中的所有消息 然后在服务器上对其进行过滤 我的服务器收到带有队列消息 ID 的 SNS 发起请求 我必须从来自 SQS 的消息数组中过
amazonsqs
SpringBoot @SqsListener - 不工作 - 有异常 - TaskRejectedException
我有一个 AWS SQS 队列中已有 5000 条消息 示例消息类似于 Hello 1 我创建了一个 SpringBoot 应用程序 并在其中一个组件类中创建了一个从 SQS 读取消息的方法 package com example aws
Java
springboot
springCloud
amazonsqs
Akka、SQS 和 Camel 的消费者投票率
我正在做的一个项目需要从SQS读取消息 我决定使用Akka来分布式处理这些消息 由于 Camel 支持 SQS 并且在 Consumer 类中内置了 Akka 中使用的功能 因此我认为最好以这种方式实现端点并读取消息 尽管我还没有看到很多人
scala
apachecamel
akka
amazonsqs
如何通过 PHP 使用 AWS SQS/SNS 作为推送通知队列来执行繁重的处理任务?
我有一台在机架空间上运行的服务器 它托管一个 PHP Web 应用程序 PHP Web 应用程序将接受表单提交 然后需要根据表单字段条目执行任务 该任务 我们将其称为生成元数据任务 需要相当多的处理时间 我想知道如何允许表单提交直接保存到数
php
amazonwebservices
amazonsqs
amazonsns
如何在Elastic Beanstalk服务器上模拟发送周期性任务?
我已经设置了 Elastic Beanstalk 服务器 工作层 它有一个 cron yaml 每小时运行一个任务 如下所示 version 1 cron name broadcast users url broadcast schedul
amazonwebservices
amazonec2
amazonelasticbeanstalk
amazonsqs
带有属性占位符的 Spring Cloud AWS SQS SendTo 注释
这个问题 https github com spring cloud spring cloud aws issues 65建议 SendTo 注释支持属性占位符 但我无法让它工作 这是我想要做的一些简化的代码片段 比尝试用文字解释更容易 我
Spring
springCloud
amazonsqs
springamqp
springcloudaws
Akka 流如何不断实现?
我在用阿卡流 http doc akka io docs akka stream and http experimental 1 0 scala stream index html在 Scala 中进行轮询AWS SQS https aws
scala
akka
amazonsqs
awssdk
akkastream
如何使用加密的 DLQ 将重新驱动策略添加到 SNS
我有一个 SNS 用 KMS 加密 由两个 lambda 订阅 我正在尝试向其中一项订阅添加重新驱动策略 相关 DLQ 已加密 添加重新驱动策略会出现错误 无法检查 Amazon SQS 队列权限 确保队列存在并且您的帐户有权读取队列的属性
amazonwebservices
errorhandling
amazonsqs
amazonsns
在 Lambda 中重新处理 DLQ 事件
我有一个配置了 SQS DeadLetterQueue 的 AWS Lambda 函数 A 当 Lambda 无法处理事件时 该事件会正确发送到 DLQ 有没有办法重新处理以 DLQ 结束的事件 我找到了两种解决方案 但它们都有缺点 创建一
amazonwebservices
awslambda
amazonsqs
deadletter
可以从 http(javascript 客户端)直接向 Amazon SQS 发送请求吗?
是否可以直接从 JavaScript 向 Amazon 的 SQS 发送消息请求 我正在尝试创建一个日志系统 并且希望绕过将请求发送到中间人服务器 另外 有人知道我可以利用这个解决方案的任何替代方案吗 SQS 事实上所有 aws 服务 都公
amazonwebservices
MessageQueue
amazonsqs
Amazon AWS SQS - 将 QueuePolicy 应用于现有队列
如果我通过 Cloudformation 创建 SQS 队列 您是否可以在创建 SQS 队列后附加第二个 QueuePolicy 如果我运行以下配置 Resources SQSQueue Properties QueueName Ref S
amazonwebservices
awscloudformation
amazonsqs
我可以判断 Amazon SQS 消息是否仍在传输中吗?
给定一条 Amazon SQS 消息 有没有办法通过 API 判断它是否仍在运行中 或者 我是否需要记下收到消息时的时间戳 从当前时间中减去该时间戳 然后检查该时间戳是否小于可见性超时 使用 Amazon Simple Queuing Se
amazonwebservices
amazonsqs
AWS Lambda SQS 触发器限制/限制
我有一个 AWS SQS 队列 我将使用 Lambda 函数触发器对其进行设置 以便为添加到队列中的每个项目运行 Lambda 函数以执行一些处理工作 处理的一个步骤是访问 API 端点 为添加到队列中的每个项目取回一些数据 然后将其存储在
amazonwebservices
awslambda
amazonsqs
仅在处理同一主题的 SQS 订阅后调用 AWS Lambda SNS 事件
我想实现一个 Amazon SNS 主题 它首先将消息传递到作为该主题订阅者的 SQS 队列 然后执行也是同一主题订阅者的 AWS Lambda 函数 然后 Lambda 函数可以从 SQS 队列读取消息并并行处理其中的多个消息 数百个 我
amazonwebservices
amazonsqs
amazonsns
awslambda
如何将数据从 Amazon SQS 流式传输到 Amazon S3 中的文件
如何快速创建从 Amazon SQS 读取 json 数据并将其保存在 s3 存储桶中的 avro 文件 可能是其他格式 中的机制 并按 json 消息中给定字段的日期和值进行分区 你可以写一个AWS Lambda 函数由发送到 Amazo
amazons3
amazonsqs
AWS Lambda SQS 触发器在队列重新创建后未触发
我一直在使用 terraform 定义一些 SNS 主题 然后使用 SQS 队列来订阅它们 然后这些队列具有由 SQS 触发的 lambda 并从这些队列中获取消息 Terraform 处理 SNS 主题 SQS 队列的创建以及允许 SNS
amazonwebservices
awslambda
amazonsqs
amazonsns
Airflow + Cluster + Celery + SQS - Airflow Worker:“Hub”对象没有属性“_current_http_client”
我正在尝试对我的 Airflow 设置进行集群 并且正在使用本文 https i stack imgur com JRNOj png这样做 我刚刚配置了我的airflow cfg文件以使用CeleryExecutor 我指着我的sql al
python
Celery
amazonsqs
airflow
airflowscheduler
1
2
3
4
»