在 kylo 中自定义数据摄取模板

Customize data-ingest template in kylo

我正在尝试使用配置文件自定义 kylo 中可用的标准数据摄取模板。我在 kylo-services/conf 目录中可用的 application.properties 文件中添加了字段名称 nifi.getfile.business_line1=Test。当我尝试在处理器 ${business_line1} 中使用 nifi 表达式时，它会抛出 business_line1 not found.

或者有没有其他方法可以自定义标准数据摄取？

谁能解决这个问题...

使用您的示例，Kylo 将在创建提要时查找所有 GetFile 处理器，并将 'business_line1' 属性替换为值 'Test'。但是 GetFile 处理器不允许自定义属性，您将收到类似于以下内容的错误消息：

'business_line1' validated against 'Test' is invalid because 'business_line1' is not a supported property

有几种方法可以解决这个问题：

如果你想使用 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

在 kylo 中自定义数据摄取模板

Customize data-ingest template in kylo

apache-nifi

kylo