我正在尝试使用配置文件自定义 kylo 中可用的标准数据摄取模板。我在 kylo-services/conf 目录中的 application.properties 文件中添加了字段名称 nifi.getfile.business_line1=Test 。当我尝试在处理器 ${business_line1} 中使用 nifi 表达式时，它会抛出 business_line1 未找到。
或者有没有其他方法可以自定义标准数据摄取？
谁能给这个解决办法...
问问题
607 次
1 回答
3
使用您的示例，Kylo 将在创建提要时查找所有 GetFile 处理器，并将“business_line1”属性替换为“Test”值。但是，GetFile 处理器不允许自定义属性，您将收到类似于以下内容的错误消息：
针对“Test”验证的“business_line1”无效，因为“business_line1”不是受支持的属性
有几种方法可以解决这个问题：
如果你想使用 NiFi 表达式，那么你需要创建一个 UpdateAttribute 处理器并在那里添加“business_line1”属性。任何后续处理器都可以访问该值
${business_line1}如果您希望所有 GetFile 处理器具有相同的属性值，您可以在 Kylo 的 application.properties 中设置以下属性：
nifi.getfile.file_filter=Test
Kylo 文档更详细地介绍了如何使用变量替换： http: //kylo.readthedocs.io/en/latest/how-to-guides/ConfigurationProperties.html
在 NiFi 中，您可以使用 NiFi 表达式语言访问流文件属性： https ://nifi.apache.org/docs/nifi-docs/html/expression-language-guide.html
于 2017-08-16T16:47:29.330 回答