java - 如何使一个流程文件成为单独的预先存在的流程文件的子文件?

标签 java groovy apache-nifi amqp

当一个流文件从外部源产生,但知道它来自的前一个流文件的 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/

相关文章:

java - 使用进度条的问题

java - mkp.yieldUnescaped 不起作用

apache-nifi - kylo 摄入饲料错误

java - 运行项目后出现异常java.lang.UnsatisfiedLinkError

java - 带有每个选项卡菜单的操作栏

java - 如何将 map 存储在 Guava 缓存中

java - 在 grails url 映射中使用目录

java - Gradle,在 build.gradle 脚本中创建对象

csv - 如何使用 nifi 更新 csv 上特定字段的值?

apache-nifi - Apache NiFi无法连接到 "localhost:8080/nifi"