问在QueryDatabaseTable中在NiFi中执行多重选择*

EN

有几种方法可以用来解决这个问题。

• 如果您的表实际上是table1、table2等，您可以简单地生成80个流文件，每个文件在属性中都有一个唯一的整数值(即table_count)，并使用GenerateTableFetch和ExecuteSQL通过表达式语言使用该属性创建查询。
• 如果表名是非顺序的(如users、addresses等)，则可以从列在一行上的文件中读取，或者使用ListDatabaseTables查询数据库中的名称。然后，您可以执行简单的文本处理，将创建的流文件拆分为每个表一个，并继续如上。

QueryDatabaseTable不允许传入连接，所以它是not possible。

但是，您可以使用以下流程实现相同的用例

流：

1. ListDatabaseTables
2. RouteOnAttribute //*optional* filter only required tables
3. GenerateTableFetch //to generate pages of sql queries and store state
4. RemoteProcessGroup (or) Load balance connection
5. ExecuteSql //run more than one concurrent task if needed
6. further processing
7. PutElasticSearch.

此外，如果您不想运行流incrementally，那么删除GenerateTableFetch处理器

• 配置ExecuteSql处理器，选择查询作为 select * from ${db.table.schema}.${db.table.name}

一些有用的参考资料：

• GenerateTableFetch link1 link2
• 增量运行ExecuteSQL处理器而不使用GenerateTableFetch 链接