读取处理器中的自定义属性

Question

我正在尝试在 Apache Nifi 中创建一个自定义处理器（使用 Java）来读取用户的自定义属性。是否可以创建一个处理器来提取用户键值对？如果是这样，我应该如何提取它们？

用户自定义属性是否存储在某些 nifi.processor.* 库的字典中？

请参考下图：

理想情况下，我想提取上述所有输入的属性和值的动态值。IE。{“自定义属性 1”：“某个值”，“自定义属性 2”：“另一个值”，“自定义属性 3”：“第三个值”}

Answer 1

像所有属性一样，用户定义的属性在 ProcessContext 中可用，但它们有一个标记为 be dynamic。以下是用于迭代用户定义属性的代码片段：

context.getProperties().keySet().stream().filter(PropertyDescriptor::isDynamic).forEach()

forEach()使用处理属性的逻辑填写 lambda 。