属性文件查找增强 Apache NiFi 1.7.x 中的数据流

属性文件查找增强 Apache NiFi 1.7.x 中的数据流

一位非常酷的技师与我联系, 问了一个有趣的问题:

蒂姆

“如何从属性文件中读取值并在流中使用它们。我要更新/插入具有此值的属性。

如果不想使用变量注册表, 但希望从属性文件中插入一个值如何执行该操作。您可以运行一些 REST 服务器, 阅读它或做一些文件读取黑客。但我们有一个伟大的服务, 这样做很容易!

在我的 UpdateAttribute (或者在您的常规属性中), 我有一个名为keytofind的属性。它包含一个查找键, 如整数或字符串键。我们将在属性值中找到该值, 并在您选择的属性中给出它。

我们有一个控制器服务来为您处理此事。它从指定的属性文件中读取。确保 Apache NiFi 具有该路径的权限并可以读取该文件。

我们查找 “keytofind” 中指定的键。它返回一个您指定为额外属性的值, 我的是 “updatedvalue”。

这是我的属性文件:

-rwxrwxrwx  1 tspann  staff  67 Oct  4 09:15 lookup.properties

stuff1=value1
stuff2=value2
stuff3=value other
tim=spann
nifi=cool

在本例中, 我们使用的是LookupAttribute处理器。您也可以根据需要使用LookupRecord处理器。