当前位置: 首页 > 知识库问答 >
问题:

Camel SFTP按计划按需获取

公良安邦
2023-03-14

我可以在不同的变体中看到类似的问题,但还没有找到一个明确的答案。

    null

这两个函数都应该是幂等的,因为使用轮询机制下载的文件不应该在临时拉取中再次下载,反之亦然。这两种访问方式都应该下载所有尚未下载的可用文件(可能会有不止一个新文件--我在这里看到了一个类似的问题,用于按需获取,但它是针对单个文件的)。

我想避免通过pollEnrich来修改SFTP-我的理解是,每个pollEnrich都将从SFTP请求一个新的文件列表,因此在循环中执行pollEnrich直到检索到所有文件将多次调用SFTP。

我在考虑创建一个路由,该路由将启动/停止单独的路由,以便进行特殊提取,但我不确定这是否允许维护路由之间的幂等行为。

那么,聪明的骆驼大脑在那里,什么是满足这些要求的最优雅的html" target="_blank">方法呢?

共有1个答案

司徒俊雄
2023-03-14

不是一个聪明的骆驼大脑,但根据我的理解,我会尝试一下。

希望,你已经经历过:

http://camel.apache.org/file2.html

“我希望避免通过pollEnrich来重击SFTP--我的理解是,每个pollEnrich都会从SFTP请求一个新的文件列表,所以在循环中执行pollEnrich直到检索到所有文件将多次调用SFTP。”->除非您使用选项disconnect=true,否则连接不会终止,您可以连续使用或生成文件,请检查ftp选项disconnect和DisconnectonBatchComplete。

希望这能有所帮助!

 类似资料:
  • 问题内容: 按计划运行Scrapy使我绕过Twist(ed)。 我以为下面的测试代码可以工作,但是第二次触发蜘蛛时出现错误: 我猜想,作为CrawlerProcess的一部分,Twisted Reactor会在不需要时再次启动,从而导致程序崩溃。有什么办法可以控制吗? 同样在这个阶段,如果有一种自动执行Scrapy Spider的替代方法可以按计划运行,我也很高兴。我试过了,但还是不能让它循环:

  • 我有一个简单的CRUD应用程序,其中包含dropwizard中的后端代码。整个应用程序只包括简单的资源类和crud操作,但涉及一些业务逻辑的情况除外。 我试图将其提取到服务中,而不是将其放入资源类本身。但为此,我的服务需要一个ondemand jdbi连接来访问数据并完成它的工作。 我所有的连接字符串和配置值都在YML文件中。由于这个应用程序将运行在具有不同yml文件的不同服务器上,我不想硬编码y

  • 我可以使用创建演员,并使用查看他们。现在我想通过一些获得一个actor,如果它不存在,我想创建它。大概是这样的: 但是这不起作用,因为总是正确的,而且我得到

  • 根据虚拟内存的概念,要执行某个进程,只需要在主内存中存在一部分过程,这意味着在任何时候只有少数几页才会出现在主内存中。 但是,决定哪些页面需要保存在主存储器中,哪些页面需要保存在辅助存储器中,这很困难,因为不能预先说明某个过程在特定时间需要特定的页面。 因此,为了克服这个问题,有一个叫做按需分页(Demand Paging)的概念被引入。 它建议将所有帧的页面保留在辅助存储器中,直到它们被需要为止

  • 出于性能的考虑,我们会对模块和组件进行按需加载。 按需加载组件 通过 umi/dynamic 接口实现,比如: import dynamic from 'umi/dynamic'; const delay = (timeout) => new Promise(resolve => setTimeout(resolve, timeout)); const App = dynamic({ loa

  • 问题内容: 我有一个用Java编写的控制台程序,该程序可以响应单键按下,但是用户不按Enter。 我正在打乒乓球,所以需要上下键来移动蝙蝠的东西。 欢迎使用其他方法!(除了制作GUI外) -编辑: 我将只在UNIX系统(OSX和Linux)上运行程序,因此我可以通过以下方式将终端置于“原始”模式: 当我在运行程序之前在控制台中键入该命令时,它将起作用!但是我需要Java自动执行此操作,因此我尝试了