Выполнить один запрос на нескольких схемах - NiFi

Question

Я использую execute sql для выполнения запроса на MySql. Прямо сейчас мне нужно указать имя схемы, где бы я ни использовал имя таблицы.

Можно ли каким-либо образом настроить имя схемы и выполнить запрос по любому желаемому имени схемы, которое я выберу?

Answer 1

Если вы используете NiFi-1.7 , то вы можете динамически выбирать пулы соединений DBCP.

См. NiFi-5229 Джира, посвященная этому улучшению.

Если вы следуете этим путем, вам необходимо define connection pools перед их использованием, а затем с помощью одного ExecuteSQL процессора, мы собираемся выбрать пулы соединений динамически на основе атрибута.

Если вы используете предыдущие версии NiFi-1.7, то, к сожалению, нам нужно указать имя схемы для каждого запроса .