2017-05-09 61 views

回答

4

如果Vertica的和紅移已經「乖」 JDBC驅動器,則可以設置爲每一個DBCPConnectionPool,則SQL處理器如ExecuteSQLQueryDatabaseTable,或者GenerateTableFetch(後者用於使用生成的ExecuteSQL SQL) 。這些會將您的記錄轉換爲Avro格式,然後(在NiFi 1.2.0之前),您可以使用ConvertAvroToJSONConvertJSONToSQLPutSQL將您的記錄插入到Redshift中。

在NiFi 1.2.0中,您可以使用在PutDatabaseRecord中設置AvroReader。然後您只需要SQL處理器就可以將記錄從Vertica中取出,直接放到PutDatabaseRecord中,將它們放入Redshift中。

+0

有沒有人試過這個呢?如果我們想要插入百萬行,PutSQL是否可以生成10000行批量插入? – halil

+0

答案中的鏈接是死的 - 信息可以在這裏找到:https://nifi.apache.org/docs.html – shakedzy

相關問題