某些NiFi处理器不允许动态属性的原因是什么?我在其中一个工作流程中使用FetchFile处理器,并且需要在整个流程中传递一些数据才能在最后一步中使用它。但是,FetchFile通过不允许动态属性来破坏它。我想知道是否还有另一种方法?NiFi为什么在某些处理器上不允许动态属性?
我的流程就像
ExecuteScript-> EvaluateJSon->自定义处理器以写入文件-> FetchFile-> SendtoS3->标记工作流程已完成
我想发送一些元数据,以便可以将工作流程标记为完成。我将这些数据作为属性传递,但在FetchFile处断开。
有两个单独的概念,即处理器上的用户定义属性和流文件属性。
用户定义的属性使处理器可以从用户那里获取无法提前定义的输入。例如,在用户定义属性中指定JSON路径时在EvaluateJsonPath中,或者在将所有用户定义属性作为查询参数传递给Solr时在PutSolrContentStream中。
FlowFile属性是键/值对的映射,键/值对随每个数据传递。这些属性通常在处理器生成或修改流文件时创建,或者可以使用诸如UpdateAttribute之类的处理器进行操作。
由每个处理器决定是否需要用户定义的属性以及如何使用它们。UpdateAttribute碰巧是一个处理器,其中用户定义的属性作为新的键/值对添加到每个流文件中,但是并不是每个处理器都这样做。
| 归档时间: |
|
| 查看次数: |
1131 次 |
| 最近记录: |