apache-nifi - NiFi fetchFile 处理器不允许动态属性

Question

某些 NiFi 处理器不允许动态属性的原因是什么？我在一个工作流程中使用 FetchFile 处理器，我需要在整个流程中传递一些数据才能在最后一步中使用它。然而，FetchFile 不允许动态属性，从而打破了这一点。我想知道是否还有其他方法可以做到这一点？为什么 NiFi 不允许在某些处理器上使用动态属性？

我的流程是这样的

ExecuteScript -> EvaluateJSon -> 用于写入文件的自定义处理器 -> FetchFile->SendtoS3 -> 将工作流程标记为完成

我想发送一些元数据，以便我可以将工作流程标记为完成。我将该数据作为属性传递，但它在 FetchFile 处中断。

Answer 1

有两个独立的概念:处理器上的用户定义属性和流文件属性。

用户定义的属性允许处理器从用户那里获取无法提前定义的内容的输入。此类示例包括在 EvaluateJsonPath 中(当在用户定义的属性中指定 JSON 路径时)或在 PutSolrContentStream 中(当所有用户定义的属性都作为查询参数传递给 Solr 时。

FlowFile 属性是随每条数据传递的键/值对的映射。这些属性通常在处理器生成或修改流文件时创建，或者可以使用 UpdateAttribute 等处理器进行操作。

由每个处理器决定是否需要用户定义的属性以及如何使用它们。 UpdateAttribute 恰好是一个处理器，其中用户定义的属性作为新的键/值对添加到每个流文件中，但对于每个处理器都这样做没有意义。