如何从文件中动态读取 updateAttribute 中 属性 的值?
How to read values dynamically from a file for a property in updateAttribute?
我使用“+”按钮在 'updateAttribute' 处理器中添加了一些自定义属性。例如:我声明了一个 属性 'DBConnectionURL' 并给出了 'jdbc:mysql://localhost:3306/test' 的值。然后,在 'DBCPConnectionPool' 服务控制器中,我简单地使用了 'Database Connection URL' 属性 的值'${DBConnectionURL}'。但是,我手动给出了 'DBConnectionURL' 的值 property.I 想要一种可以从文件中动态提供值的方法,这样我只需要更改文件中的值和 'DBConnectionURL' 根据文件中存在的值动态变化。有办法吗?
里沙布,
你必须使用 nifi 变量注册表。
在 conf/nifi.properties 中,您可以在其中配置以下配置以动态更新数据流中的值。
nifi.variable.registry.properties=./dynamic.properties
您可以在该文件中提供您的变量 dynamic.properties 它应该出现在 conf 目录中。
例如,如果 dynamic.properties 个文件包含以下值
DBCPURL= jdbc://<host>:<port>
您可以通过 ${DBCPURL}
在数据流中使用它
注意:如果您在conf/nifi中更改任何配置,您应该重新启动nifi服务。properties.Otherwise您的更改在数据流中不起作用。
如果对您有用,请随时接受它作为答案。
我使用“+”按钮在 'updateAttribute' 处理器中添加了一些自定义属性。例如:我声明了一个 属性 'DBConnectionURL' 并给出了 'jdbc:mysql://localhost:3306/test' 的值。然后,在 'DBCPConnectionPool' 服务控制器中,我简单地使用了 'Database Connection URL' 属性 的值'${DBConnectionURL}'。但是,我手动给出了 'DBConnectionURL' 的值 property.I 想要一种可以从文件中动态提供值的方法,这样我只需要更改文件中的值和 'DBConnectionURL' 根据文件中存在的值动态变化。有办法吗?
里沙布,
你必须使用 nifi 变量注册表。
在 conf/nifi.properties 中,您可以在其中配置以下配置以动态更新数据流中的值。
nifi.variable.registry.properties=./dynamic.properties
您可以在该文件中提供您的变量 dynamic.properties 它应该出现在 conf 目录中。
例如,如果 dynamic.properties 个文件包含以下值
DBCPURL= jdbc://<host>:<port>
您可以通过 ${DBCPURL}
注意:如果您在conf/nifi中更改任何配置,您应该重新启动nifi服务。properties.Otherwise您的更改在数据流中不起作用。
如果对您有用,请随时接受它作为答案。