【问题标题】:Mule: How to track non-deletable & non-movable filesMule:如何跟踪不可删除和不可移动的文件
【发布时间】:2014-08-10 06:35:17
【问题描述】:

我有一个目录,其中包含无法删除的文件,因为它们被其他应用程序使用或具有只读属性。这意味着我不能像 Mule 作为自然文件跟踪系统那样移动或删除文件。为了在它们到达或更新时通过 Mule 处理这些文件而不从原始目录中删除/移动它们,我需要某种自定义跟踪。为此,我认为我需要添加一些规则并能够跟踪以下文件:

  • 新文件
  • 已处理的文件
  • 更新文件

为此,我想在同一目录中创建一个日志文件,该文件将按名称和修改日期跟踪每个文件,但我不确定这是否是正确的做法。我需要能够写入和读取此日志文件并将其内容与目录中的当前文件进行比较,以确定哪些文件是新的或更新的。这似乎有点太复杂了,需要我添加相当多的编程(可能是 groovy 脚本或覆盖某些方法)。

在 Mule 上还有其他更简单的方法吗?如果没有,我应该如何开始解决这个问题?我猜我可以编写一些 java 来与 File EndPoint 对话。

【问题讨论】:

  • 你想对不可删除的文件做什么?只处理一次?当它们发生变化时处理它们?
  • 我希望在它们到达目录并更新它们后对其进行处理。
  • 考虑禁用自动删除并移动到,然后使用具有返回文件名和上次更新组合的 id 表达式的幂等过滤器。
  • 维克多,谢谢!幂等过滤器实际上对我有用,但是我正在尝试使用简单文本文件存储在文件中保存已处理文件的状态。只要我不重置骡子进程,这就会起作用。如果我重新启动该过程,它会忽略文件的内容并再次重新处理每个文件。我错过了什么?

标签: java file version-control mule mule-studio


【解决方案1】:

正如 Victor Romero 指出的那样,幂等过滤器可以解决问题。我尝试了两种类型的幂等过滤器,看看哪一种效果最好:Idempotent Message Filter 和Idempotent Secure Hash Message Filter。他们俩都完成了这项工作,但是我最终使用幂等消息过滤器(无哈希)在 simple-text-file-store 中记录时间戳和文件名。

就在文件入站端点之后:

<idempotent-message-filter idExpression="#[message.inboundProperties.originalFilename+'-'+message.inboundProperties.timestamp]" storePrefix="prefix" doc:name="Idempotent Message">
    <simple-text-file-store name="uniqueProcessedMessages" directory="C:\yourDirectory"/>
</idempotent-message-filter>

只有用于我的流程的新文件或修改过的文件才能通过。但是,幂等安全哈希消息过滤器在识别不同文件方面应该做得更好。

【讨论】:

    猜你喜欢
    • 2016-02-14
    • 2020-11-18
    • 1970-01-01
    • 2011-11-27
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2016-05-23
    相关资源
    最近更新 更多