对Camel聚合拆分的最后一个索引执行操作
是指在Camel路由中使用聚合器（Aggregator）将多个消息合并为一个消息，并在最后一个消息上执行某种操作。聚合器是一种模式，用于将多个相关消息合并为一个消息，以便进行后续处理。
聚合拆分是指将一个消息拆分为多个子消息，并在每个子消息上执行某种操作。在Camel中，可以使用splitter模式来实现聚合拆分。splitter模式将一个消息拆分为多个子消息，并将每个子消息发送到下一个处理器进行处理。
对于聚合拆分的最后一个索引执行操作，可以使用Camel的聚合器来实现。聚合器可以在每个子消息上执行某种操作，并将结果合并为一个消息。在最后一个子消息上执行操作可以使用Camel的聚合器的完成策略（Completion Strategy）来实现。完成策略定义了何时认为聚合操作完成，并触发最后一个子消息上的操作。
以下是一个示例代码片段，展示了如何在Camel中对聚合拆分的最后一个索引执行操作：
from("direct:start")
.split().body()
.aggregationStrategy(new MyAggregationStrategy())
.completionSize(3) // 设置聚合的大小，这里假设有3个子消息
.completionTimeout(5000) // 设置聚合的超时时间，如果在5秒内没有收到足够的子消息，则触发聚合操作
.to("direct:aggregate");
from("direct:aggregate")
.process(new MyProcessor()); // 在最后一个子消息上执行操作的处理器
class MyAggregationStrategy implements AggregationStrategy {
public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
if (oldExchange == null) {
return newExchange;
}
// 合并消息的逻辑
return oldExchange;
}
}
class MyProcessor implements Processor {
public void process(Exchange exchange) {
// 在最后一个子消息上执行操作的逻辑
}
}在上述示例中，我们使用了splitter模式将消息拆分为多个子消息，并使用自定义的聚合器（MyAggregationStrategy）将子消息合并为一个消息。在最后一个子消息上执行操作的逻辑在MyProcessor中实现。
对于Camel聚合拆分的最后一个索引执行操作，可以根据具体的业务需求来定义聚合器和处理器的逻辑。在实际应用中，可以根据需要选择不同的聚合策略和完成策略，以满足业务需求。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云云服务器（ECS）：https://cloud.tencent.com/product/cvm
- 腾讯云云原生容器服务（TKE）：https://cloud.tencent.com/product/tke
- 腾讯云云数据库MySQL版（CDB）：https://cloud.tencent.com/product/cdb
- 腾讯云人工智能（AI）：https://cloud.tencent.com/product/ai
- 腾讯云物联网（IoT）：https://cloud.tencent.com/product/iotexplorer
- 腾讯云移动开发（移动推送、移动分析、移动测试等）：https://cloud.tencent.com/product/mobile
- 腾讯云对象存储（COS）：https://cloud.tencent.com/product/cos
- 腾讯云区块链服务（BCS）：https://cloud.tencent.com/product/bcs
- 腾讯云元宇宙（Tencent Cloud Metaverse）：https://cloud.tencent.com/solution/metaverse
相关·内容
我是activeMQ / Camel的新手，所以请容忍我。
在驼峰路由中，我使用拆分器来生成多个子路由。这些路由中的每一个都将使用一些外部API来做一些工作，并进行轮询，直到工作完成。我就差那么远。
现在，我需要触发最后一个操作来收集所有这些路由的结果。我该如何使用Camel / AMQ的方式呢？
我正在考虑将每个子路由中的一条消息发送到一个AMQ队列，但我还没有找到一种方法，在我的最后一个Camel路由中使用它之前，等待在该队列中接收到N条消息。
谢谢。
浏览 1提问于2020-02-03得票数 0
1回答
我只是试图拆分Map实例的列表，在bean中处理它们，然后将它们合并到list对象中。所以我做了这件事：
<camel:route>
<camel:from uri="ref:contactHistoryDbRead"/>
<camel:split parallelProcessing="true" streaming="true" strategyRef="groupedExchangeAggregationStrategy">
浏览 4提问于2015-04-01得票数 0
我需要发布一个JSON Camel Servlet，然后复制消息并拆分列表。处理每个分裂的消息，最后聚合并返回servlet响应。
但是，一旦在路由中引入拆分器，我就会看到输入流正在关闭，Servlet无法将响应写回。
请注意，流缓存也是启用的。
from("servlet:sample")
.log(LoggingLevel.INFO, "Message Received: JSON RQ")
.to("direct:samplejson");
from("direct:s
浏览 1提问于2017-06-12得票数 0
我们使用拆分器来迭代压缩文件中的文件，同时，我们还使用了一个自定义聚合器，它为我们提供了一个正文列表--主压缩文件中的两个文件的列表。现在，在拆分之后，我想提取在聚集器结果上发生的聚集块处理期间设置的头。但是，聚合器的输出似乎丢失了，并且在拆分块之后我没有得到任何东西。
我确信我没有得到这方面的基本知识。如果有人能帮上忙我会很感激的。
<route id="main-route">
<split streaming="true">
<ref>zipSplitter</ref>
浏览 3提问于2015-08-28得票数 2
1回答
问题:
首先，我有一个笼子的列表，在那里我分别检索这些笼子的位置。
下面的消费者已经一个接一个地得到了保持架，处理器提取了这个位置。
from("direct:cages-to-positions")
.process(new CageToPositionProcessor())
.aggregate(body(), new PositionsAggregation())
.completionTimeout(1000)
浏览 0提问于2018-04-18得票数 1
回答已采纳
1回答
我正在解析一个CSV文件，将其拆分并通过camel中的多个处理器进行路由。有两个端点，一个具有错误数据，而另一个具有验证数据。
我需要在聚合数据方面的建议。
假设CSV文件有10条记录，其中6条到达一个端点，4条到达另一个端点。我如何才能知道每个端点的文件中的所有10个都已完成，并领先于聚合器。我需要创建两个文件，一个包含有效数据，另一个包含来自单个文件的损坏数据。
浏览 1提问于2014-10-14得票数 3
回答已采纳
我使用CAMEL聚合来自两个来源的响应，一个是xml，另一个是json。最初，我已经将这些响应存根，并从文件中获取它们。目标是聚合来自两个来源的响应。
我的聚合器路由如下所示
from("direct:fetchProfile")
.multicast(new ProfileAggregationStrategy()).stopOnException()
.enrich("direct:xmlProfile")
.enrich("direct:jsonProfile")
.end();
我的"dir
浏览 0提问于2014-09-21得票数 0
我想处理一系列自定义的java对象，使用camel拆分器拆分这些对象，并希望以并行线程的方式处理它们。但我面临的挑战是，自定义对象的列表是根据Id排序的，而Id必须写入文件中。
一旦我使用并行处理，这个序列就会被打乱。我浏览了一些文章，这些文章要求使用“重定序器”或“单线程”。但使用单线程时，处理5000条记录需要大量的时间。
任何线索都会很有帮助。谢谢Nitin
浏览 1提问于2018-05-06得票数 1
2回答
我想知道是否有人能解释一下为什么GroupedExchangeAggregationStrategy没有做我希望它应该做的事情。
我有一个正确切分的消息列表，每个消息都被传递到我的路由进程。通过这种方式，聚合器应该收集所有的响应，并将它们组合到一个很好的最终交换中，然后返回它。
然而，我看到的是，每个拆分的消息都得到了正确的执行。但是聚合器似乎并没有把它们放在一起。相反，父路由以原始邮件结束。这就是我在默认的Camel DefaultAggregationCollection和UseLatestAggregationStrategy中看到的行为。但是，如果我将策略更改为GroupedExcha
浏览 1提问于2014-02-10得票数 1
回答已采纳
3回答
Apache Camel迭代列表
、、、、
我是Apache Camel的新手，我在理解如何实现一个简单的集成任务时遇到了问题：
REST服务正在通过Apache路由调用Spring
Spring返回类集合(ArrayList)
我需要迭代集合中的每一项，并通过自定义转换器将其转换为另一种类型。
我似乎应该使用Split和聚合器，但是如何约束聚合器使用原始列表中的所有项，而不是更多，更少。此外，如何将一个项目转换为另一个项目？我应该使用类型转换器吗？
有人能给我举个简单的例子吗？
更新1
对不起，我不得不撤销对所提供的例子的接受，因为它实际上没有回答我的问题。下面是用例限定:我需要拆分和转换来自to("bean:
浏览 2提问于2014-11-24得票数 1
回答已采纳
1回答
我们在Camel中定义了一条路由，并必须找出是否在处理器中抛出异常。当我们只有一个处理器时，Camel会在sendBody()方法中重新抛出异常。如果存在前面的拆分/聚合，则不会引发异常。因此，下面示例的结果是
before throwing Exception
after sendBody
如果我省略了从.split到.completionSize(1)的所有内容，输出是
before throwing Exception
Exception thrown
有什么想法，如何找出，如果出现异常后，分裂？
private static final String DIRECT_START =
浏览 8提问于2016-02-11得票数 2
回答已采纳
我手头有一种情况，我需要从目录中读取并处理那里的所有XML文件。然后，根据某些规则对文件进行处理和拆分，从而产生N个新消息/文件。我想将所有新文档聚合到一个索引文件中，每个文件只有一行。批处理完成后，我将调用一个webservice并告诉它获取索引文件。
我面临的问题是Camel没有将文件的传递看作一个作业，而我的聚合被多次调用，导致多个索引文件而不是一个索引文件。我曾尝试使用Exchange.BATCH_SIZE属性，并将其乘以Exchange.SPLIT_SIZE用于aggregration completionSize。
伪码：
from("file://&#
浏览 1提问于2019-05-26得票数 2
我知道这个问题已经问过很多次了，但没有一个帖子对此有帮助，也没有一个有决定性的解决办法。我正在拆分一条消息，然后使用Aggregator2聚合它。代码抛出异常，因为oldExchange总是空的。所以为了测试我设计了一个小代码。
我读了一个订单，xml文件，如下所示
<Orders xmlns="http://some/schema/Order">
<Order>
<orderNum>1</orderNum>
</Order>
<Order>
浏览 0提问于2014-01-22得票数 2
回答已采纳
我们在我们的项目中使用camel-cxf作为使用者(soap)，并问自己camel-cxf是否使用多个线程来响应请求。我们认为它使用多个线程，对吗？！但这对剩下的路线意味着什么呢？是否所有多线程都在"from“之后，还是存在同步点？
这对"parallelProcessing“或”线程“意味着什么？
在我们的例子中，我们稍后在路由中使用jdbc组件。camel是否也使用多个线程？
一般情况下，如何知道给定组件所使用的线程模型？
浏览 5提问于2016-11-02得票数 3
2回答
我正在使用Camel Split组件和并行处理来拆分整数的ArrayList。该列表中包含700,000+ in。其思想是每个ID都需要传递给XML生成器，然后插入到数据库表中。但是，我注意到，在消息体中生成并传递回Camel的XML似乎被保留。它看起来像是持有消息正文，直到拆分中的所有元素都完成处理。这意味着我的内存中应该有700,000+ XML。有没有办法告诉Camel不要这么做？是否在拆分工作完成时丢弃拆分工作？
我已经尝试创建I块并拆分每个块，允许拆分完成并释放内存。这里的问题是每个ID生成不同大小的XML。因此，如果我创建了10个I的区块，其中1个具有关联的非常大的XML，则我的线
浏览 1提问于2014-03-27得票数 2
1回答
我想聚合一组xml。首先，我将展示我想要得到的最终结果
<?xml version="1.0" encoding="UTF-8"?>
<order>
<header>
<name>something</name>
<age>321321</age>
</header>
<message>
<id>1</id>
<name>some
浏览 1提问于2018-12-11得票数 0
我想聚合3个主题，但只是为了聚合策略的PoC，我尝试聚合2个主题。 因此，我已经配置了以下Camel路由： @Override
public void configure() throws Exception {
CamelContext contexto = new DefaultCamelContext();
try{
onException(SQLException.class, Exception.class)
.handled(true)
.maximumRedeliveries(1)
.process
浏览 44提问于2020-08-15得票数 1
回答已采纳
1回答
在尝试使用Apache camel聚合策略时，我遇到了如下所述的问题：
我的应用程序:公开一个简单的soap服务，该服务包含组织中部门的名称(财务、销售.)。在我的骆驼路线内，我相应地将请求路由到部门特定的路线。在这些路径中，我查询一个表，并为该部门获取员工。
作为soap服务的响应，我希望将所有员工聚集在一起并发送。
下面是我的骆驼路线：
<camelContext id="camel"
xmlns="http://camel.apache.org/schema/spring">
<camel:dataFormats>
浏览 0提问于2018-04-10得票数 1
回答已采纳
我们在Camel中定义了一个具有拆分和聚合功能的路由，但是不能在聚合器之后将异常传播回split。即使遇到异常，也会导致分割运行
下面是不起作用的代码
from("direct:MyRoute")
.routeId("MyRouteID")
.split().tokenize("\n", 1)
.streaming().stopOnException()
.choice()
.when(simple("${property.CamelSplitIndex} >
浏览 1提问于2017-01-20得票数 2
在camel中，如何通过AggregateStrategy中的aggregate()返回多个交换。我编写了聚合两个csv文件的逻辑，我想根据某些条件生成3个不同的文件，这样我就可以发送3个交换对象，并将其发送到不同的路由器。
浏览 0提问于2014-09-29得票数 0
我正在从rabbit上拉取消息并聚合它们。我注意到，即使使用autoAck=false，消息一旦聚合就会被确认。这意味着如果我的进程崩溃，消息将不会重新排队等待rety。
我插入了leveldb java db作为聚合repo，它解决了这个问题，因为我假设它只有在聚合并存储在repo中时才会确认。老实说，基于它的活动和C版本的问题，level-db让我感觉不舒服，我想我可以把它切换到SQL代码库。
所以。问题是，有没有什么我可以做的，这样Camel只会在聚合消息完成其旅程后才接受交换的消息？聚合之后，我的下一步是简单地写入磁盘。
浏览 13提问于2017-07-07得票数 1
回答已采纳
我有以下使用xpath拆分xml的camel配置。
from("direct:[nameofthetemplate]")
.split(xpath(xPath))
.end();
我需要获取从split返回的项，并将它们存储在数组中list.How，我能做到吗？
浏览 5提问于2016-09-30得票数 0
从使用camel的春季引导中，我想知道是否有可能在骆驼路线完成后(在我的示例中的最后一条路径)获得来自骆驼路由的响应。它开始像这样使用ProducerTemplate：
@Component
public class CamelSender {
@Produce(uri = "direct:start")
private ProducerTemplate template;
public void callRoute(List<String> list) throws ExecutionException, InterruptedException {
浏览 2提问于2016-09-15得票数 0
回答已采纳
2回答
我正在编写一个工具来解析一些非常大的文件，并且我正在使用Camel实现它。我以前用过骆驼做其他的东西，而且它对我很有好处。
我正在对在streaming模式下处理文件的概念做一个初步的证明，因为如果我试图运行一个没有它的文件太大，我就会得到一个java.lang.OutOfMemoryError。
以下是我的路由配置：
@Override
public void configure() throws Exception {
from("file:" + from)
.split(body().tokenize("\n")).str
浏览 7提问于2015-12-08得票数 0
回答已采纳
1回答
我在MongoDB中收集了一些文档，比如：
{_id : "...", ip : "0.1.10.200", item : "..."}
ip是IP v4地址。我需要按IP对此数据进行分组。另外，我需要将ip分成4个部分，并添加额外的字段，以从文档结果，如：
{
"ip" : "0.1.10.200",
"ip_part1" : "0",
"ip_part2" : "1",
"ip_part3" : &#
浏览 13提问于2016-09-06得票数 0
我面临着一个复杂的案子。我所做的是以下步骤：
1) <from uri="jetty:http://0.0.0.0:30100/jetty/test"/>
2) <to uri="hazelcast-client:master-test-series" />
3) <to uri="bean:modelSeriesWrapperTest" />
4)
${body}
5)从另一条路线
真<骆驼:到uri="file:src/data/catask/output?fileName=outp
浏览 1提问于2015-01-08得票数 0
3回答
我有一个text："The camel is big"，然后我查找字母"e"，然后我想将接下来的两个字母存储在字符串变量中，所以"The camel is big"将得到值"l"，next2将存储空间" "；但是编译器会抛出一个异常，说明索引超出了数组的范围。以下是代码：
for (int i = 0; i < text.Length; i++)
{
if (text[i]=='e' || text[i]=='E')
{
next1 = text
浏览 6提问于2013-02-06得票数 1
根据一些头部，在camel中使用不同的聚合策略的正确方法是什么？下面的方法可以吗?或者有没有其他更干净的方法来做到这一点？
from("direct:start")
.choice()
.when(header("foo").equalTo("bar"))
.aggregate(header("id"), new BodyInAggregatingStrategy()).completionTimeout(3000).endChoice()
.when(header(&
浏览 3提问于2014-12-16得票数 0
在我的驼峰路线中，我必须使用。这意味着我首先必须拆分交换(在db的大结果集上)，然后我必须聚合它。
我使用解耦的seda队列看到的问题是如何检测工作是否完成(路由是手动触发的，并将运行几个小时)。我必须回调到基础设施，告诉他们工作已经完成。
使用"splitter only“变体不是一个好的选择，因为我会丢失aggreagator-correlated logic(相关的交换必须是有序的)。但最大的问题是失去了completionSize。我不能聚合成多个组。
下面是该模式的一个示例：
from("direct:start")
.split().body()
浏览 0提问于2015-10-14得票数 0
2回答
并行数据处理的聚合结果
、、、、
我希望使用ServiceMix / ActiveMQ / Camel集群并行处理数据。我似乎可以通过首先分割数据，然后通过多个JMS消息和代理的ActiveMQ网络来分发它。
但是，让它变得困难的部分是，我最终需要聚合来自所有节点的所有结果。我现在不知道该怎么做。所有结果最终都必须在一个节点上结束。
所以整个流程如下所示：(1)检索数据。(2)将其分割成可管理的块。(3)通过ActiveMQ集群将大块数据发送到分布式JMS队列。(4)对所有节点进行数据处理。
现在我不知道该怎么处理：
(5)将来自所有节点的已处理数据进行聚合(6)最后处理步骤和聚合结果。
浏览 0提问于2013-03-18得票数 0
在MongoDB中，我有一个包含带有时间戳的文档的集合。我还对一些文档(按两个字段过滤)有一个视图，这些文档是聚合的(按用户和月份分组)。该视图定义了一个复合索引:它由userId和monthOfYear (带有月份YYYY-MM的字符串)组成。该视图另外仅定义了两个字段:这两个字段都是原始集合中某些字段的总和。
接下来，我尝试在视图上运行查询，以获取特定userId的视图的最后13个条目。
即使在没有写入数据库的情况下(原始集合中50k文档的写入时间为300ms)，该查询的运行速度似乎也相当慢。
我不知道我应该创建什么样的索引来支持我的查询。如何对其进行优化？
视图定义如下：
{
浏览 2提问于2020-01-17得票数 1
我必须为数组B的每个元素调用一个服务。但是数组A在数组A中，所以我尝试在camel_Context.xml中使用split，如下所示。一旦执行了所有内部拆分数组值，我也需要聚合它们。
<split>
<jsonpath>$.Request.Fruits</jsonpath>
<split>
<jsonpath>$.request.Fruits[index].item</jsonpath>
<to someURI>
</split>
</
浏览 8提问于2016-11-16得票数 4
回答已采纳
我有一个很大的xml文件，我想用Apache Camel Splitter将它拆分成几个单独的小文件。因此，我使用了示例的代码：
<route>
<from uri="file:inbox"/>
<split streaming="true>
<tokenize token="order" xml="true"/>
<to uri="activemq:queue:order"/>
</split>
</route>
我的xml文件看起来是这
浏览 1提问于2014-10-21得票数 1
我是阿帕奇骆驼的新手。我已经将我的应用程序设置为使用基于XML的配置的Apache。我的配置包含具有类似步骤集的多个路由。我试图找出一种方法，将这些不同路线的公共部分或重复部分放置在一个地方，并从路线中引用它们，而不是一次又一次地重复它们？
例如，在我下面的骆驼路线配置中，路线2是重复路线1的几个步骤，那么有没有办法提取路线1和路线2的共同步骤，然后引用从路线1和路线2提取的部分？
<context:property-placeholder location="classpath:quartz.properties" />
<context:componen
浏览 0提问于2014-01-06得票数 0
回答已采纳
我正在努力实现：
从s3目录读取所有文件。
将所有文件复制到s3上的备份目录。
将所有文件内容聚合到一个文件中，并将其复制到s3上的另一个目录。
但是，我坚持第一点，在一次投票中读取所有的文件。
my from router : aws-s3://${camel.bucket.name}?amazonS3Client=#s3Client&prefix=some_path_on_s3&deleteAfterRead=true&delay=100s
for example if, some_path_on_s3 -> has 2 files say
浏览 4提问于2019-07-09得票数 0
回答已采纳
1回答
在出现问题时，事务可以通过预写日志恢复一致性。也就是说，预写日志包含用于修复已变异行的条目的信息。但是B+树索引呢？当然，SQL事务需要输入预写日志。但是当插入发生在B+树上时，会改变B+树的状态。事务如何恢复B+树的状态。如何在事务上下文中实现B+树以保持一致性？
浏览 2提问于2013-11-26得票数 0
回答已采纳
我刚接触过骆驼，我被困在一个似乎很简单的地方。我需要对交换中的2个xml进行解编组，然后将相应的POJO传递给处理器。我在想，如果我可以取消一个xml，将其设置为一个属性作为交换，然后为另一个xml重复相同的属性。最后，在处理器中，我将检索属性并在处理器中执行所需的逻辑。我能够成功地取消xml，并在exchange.in.body中获得最后一个POJO。但是，有人能告诉我，在交换属性中设置解组对象的结果的正确方法是什么吗？我试过了，但它不起作用：
<setProperty propertyName="foo">
<unmarshall
浏览 3提问于2017-10-11得票数 0
回答已采纳
我正在尝试将GET HTTP请求发送到分页终结点。挑战是我不知道之前的页面大小，因此我必须发送一个请求，以获得页码和兴趣，直到结束。我尝试过Camel HTTP，但我不能让它基于第一个(或前一个)响应发送动态请求。我目前正在测试recipientList，通过发送第一个请求并使用简单的method作为处理器来生成HTTP。由于Camel对我来说真的很新，我不确定这是否是这样做的最好方法。
如果有人能在这方面指出一些方向，我将不胜感激。谢谢
浏览 0提问于2020-12-17得票数 0
正如问题所述，我试图在聚合文件系统并将其拆分之后，将它们(在本例中为3)写入文件系统。
我怎么才能在骆驼身上做到这一点？我使用的是2.16.5，因为这是我所关注的项目的骆驼版。
在我看来，这就是我认为应该这样做的代码：
// reads
public class StringRoute extends RouteBuilder {
public void configure() throws Exception {
from("direct:readStrings")
.split(body())
.to
浏览 0提问于2018-05-11得票数 0
回答已采纳
3回答
我想知道Camel是否可以根据交换的内容进行节流。
情况如下:我必须通过soap调用via服务。在发送到该sent服务的参数中有一个customerId。问题是，如果给定的customerId每分钟有超过1个请求，per服务就会发回一个错误。
我想知道是否有可能使用Camel实现每个customerId的节流。因此，不应对所有消息实施节流，而应仅对具有相同customerId的消息实施节流。
让我知道如何实现这一点，或者如果我需要澄清我的问题。
浏览 0提问于2012-09-11得票数 6
回答已采纳
我想知道在Elasticsearch的幕后索引别名究竟是如何工作的？
别名是否有链接到的每个索引的单独数据副本？还是只知道索引名，而不是每个索引中的数据？
如果是这样的话，在使用多个链接索引的别名上执行聚合时，聚合会慢得多吗？
浏览 6提问于2014-04-16得票数 1
回答已采纳
1回答
按日期时间前5分钟的时间间隔平均
、、、、
我很感激有类似的问题，然而，我似乎找不到正确的答案，我的查询。我有一个数据集，我想根据我的时间戳将数据按5分钟的间隔在一列中平均，平均时间从小时开始，例如，前5分钟的平均时间是10:00 ( 09:56-10:00 )。
下面是我的数据集的一个示例：
data <- structure(list(datetime = c("11/07/2013 19:20", "11/07/2013 19:21",
"11/07/2013 19:22", "11/07/2013 19:23", "11/07/2013 19:24&
浏览 1提问于2014-01-08得票数 1
回答已采纳
我有这样一个列，它应该根据第一个"-"，例如下面的
MGESAD :
"6095 - NCAM - US - GIUTCB - US Consumer Bank - USRB"
"6595 - NBAM - US - UDAS - Consumer Bank - USRB"
"0595 - NWWAM - US - GWCB - US BANK Bank - USRB - TBL"
I need to split this column into:
Col1 Col2
6095 NCAM - US - GIUTCB - U
浏览 2提问于2021-11-16得票数 0
回答已采纳
1回答
我在输入文件夹中有一堆相关的PDF和XML文件：
1.PDF - 1.XML
2.PDF - 2.XML
3.PDF - 3.XML
etc.
PDF文件是扫描的文档，相关的XML文件包含与PDF文件相关的索引信息。
我使用Apache来轮询XML和PDF文件的文件夹，一旦有了发布对，我就会将它们发布到输出文件夹中。理想情况下，我希望最后发布XML文件。
下面的代码似乎正确地选择了这对代码，但是当我再次尝试拆分文件时，我会收到一条错误消息。
@Grab('org.apache.camel:camel-core:2.13.0')
@Grab('org.slf4j:slf4
浏览 6提问于2014-10-20得票数 1
我在一个项目中工作，我们需要解析一个大小大于2 2GB的文件，并将数据加载到DB中。我计划使用Camel拆分器将文件拆分成50个不同的文件，然后使用Apache camel处理每个文件。
我的问题是：
如果在处理其中一个文件时，camel路由失败，那么我如何停止camel路由并使用文件名在DB中对其进行审计。可能会发生这样的情况:一些记录被处理并上载到数据库，而对于特定的记录，它无法加载到数据库中。因此，我们需要将此特定记录记录到其他文件中。
此外，在处理过程中，如果由于网络故障而停止支持数据库操作，则在这种情况下，文件处理将不完整。那么如何处理这种不完整的文件处理场景，因为只有剩余的记录应该
浏览 4提问于2014-12-05得票数 0
1回答
我有一个table_A (C1，C2，C3，.....，Cn，datestamp)
注意:列日期戳已编入索引
QRY1
select * from
(select max(datestamp) dates from table_A) t,
table_A
where a.datestamp = t.dates
QRY2
select * from (
select a.* , max (datestamp) over() dates from table_A a))
where datestamp = dates
使用索引扫描解释QRY1的Paln (在1秒内执行)成本非常
浏览 0提问于2013-04-10得票数 1
回答已采纳
2回答
我是Camel的新手，不知道如何使用Camel实现下面提到的用例。
我们有一个REST web服务，假设它有两个服务操作callA和callB。现在，我们在前面有了ESB层，它在访问这个实际的web服务URL之前拦截客户端请求。
现在，我正在尝试这样做-在ESB中公开一个客户端将实际调用的URL。在ESB中，我们使用Camel的Jetty组件，它只代理这个服务调用。因此，假设此URL为/my-service/scan/
现在，在收到这个请求@ESB时，我想调用这两个REST端点(callA和callB)并获得它们的响应- resA和resB ->将其聚合为一个响应对象resScan -&
浏览 1提问于2012-05-16得票数 8
回答已采纳
我得到了一个大约有300.000个条目的数据集。为了存储这些数据，我使用的是当前版本的mongodb 2.2.3。我的问题是如何通过使用聚合框架来提高搜索性能？
这是我存储的数据的一个示例：
{
"_id":"654311649875645643131564",
"@type":"K",
"dataSourceA":{
"name": "abc",
"price": 12.99
},
"d
浏览 2提问于2013-03-14得票数 2
回答已采纳
4回答
我正在编写一个shell脚本，并且有一个类似下面这样的变量：something-that-is-hyphenated。
我需要在脚本中的不同位置使用它，如下所示：
something-that-is-hyphenated、somethingthatishyphenated、SomethingThatIsHyphenated
我已经设法将其更改为somethingthatishyphenated，方法是使用sed "s/-//g"剥离-。
我相信有一个更简单的方法，而且还需要知道如何获得驼峰大小写的版本。
编辑:从@Michał的答案派生的工作函数
function hyphen
浏览 2提问于2011-08-07得票数 6
回答已采纳
是否可以使用apache camel解决以下情况：
从ftp读取(定期)检索包含xml的zip文件，将此xml存储在数据库中。
主要的问题是camel中存在哪些功能，以及哪些功能和需要我自己编写？
浏览 0提问于2011-05-22得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
云直播
对象存储活动推荐
腾讯云开发者
