Apache Camel :我有一个下载文件名中包含Id的文件集的用例。我使用pollenrich来获得文件计数，使用antInclude和正则表达式，并迭代一个循环来下载每个文件。
浏览 7提问于2018-07-10得票数 0
我遇到的问题是Camel轮询一批文件，但随后较新的文件被写入目录，因此在随后的轮询中，新文件在前一批文件完成之前被处理。我向我的路由添加了一些属性，以显示批处理大小以及它是否已完成，只是为了提供一些信息：
<camel:log message="Camel batch size: $simple{property.CamelBatchSize}, Camel Batch Index: $simple{property.
浏览 4提问于2018-05-10得票数 0
我正在评估Camel在两个解耦的系统之间创建集成。我需要Camel定期轮询web服务以获取项目列表，对收到的项目进行一些转换，然后使用不同的传输将其发送到第二个系统。Querying WS"/> </route>
其中itemRetriever是我之前设置的bean，它实现了org.apache.came
浏览 0提问于2013-07-07得票数 1
回答已采纳
我需要从目录中轮询文件，并将交换发送到seda hazelcast队列(处理集群中的交换)。首先用于轮询文件： .to("hazelcast:seda:queue?hazelcastInstance=#hazelcast-instance");from("hazelcast:seda:queue?: Message body
浏览 1提问于2017-02-20得票数 1
回答已采纳
我有骆驼路线 <route startupOrder="1"></route>
它不断地轮询目录。
如果此作业被触发一次，我希望停止轮询。
浏览 0提问于2017-04-14得票数 1
1回答
我对Apache camel非常陌生，我正在探索如何创建一个rout，它每隔15分钟从ftp中提取数据，并且只提取新的或更新的文件，因此，如果一些文件被提前下载，并且仍然是相同的(不变) ftp加载器不应该将它们加载到目标文件夹中另外，我观察到，一旦一些文件被下载到目标文件夹，我的意思是从ftp到本地文件系统，这些文件将在随后的数据加载中被忽略，即使这些文件在本地文件系统上被删除，我如何告诉camel下载再次删除的文件，它如何存储有关已经加载的文件的信息是否需要编写筛选器以排除已下载的文件？
浏览 4提问于2011-04-16得票数 3
回答已采纳
1回答
但是，正如我所理解的，这将影响我的应用程序的性能，因为在每次模式处理之前都会拦截路由。是否有办法在camel中进行拦截以并行处理？是我考虑在apache中使用WireTap模式的另一种方式，但我不能在上下文级别上定义它，所以在编写每一条路由时，我需要显式地编写WireTap pattern.This，这有点过于繁忙，因为我试图降低编写只需要编写路由的开发人员的复杂性
浏览 5提问于2022-01-13得票数 0
我刚接触Apache Camel，正在计划在Grails应用程序中实现一个文件轮询器，该应用程序将部署在由两个节点组成的Jboss集群中。
我计划使用Grails路由插件来包含Camel。问题是，由于这是一个集群环境，我们将有两个Camel上下文，对吗(每个节点一个)？如果是这样的话，两者将具有相同的路由。当源文件夹中存在文件时，两个camel上下文是否都会尝试处理该文件？我不希望出现两个节点都试图处理文件并导致失败的情况。我只想让文件只由一个
浏览 2提问于2012-11-05得票数 2
1回答
我正在处理一个项目，在这个项目中，我必须每隔30秒调用一次SOAP服务并检索一些信息。到目前为止，我一直在使用Camel "timer“组件进行轮询，然后调用执行SOAP调用的bean。我想知道在Apache Camel中是否有更好的方法来进行频繁的SOAP调用。
感谢您的意见。
浏览 2提问于2013-11-21得票数 1
我写了一条骆驼路线，它轮询一个文件夹并发送给Azure Blob容器我在倒车。我使用的不是消费者，而是Azure Blob制片人。这是我的路线。**java.lang.IllegalArgumentException: Unsupported blob type:org.apache.camel.component.file.GenericFile:474) ~[camel-azure-2.19.2.jar:2.19.2]
at org.apache.<e
浏览 3提问于2017-09-26得票数 0
回答已采纳
下面是一个简化的ftp轮询机制。<camelContext id="Fetcher" xmlns="http://camel.apache.org/schema/blueprint">
<camel:from uri="ftp://10.20
浏览 4提问于2019-11-14得票数 0
2回答
我的目标是处理Kafka断开连接的问题。但是，在日志中看不到异常，并且不会调用onException处理。你知道我做错了什么吗？
类似的问题可以通过在本地运行而不运行任何Kafka服务器来重现。
浏览 2提问于2017-11-14得票数 2
我使用轮询策略，此策略中的rollback方法在连接超时时被调用。但是rollback方法不允许我访问RouteID以将其记录到数据库中。由于某种原因，我发现了标志consumer.bridgeErrorHandler，它可以设置为true，以便将异常传递给默认的错误处理程序。但这只是记录了错误，并没有解决如何获取路由详细信息的问题。我使用的是apache camel 2.13.4
浏览 3提问于2016-04-29得票数 0
我有这样的FTP轮询路径
from("sftp://sftpUsername@ftpServer/path/to/folder?我能够将处理过的文件移动到/path/ to /文件夹内的子文件夹中。但是，当我试图将它移动到另一个文件夹位置时。我要破例了。不幸的是，例外没有详细说明。调试org.apache.camel.component.file.GenericFileOnCompletion -完成处理文件:Rem
浏览 2提问于2017-07-11得票数 0
回答已采纳
1回答
Camel设置具有属性计数，我将其设置为10，并期望在一次民意调查中获得10新的tweet，但问题是，模板在每个骆驼请求中只提供一个tweet：
for (int i = 0; i < 15; i++)
浏览 7提问于2022-06-23得票数 1
回答已采纳
1回答
我们不希望在文件系统之上构建一个层来轮询和触发该文件的相应进程，因为文件系统没有提供事务、隔离等好处。这听起来像是一件好事吗，或者有没有更好的处理文件系统的模式？
浏览 0提问于2013-01-29得票数 2
我编写了一个camel路由，它轮询一个文件文件夹，获取请求，检查服务器上的内存消耗(在java文件中)。如果它低于阈值，它就会将请求丢弃在JMS队列上，否则它会抛出一个异常并再次选择它进行处理。我需要做的是，当抛出异常时，我需要将处理延迟一段可配置的时间，比如15分钟。这将给服务器一些时间来稳定，而不是不必要地保持轮询。我正在使用骆驼的errorHandler机制，但它似乎不起作用。下面是包上下文快照：
浏览 0提问于2015-05-11得票数 0
回答已采纳
然后，我需要更改该静态模型，以便在其上使用不同的处理函数。该函数可以是一些java类、web服务或外部应用(其支持批处理模式)。之后，我需要捕获这些函数的输出，并进行一些可视化，绘制一些图表等。我可以假设所有这些处理函数都可以访问静态模型，它们可以将其更改为特定的模型，因此不需要将输入传递给它们。另一方面，它们的输出应该被主要的“工作流管理器”捕获。在进程开始之前，管理员应该定义使用哪个“处理函数”，仅此而已。还有一件事。最好是当数据库状态改变时触发整个过程，但这并不重要，我可以通过调用web服务来启动它。
浏览 0提问于2012-08-07得票数 4
回答已采纳
Apache Camel是否支持Spring Batch？我是我的一批使用骆驼路线。现在我们想迁移到Spring batch，但不确定我的驼峰路由是否可以与Spring Batch集成。
浏览 3提问于2012-05-19得票数 2
回答已采纳
4回答
骆驼文件处理
、、、、
我使用Camel (2.11.0)来尝试实现以下功能：
<camelContext id="my-camel-context" xmlns="http://
浏览 3提问于2014-01-21得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
实时音视频活动推荐
腾讯云开发者
