3

我正在尝试从 csv 文件中读取值，然后使用 ExtractText 处理器将值存储到属性中。该文件仅包含一行，其中有 5 个以逗号分隔的值。这是我的文件的内容：

jdbc:mysql://localhost:3306/test, com.mysql.jdbc.Driver, C:\ProgramFiles\MySQL\mysql-connector.jar, root, root

我在 ExtractText 处理器中手动添加了 5 个属性：-

DatabaseConnectionURL
DatabaseDriverClass
DatabaseDriverLocation
DatabaseUser
Password

现在，我想要我在 ExtractText 处理器中定义的上述 5 个属性的正则表达式，以便它们获得以下值：-

DatabaseConnectionURL = jdbc:mysql://localhost:3306/test
DatabaseDriverClass = com.mysql.jdbc.Driver
DatabaseDriverLocation = C:\Program Files\MySQL\mysql-connector.jar
DatabaseUser = root
Password = root

你能给我上面5个属性的正则表达式吗？

4

1 回答 1

4

里沙布，

ExtractText 处理器使用以下正则表达式来捕获行。

ExtractedData:(^.*$)

然后使用 updateAttribute 和getDelimitedField()如下所示的表达式为流文件属性分配值。

DatabaseConnectionURL:${ExtractedData:getDelimitedField(1)}

DatabaseDriverClass:${ExtractedData:getDelimitedField(2)}

DatabaseDriverLocation:${ExtractedData:getDelimitedField(3)}

DatabaseUser:${ExtractedData:getDelimitedField(4)}

Password:${ExtractedData:getDelimitedField(5)}

getDelimitedField()“将主题解析为分隔的文本行，并从该分隔文本中返回一个字段。” 并且可以用于任何支持 NiFi 表达式语言的配置属性。有关详细getDelimitedField()说明，请查看 NiFi 表达式语言指南。

https://nifi.apache.org/docs/nifi-docs/html/expression-language-guide.html#getdelimitedfield

希望此解决方案有助于解决您的问题。

不要忘记接受它是否有效，如果您遇到任何问题，请告诉我。

于 2018-04-09T10:49:10.547 回答