DASを使用してPOSTGRESQLデータベースからデータを読み取る方法は？

Question

私たちはETLに取り組んでいます。 POSTGRESQLデータベースからストリームを使用してDATA ANALYTICS SERVERのデータを読み取ってストリームを使用して操作し、操作されたデータを別の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/