如何从 updateAttribute 中的属性的文件中动态读取值

Question

我使用"+"按钮在"updateAttribute"处理器中添加了一些自定义属性。例如：我声明了一个属性"DBConnectionURL"，并将值命名为"jdbc：mysql：//localhost：3306/test"。然后，在"DBCPConnectionPool"服务控制器中，我简单地将值"${DBConnectionURL}"用于"数据库连接URL"属性。但是，我手动给出了"DBConnectionURL"属性的值。我想要一种可以从文件动态馈送值的方法，这样我只需要更改文件中的值，"DBConnectionURL"的值就会根据文件中存在的值动态更改。有没有办法做到这一点？

Answer 1

Rishab，

你必须使用nifi变量注册表。

在 conf/nifi.properties 中，可以在其中配置以下配置，以动态更新数据流中的值。

nifi.variable.registry.properties=./dynamic.properties

你可以给你的变量 dynamic.properties 它应该出现在 conf 目录中。

例如，如果动态属性文件包含以下值

DBCPURL= jdbc://<host>:<port>

可以使用 ${DBCPURL} 在数据流中使用它

注意：如果在 conf/nifi.properties 中更改任何配置，则应重新启动 nifi 服务。否则，您的更改在数据流中不起作用。

如果它对您有用，请随时接受它。