PutDatabaseRecord 处理器的 Apache NiFi 动态属性
Apache NiFi dynamic atributes for PutDatabaseRecord Processor
我在 NiFi 中有这个流程：
GetFile -> ConvertExcelToCSVProcessor -> ReplaceText ->
PutDatabaseRecord.
工作正常，但我想设置 "table name" 属性 of
PutDatabaseRecord
基于 csv 文件名（如果可以自定义）。我在文档或网络中找不到任何内容。
谢谢！
根据文档，PutDatabaseRecord processor supports nifi expression language 的参数 table name。
因此，如果流文件的属性 filename 包含值 MyTableName.csv，您可以使用带正则表达式的表达式将文件名转换为 PutDatabaseRecord 处理器中的 table 名称，如下所示：
Table Name = ${filename:replaceAll('\..*','')}
我在 NiFi 中有这个流程：
GetFile -> ConvertExcelToCSVProcessor -> ReplaceText -> PutDatabaseRecord.
工作正常，但我想设置 "table name" 属性 of
PutDatabaseRecord
基于 csv 文件名（如果可以自定义）。我在文档或网络中找不到任何内容。 谢谢！
根据文档，PutDatabaseRecord processor supports nifi expression language 的参数 table name。
因此，如果流文件的属性 filename 包含值 MyTableName.csv，您可以使用带正则表达式的表达式将文件名转换为 PutDatabaseRecord 处理器中的 table 名称，如下所示：
Table Name = ${filename:replaceAll('\..*','')}