首页 > TAG信息列表 > amazon-sqs

mysql-Amazon SQS会将数据库写入程序

因此,假设我正在建立netflix,我想通过userID和电影ID记录每个视图 因此它类似于viewID,userID,时间戳, 但是,为了扩展此功能,假设每秒获得1000次观看(只是为了疯狂).将这些视图排队到SQS是否有意义,然后我们的队列读取器可以逐个取消排队并将其写入mysql数据库.这样,数据库不会因写

我有一个AWS访问密钥,并且已经创建了一个SQS队列,但仍然无法使用python boto访问SQS

因此,我有一个AWS访问密钥ID及其相应的AWS秘密密钥.此外,从AWS仪表板中,我已经在SQS中创建了一个队列,并将测试消息放入该队列中.我已经下载了适用于Python的boto.但是,当我尝试运行最基本的命令时,出现错误： import boto.sqs conn = boto.sqs.connect_to_region('us-west-2',

春天-SimpleMessageListenerContainer Amazon SQS Pollinterval

我正在使用Spring Cloud库轮询SQS.如何设置轮询间隔？ @Bean @Primary public AmazonSQSAsync amazonSQSAsync() { return AmazonSQSAsyncClientBuilder.standard(). withCredentials(awsCredentialsProvider()). withClientConfiguration(clientConfig

python-在AWS SQS队列中连续读取数据

我是AWS SQS队列的新手,目前正在玩boto.我注意到,当我尝试在while循环中读取填充有消息的队列时,我看到读取10-25条消息后,该队列不返回任何消息(即使该队列有1000条以上的消息).几秒钟后或停止并重新启动程序后,它将开始填充另一组10-25条消息. 虽然为真：   read_queue()//已使

java-ec2实例上的堆栈不存在错误,但在本地工作正常

我低于异常,也没有任何解决方案来解决问题.另外,如果您想知道的话,我在gradle文件中使用了Amazon Cloud sqs依赖项.任何帮助将不胜感激. Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'stackResourceRegistryFactoryBean'

春天-在哪里可以找到SqsListener

我们正在尝试使用spring-cloud-aws从AWS SQS接收消息 我们希望使用注释接收消息.在春季documentation,令人困惑. 下面,他们声明使用MessageMapping和QueueMessageHandler批注. Annotation-driven listener endpoints are the easiest way for listening on SQS messages. Simp

php – 与Laravel中的AWS Sqs Queue相关的错误

尝试访问队列时,我在laravel中收到此错误 – Class 'Aws\Sqs\SqsClient' not found 我的默认队列是’sync’,我在composer.json的任何地方都没有要求’Sqs’.那么为什么会这样呢？是否必须将其包含在较新版本的Laravel中.解决方法:我用这个包：https://github.com/aws/aws-sdk-php-l

使用AWS SDK for PHP获取SQS队列中的所有消息

我正在尝试使用AWS PHP SDK检索队列中的所有消息. 之前曾经有过get_queue_size()方法来获取队列大小,然后我会遍历循环以获取所有消息. 在最新的SDK中,我没有看到这样的方法. Link 有人能告诉我如何使用最新的PHP SDK接收队列中的所有消息吗？解决方法:您可以获取队列中的所有消息,但

python – 使用SQS撤销Celery任务

我正在使用Celery Kombu和Amazon SQL. 目标是能够删除已安排在某个特定日期时间的任务.我试过了 from celery.task.control import revoke revoke(task_id) 但这并没有改变任何事情.是否撤销未实施SQS传输？它背后是否有一些设计决策,或者只是缺少一些应该由一些“DeleteMessage”

用于aws扩展客户端库的Spring cloud sqs

看来spring cloud aws sqs不支持aws sqs扩展客户端库. 当我向队列发送消息时,Spring sqsListener无法处理像这样的meaasge： [ “com.amazon.sqs.javamessaging.MessageS3Pointer”,{ “s3BucketName”： “储物柜生命EDI-数据文件从 – SQS-dev的”, “s3Key”：“f7777cab-00BA-4a8d-8

c# – 有效监控新的SQS消息

我在我的应用程序中使用Amazon SQS来使用消息.我的应用程序用于处理图像.我正在寻找一种有效的方法来持续监控新消息.我的第一种方法是在图像处理完毕后读取消息. 问题是如果一条消息在最长20秒拉长后单独到达,则什么都不会触发读取消息功能. 我考虑创建一个在一个区间内运行的函数

java – 创建将来要处理的Amazon SNS消息

在过去几年中,我们使用自己的RM应用程序来处理与我们的应用程序相关的事件.这通过每隔几分钟轮询一个数据库表,查找之前有截止日期但尚未处理的任何行来工作. 我们目前正在向SNS过渡,SQS Worker层处理它们.这种方法的问题是我们将来不能约会我们的消息.我们的应用程序有时会有一些

通过Amazon SQS将压缩文本从PHP发送到NodeJS

我似乎停留在通过Amazon SQS将压缩消息从PHP发送到NodeJS. 在PHP方面,我有： $SQS->sendMessage(Array( 'QueueUrl' => $queueUrl, 'MessageBody' => 'article', 'MessageAttributes' => Array( 'json' =>

带有Java SQS JMS连接器的AWS Xray

我们最近开始在我们的Spring项目中添加AWS Xray,并成功利用AWSXRayServletFilter创建Segments来覆盖我们的客户请求. 现在我们也开始添加AWS SDK Instrumentor来跟踪我们的AWS服务用法.其中一个是SQS,我们使用amazon-sqs-java-messaging-lib来利用JMS接收SQS消息.这是我们面临一些

java – 亚马逊sqs的异步消费者

我不熟悉队列. 我能够成功发布消息并同步接收消息但是,我现在正试图异步. sqs提供的参考链接建议使用jmsclient包装器.如果您已经有一个集成到jms客户端的代码,那么该链接还会提到使用它. http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/jmsclient.ht

java – SpringBoot @SqsListener – 无法正常工作 – 使用Exception – TaskRejectedException

我有一个AWS SQS,其中已有5000条消息在队列中(示例消息看起来像’Hello @ 1′) 我创建了一个SpringBoot应用程序,并在其中一个组件类中创建了一个从SQS读取消息的方法. package com.example.aws.sqs.service; import org.springframework.cloud.aws.messaging.listener.SqsMessag

php – 亚马逊简单队列服务(SQS)

我在SQS中创建了一个队列,添加了两条消息(序列化的PHP数组：array(‘filename’=> 0,…)和array(‘filename’=> 1,…)).我从他们的git repo使用最新版本的amazon SDK for PHP. 问题是当我使用带有以下选项的receive_message函数时： MaxNumberOfMessages = 10 VisibilityTimeout = 0

将python BOTO与AWS SQS一起使用,获取无意义的字符

所以,我使用python和BOTO来访问我的AWS SQS.我在SQS中有一些消息,我可以从AWS仪表板中看到这些消息.但是,当我尝试通过python获取这些消息时,通过的字符只是乱码.知道这里发生了什么吗？ conn = boto.sqs.connect_to_region("us-east-1") q = conn.get_queue('my-worker-queue') pr

java – 使用AmazonSQSClient消息消息缓慢

因此,我在春季jms 50-100使用并发,允许最多连接高达200.一切都按预期工作但如果我尝试从队列中检索100k消息,我的意思是我的sqs上有100k消息,我通过弹簧读取它们jms正常的方法. @JmsListener Public void process (String message) { count++; Println (count); //code } 我在控

如何绕过Linux“Too Many Arguments”限制

我必须将256Kb的文本作为参数传递给“aws sqs”命令,但是在命令行中运行的限制大约为140Kb.这已在许多地方讨论过it been solved in the Linux kernel as of 2.6.23 kernel. 但无法让它发挥作用.我使用的是3.14.48-33.39.amzn1.x86_64 这是一个简单的测试示例： #!/bin/bash SIZE=

php – 在多个服务器上扩展cronjobs

现在,我们有一个服务器,带有一个cronjob选项卡,可以发送每日电子邮件.我们想扩展该服务器.该应用程序是部署在亚马逊云的centos服务器上的标准zend框架应用程序. 我们已经负责了负载平衡,内容管理和管理部署.然而,对于我们来说,cronjob仍然是一个问题,因为我们需要承认一些工作只执