当一个流文件从外部源产生,但知道它来自的前一个流文件的 uuid 时,我如何将现有流文件标记为该流文件的父级。
我发现我会遇到这种情况,因此我有意尝试保持问题的通用性,但具体情况是:
流文件通过 AMQP(PublishAMQP 处理器)发送到外部系统,外部系统异步执行工作并在稍后的某个时间点通过 AMQP(ConsumeAMQP 处理器)返返回告。
FlowFile1:处理器 -> AMQP(带有 FF1 uuid)
FlowFile2:AMQP(带有 FF1 uuid)-> 处理器
由于响应具有原始流文件的 uuid,我想将此响应与原始流文件关联
我没有看到从 ProcessSession、FlowFile、ProvenanceEventRecord 或我可以通过绑定(bind)或其他方式访问的任何其他内容执行此操作的方法。我的大部分尝试都是通过 ExecuteScript 处理器进行的,我可以在其中访问流文件对象和 nifi dev api。
最佳答案
目前,您只能跟踪从流文件创建到离开 NiFi 的沿袭。一旦它离开 NiFi,那么您就进入了跨系统谱系。
关于java - 如何使一个流程文件成为单独的预先存在的流程文件的子文件?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56546111/