如何使用DAS從POSTGRESQL數據庫讀取數據？

Question

我們正在研究ETL。如何讀取使用流在數據分析服務器的POSTGRESQL數據的基礎數據和操作使用流的一些操作和操縱數據插入到在預定的時間另一POSTGRESQL數據的基礎上。請分享遵循的程序。

Answer 1

實際上，您不需要從PostgreSQL服務器發佈數據。使用WSO2 Data Analytics Server（DAS），您可以從數據庫中提取數據並進行分析。最後，您可以將結果推回到PostgreSQL服務器。在DAS中，我們有一個名爲「CarbonJDBC」的特殊連接器，使用該連接器可以輕鬆完成此操作。

「CarbonJDBC」連接器的當前版本支持以下數據庫管理系統。

1. MySQL的
2. H2
3. MS SQL
4. DB2
5. PostgreSQL的
6. 甲骨文

您可以使用下面的查詢從您的PostgreSQL數據庫中提取數據，並形成一個火花表。一旦火花表填充了數據，您就可以開始數據分析任務。

create temporary table <temp_table> using CarbonJDBC options (dataSource "<datasource name>", tableName "<table name>"); 
select * from <temp_table>; 
insert into/overwrite table <temp_table> <some select statement>; 

有關「CarbonJDBC」連接器的更多信息，請參閱以下博客文章[1]。

[1]。 https://pythagoreanscript.wordpress.com/2015/08/11/using-the-carbon-spark-jdbc-connector-for-wso2-das-part-1/