amazon-sqs

    0热度

    1回答

    我与SQS celery worker -A project.celery --loglevel=info 与同SQS的连接字符串信息运行,我可以连接到一个SQS队列,并修改/写消息。但芹菜工人不会开始。它给了我错误: [2017-04-27 00:11:34,592: CRITICAL/MainProcess] Unrecoverable error: TypeError('invalid

    0热度

    1回答

    是否可以在Elastic Beanstalk中使用SQS的所有功能?我的意思是,在desctiption他们说,网络层可以通过SQS发送消息到工作层。但是,网络层也可以接收来自SQS的消息,或者可以说网络层可以使用本地SQS-API?

    0热度

    1回答

    AWS控制台中是否有选项查看向SQS请求民意测验的时间戳?我想看看客户端最后一次轮询队列的时间。 我在CloudWatch中可以看到的最接近的指标是NumberOfMessagesReceived,它是通过调用ReceiveMessage API操作返回的消息数。但我也想看看这些电话的时间戳。

    0热度

    1回答

    我能够从我的springboot发送消息到SQS队列,但无法使用sqslistener注释接收,有人可以帮忙吗? public void send(String message) { queueMessagingTemplate.convertAndSend("test-queue", MessageBuilder.withPayload(message).build()); }

    0热度

    1回答

    我正在使用SQS作为我的ActiveJobs的后端。 我有被发送到队列中after_create回调我的模型的一个非常简单的工作: after_create :update_stuff_after_create 这初始化一个ActiveJob: UpdateStuffAfterCreateJob.perform_later(self.id) 将作业发送到SQS正确排队。问题是,其他实例谁是

    1热度

    1回答

    我正在研究一项要求,要求我在成功获取某些数据后调用特定的端点。我们使用发布到SQS队列的SNS主题实现了这一目标,SQS队列又调用端点。 SNS - > SQS - >我的端点(进程Q消息) - >调用外部端点来获取数据。 现在,我们发现订单处理后数据不可用,现在需要每隔30秒继续尝试5次。 有什么办法可以做到这一点? 现在,我做了这样的事情,使得从队列处理消息的我的端点始终返回错误,以便重试消息

    0热度

    1回答

    我正在sqs队列上发送消息,奇怪的消息在消费者读取消息之前被删除或删除。 我已记录活动,我可以看到消息成功进入队列,但消费者没有得到它。 可能是什么原因? 这post是相关的,但运算解决它在私人那么伤心无解

    1热度

    1回答

    我在特殊标题中获得WebHook中的签名。我想将它们传递给令牌体或属性中的SQS。我试过以下配置。它不工作。请帮助 以下是详细信息: AWS Service : Simple Queue Service (SQS) HTTP method :POST Path override :Account/QueueName?Action=SendMessage Execution role :arn

    1热度

    1回答

    有没有办法在SQS消息中发送配置为通过EC2的自动缩放服务启动的衍生“缩放”实例的列表?

    0热度

    1回答

    我有一个需要很长时间才能完成的lambda函数。它从DynamoDB读取记录,并为每个记录执行对第三方服务的HTTP调用,然后将结果保存回DynamoDB。我想扩展这个功能,这样它可以处理更多的记录。因需要重新设计,因为最大拉姆达持续时间可以超过。 解决方案似乎很明显。一个lambda从DynamoDB读取所有记录,或者为所有记录进行HTTP请求,并将消息发送到SQS。另一个lambda在队列中侦