2017-03-02 63 views
1

我打算將Apache Nifi用於數據提取用例。來源可能是平面文件和Teradata數據庫,並且輸出接收器將是Oracle數據庫。我創建了幾個流程,使用GetFile和Teradata數據庫使用ExecuteSQL從平面文件中讀取數據,並使用PutSQL將數據加載到Oracle數據庫。一切似乎都工作正常。我們預測未來的源系統可能會發生變化,我注意到Nifi提供的處理器可以支持這些來源。Apache Nifi - 從單個流中的多個表中讀取數據

現在我的問題是,是否有可能從Teradata數據庫讀取多個表,並將數據加載到單個Nifi流中的oracle數據庫中的多個表中?我已經爲每個表建立了單獨的流程,它似乎工作正常。

回答

3

您使用的是什麼版本的Nifi?如果您爲每個表使用ExecuteSQL,並且最近版本的NiFi(1.0.0和更高版本)可以使用ListDatabaseTables處理器,然後ReplaceText創建SQL語句以獲取該表的行(使用NiFi Expression Language),然後將它發送給ExecuteSQL來執行讀取操作,無論下游處理器如何,都必須將這些行放到Oracle表中。

相關問題