腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
java
-
消息
通过
camel
处理
后
无法
从
SQS
中
删除
、
、
、
我
无法
在
消息
处理
后
将其
从
SQS
中
删除
...我尝试了在StackOverflow上解释的几种方法,但都不适用于我…… 这是我发送的
SQS
部分 @Override .endChoice() .end(); 该文件被
处理
并发送到服务器,但在<e
浏览 9
提问于2020-07-22
得票数 1
回答已采纳
1
回答
调用amazonSQS.deleteMessage(queueURL,receiptHandle)时引发javax.xml.stream.XMLStreamException异常
、
、
、
、
我正在开发一个应用程序,其中我
通过
Apache
Camel
连接到
SQS
queue,它只需要AmazonSQS客户端(我找不到任何
Camel
+ AWS SDK和
Java
2.x的引用)作为
SQS
queue作为同一个应用程序的一部分,我在
SQS
中
做了不同的操作,其中之一是
删除
消息
。同时使用AmazonSQS.delete(queueURL,receiptHanlde)
从
AWS
SQS</em
浏览 17
提问于2021-03-18
得票数 0
1
回答
如何使用apache
camel
将批
处理
消息
发送到
sqs
队列
、
、
我在apache
camel
中有一个rest api。我根据
sqs
的文档,使用apache
camel
编写了类似这样的代码来向
sqs
发送批
处理
消息
。.post("
sqs
-send-batch-message") .process(new Processor} })
浏览 23
提问于2020-07-13
得票数 0
回答已采纳
1
回答
Apache
Camel
立即从
SQS
读取
、
、
、
我有非常庞大的骆驼管道,它从消费来自
SQS
的
消息
开始。整个过程所需的时间各不相同。
从
5秒到30分钟,这里很难猜到。我想达到的目标是:尝试了
Camel
选项deleteAfterRead=true ->并不有用,因为正如doc:在读取(并由路由
处理
)之后
从
SQS
删除</
浏览 4
提问于2020-11-04
得票数 0
1
回答
如何使用多个核心
处理
来自
Camel
的
SQS
消息
、
、
我使用
Camel
从
Amazon队列
中
读取
消息
,进行一些CPU密集型
处理
,然后将它们放到另一个
SQS
队列
中
。
Camel
是
通过
使用mvn
camel
:run的maven插件调用的。当运行在具有多个核的服务器上时,
Camel
似乎只使用单个内核来
处理
消息
(
通过
监视所有内核的CPU利用率来观察)。如何利用所有可用的核心?我尝试过的事情: 运行JVM的多
浏览 0
提问于2014-10-02
得票数 1
回答已采纳
2
回答
消费者/生产者AWS
SQS
akka scala和synchrone使用者
、
、
、
、
有时我的队列将是空的,有时我会收到一些
消息
。我希望让我的消费者收听队列,当
消息
在其中时,接受它并
处理
这条
消息
。这个过程可能需要几个小时,如果消费者还没有完成当前
消息
的
处理
,我不希望他接收队列
中
的另一条
消息
。class MySqsConsumer e
浏览 4
提问于2016-06-17
得票数 0
1
回答
Spring-boot + Apache
camel
+嵌入式tomcat,显示
SQS
删除
时回执句柄已过期。在外部tomcat
中
工作正常
、
、
、
、
使用apache
camel
访问
SQS
。
从
SQS
中使用
消息
后
,必须将其
从
队列
中
删除
,但它显示“接收句柄已过期”。我们在做负载测试时遇到了一些问题,在很少的请求下,它工作得很好。Caused by: [com.amazonaws.services.
sqs
.model.AmazonSQSException ReceiptHandle is invalid.使用apache
camel
访问
SQS<
浏览 57
提问于2019-08-26
得票数 0
1
回答
骆驼
SQS
解组
、
我有非常简单的
camel
路由器,它使用
SQS
和base64解码: from("aws-
sqs
://test-
camel
-start?测试-骆驼启动”队列读取
消息
;2) BaseProcessor成功地
处理
消息
;3)在将
消息
重试到“测试-骆驼-成功”的过程
中
失败。)( com.amazonaws.services.
sqs
.AmazonSQSClient.sendMessage(Amazo
浏览 0
提问于2018-03-28
得票数 3
回答已采纳
1
回答
如果
处理
时间过长,Apache是否会跳过
删除
从
队列
中
读取的
消息
?
、
、
我有一个Apache使用者,它从
SQS
标准队列读取
消息
并对其进行
处理
。 有些
消息
处理
时间非常短(1-2分钟),而有些
消息
需要很长时间(70-80分钟)。我没有在
Camel
配置
中
显式指定可见性超时,因此,按照队列配置
中
的指定,每个
消息
读取的可见性超时时间为30。需要很短时间
处理
的
消息
运行良好,但是对于持续时间较长的
消息
,Apache在完成
处理
<em
浏览 0
提问于2021-07-06
得票数 0
回答已采纳
1
回答
使用Apache基于S3事件通知传输S3文件
、
、
、
我有一个应用程序(运行在EC2实例上),它解析到达S3桶
中
的新日志文件。我在这个桶上设置了S3通知,以便在put请求上将
消息
放在
SQS
队列
中
。目的是将新到达的日志文件
从
S3传输到EC2实例。我对解决办法有以下问题/意见,并希望就此提供一些反馈意见: 我们可以使用
Camel
路由
从
SQS
读取
消息
,然后
从
JSON
消息
中提取对象密钥。在将对象
从
S3复制到本地FS的另一个<em
浏览 3
提问于2015-01-14
得票数 4
3
回答
导入/
处理
场景
、
、
、
我想协调告诉服务器B
从
服务器A启动进程,然后在服务器A上运行导入脚本,当它完成
后
,我很难在这个场景中正确地使用
SQS
。服务器A:主要专用服务器B:云
处理
服务器
浏览 2
提问于2013-03-13
得票数 2
回答已采纳
2
回答
我是否可以将S3用作共享的独立工作队列?
、
、
、
我在S3存储桶中有一组文件,我想让多个客户机
通过
下载和
删除
这些文件来
处理
这些文件,以便可以在本地
处理
它们。 如何确保只有一个客户端可以访问任何单个文件,以便只有一个worker下载并
处理
该文件?
浏览 2
提问于2021-07-29
得票数 0
1
回答
基于
SQS
消息
中
的url下载使用
Camel
的文件
我试图使用
Camel
从
SQS
队列
中
读取XML
消息
,
从
XML
中
的特定节点提取URL,并将该URL上的文件下载到特定的目录
中
。<command> <path>http://example.com/myfile/here?(我可以编写一个
处理
器来读取
SQS
消息
并下载该文
浏览 1
提问于2014-11-21
得票数 0
回答已采纳
1
回答
Amazon没有向我的worker实例提供完整的
消息
、
、
、
我试图用
SQS
排队并
处理
请求。我使用弹性豆茎上的一个Node.JS工作人员来设置它,当
消息
从
另一个框添加到它时,它会自动
从
SQS
获得http帖子。问题是,我
无法
从
http post获得所有必要的数据来
删除
队列
中
的
消息
。我看到的唯一数据是我自己输入的
消息
数据,但没有MessageId或ReceiptHandle。当我手动调用
SQS
.receiveMessage(qu
浏览 2
提问于2016-10-23
得票数 1
回答已采纳
1
回答
如何
从
lambda触发器返回
消息
给
SQS
?
、
我有lambda触发器,它从
SQS
队列读取
消息
。在某些情况下,
消息
可能还没有准备好进行
处理
,所以我想将
消息
放回队列
中
1分钟,然后再试一次。与创建新记录相比,我是否有理由/方法将原始记录保留在队列
中
?attemptCount = 2
sqs
= boto3.resour
浏览 1
提问于2018-12-16
得票数 1
1
回答
我的lambda函数没有
从
SQS
服务接收事件
、
、
、
我已经设置了一个lambda函数和一个
SQS
服务。我希望来自
SQS
服务的事件由lambda函数使用。 所有其他配置都设置为与默认配置匹配。λ触发器Lambda配置使用的代码来自
sqs
-poller模板(以及配置)我正在使用发送事件。/credentials node
sqs
.js你知道为什么我的lambda函数没有使用事件吗?
浏览 7
提问于2021-07-20
得票数 0
2
回答
处理
后
从
SQS
队列
中
删除
消息
、
、
我的应用程序将
消息
发送到AWS
SQS
队列,以获取需要某种后台
处理
的作业。我的
处理
守护进程接收并
处理
如下
消息
: 'QueueUrl' => \Myapp\Config::get('
sqs
.queue$handler = new \Myapp\Handler(); $handler->dispatch($messageBod
浏览 0
提问于2015-02-22
得票数 9
回答已采纳
2
回答
Akka,
SQS
和
Camel
的消费者民意测验率
、
、
、
我正在从事的一个项目需要读取来自
SQS
的
消息
,我决定使用Akka分发这些
消息
的
处理
。由于
SQS
是
Camel
支持的,并且有内置的功能供消费者类
中
的Akka使用,所以我认为最好以这种方式实现端点和读取
消息
,尽管我没有看到很多这样做的例子。我最初想的是,我可以让一个消费者以X/s的速度在
Camel
上接收来自
SQS
的
消息
,从那里,我可以创建更多的消费者,以达到我需要
处理
消
浏览 0
提问于2013-11-04
得票数 6
回答已采纳
1
回答
Apache
Camel
:在完成聚合交换时完成交换
在我的Apache
Camel
应用程序
中
,我有一个非常简单的路径: .aggregate(constant(true), new AggregationStrategy()) .to("SEND_AGGREGATE_VIA_HTTP"); 也就是说,它从AWS
SQS
获取
消息
,以100个为一批对它们进行分组,然后
通过
与来
浏览 0
提问于2016-11-30
得票数 1
1
回答
节流阀语法示例
、
、
我有一个简单的路由,可以将
消息
从
SQS
转移到本地数据库: """aws-
sqs
://123467890/test-queue("dlr_body", body) to("sql:insert into
camel
_test
浏览 5
提问于2015-12-21
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Java近期新闻:JNoSQL 1.0、Liberica NIK 23.0、Micronaut 4.0-RC2、Log4j 3.0-Alpha1、KCDC、JCON
Java近期新闻:Java 28岁、Payara、Micronaut 4.0-M5、Spring更新
我是如何在AWS Lambda中用几分钟处理50万个事务的?
Java近期新闻:字符串模板、Quarkus、Open Liberty、PrimeFaces、JobRunr、Devnexus 2023
“集成架构”我们得谈谈 Apache Camel集成框架
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券