Apache Nifi - 1つのフローで複数のテーブルからデータを読み取る

Question

データ摂取の使用例としてApache Nifiを使用する予定です。ソースはフラットファイルでTeradataデータベース、出力シンクはOracleデータベースとなります。私は、GetFileとExecuteSQLを使用してTeradataデータベースを使用してフラットファイルからデータを読み取るフローを作成し、PutSQLを使用してOracleデータベースにデータをロードしました。すべてが正常に動作しているようです。そして私たちは将来、ソースシステムが変わるかもしれないと予測しています。そして、そのソースをサポートするためにプロセッサーがNifiで利用可能であることに気付きました。

Teradataデータベースから複数のテーブルを読み込んで、1つのNifiフローでOracleデータベースの複数のテーブルにデータを読み込むことは可能ですか？私は各テーブルのための個々のフローを構築し、それは正常に動作しているようです。

Answer 1

あなたはどのバージョンのNifiを使用していますか？各テーブルにExecuteSQLを使用していて、最新のバージョンのNiFi（1.0.0以降）を使用している場合は、ReplaceTextを使用して、そのテーブルの行を取得するSQL文を作成します（NiFi Expression Languageを使用）。これをExecuteSQLに送信してフェッチを行い、下流のプロセッサを使用して行をOracle表に置く必要があります。