使用 Apache NiFi 中的 csv 值查询数据库 Table
Query Database Table with the values of csv in Apache NiFi
我有一个这样的 csv 文件
col1,col2,col3
_______________
d1c1,d1c2,d1c3
d2c1,d2c2,d2c3
d3c1,d3c2,d3c3
我有一个数据库 table table1 具有以下架构
col1,col4,col5
______________
d1c1,d4c2,d4c3
d2c1,d5c2,d5c3
d4c1,d6c2,d6c3
现在，我想用 col1 的 csv 值查询数据库 table1。反正有没有在nifi中做到这一点？
我可以通过 QueryRecord 处理器从 csv 中提取 col1，但无法将其路由到任何数据库查询处理器。
以下流程对我有用。
QueryRecord: 用于查询csv文件（Select col1 from FLOWFILE"），记录分隔符不要使用"\n"，使用", ".
ExtractText 用于为值分配变量（col.0）。
ExecuteSQL 用于执行特定的 sql 查询“Select * from table1 where col1 in (${col.0})”
我有一个这样的 csv 文件
col1,col2,col3
_______________
d1c1,d1c2,d1c3
d2c1,d2c2,d2c3
d3c1,d3c2,d3c3
我有一个数据库 table table1 具有以下架构
col1,col4,col5
______________
d1c1,d4c2,d4c3
d2c1,d5c2,d5c3
d4c1,d6c2,d6c3
现在，我想用 col1 的 csv 值查询数据库 table1。反正有没有在nifi中做到这一点？
我可以通过 QueryRecord 处理器从 csv 中提取 col1，但无法将其路由到任何数据库查询处理器。
以下流程对我有用。
QueryRecord: 用于查询csv文件（Select col1 from FLOWFILE"），记录分隔符不要使用"\n"，使用", ".
ExtractText 用于为值分配变量（col.0）。
ExecuteSQL 用于执行特定的 sql 查询“Select * from table1 where col1 in (${col.0})”