DataWorks:Verticaデータソース

サポートされているVerticaバージョン

Vertica Readerは、Vertica Java Database Connectivity（JDBC）ドライバーを使用してVerticaデータベースに接続します。ドライバーのバージョンがVerticaデータベースと互換性があることを確認する必要があります。次のバージョンのVertica JDBCドライバーが使用されます。

<dependency>
<groupId>com.vertica</groupId>
<artifactId>vertica-jdbc</artifactId>
<version>7.1.2</version>
</dependency>

制限事項

• Verticaデータソースは、Data Integrationの排他リソースグループのみをサポートします。

• Vertica Writerは、writeModeパラメーターをサポートしていません。

• 同期タスクの設定には、コードエディターのみを使用できます。

データ型マッピング

整数、浮動小数点、文字列、および時間カテゴリのデータ型を含む、一般的なVerticaデータ型がサポートされています。ただし、一部の高度なデータ型のサポートは制限されています。

データ同期タスクの開発

データ同期タスクの設定のエントリポイントと手順については、以下のセクションを参照してください。パラメーター設定については、タスクの設定タブにある各パラメーターのヒントをご覧ください。

データソースの追加

特定のデータソースとのデータ同期を行うデータ同期タスクを設定する前に、DataWorksにデータソースを追加する必要があります。詳細については、「データソースの追加と管理」をご参照ください。

単一テーブルのデータを同期するバッチ同期タスクの設定

• 設定手順については、「コードエディターを使用したバッチ同期タスクの設定」をご参照ください。

• コードエディターを使用してバッチ同期タスクを設定する場合に設定されるすべてのパラメーターと実行されるコードについては、「付録：コードとパラメーター」をご参照ください。

付録：コードとパラメーター

付録：コードエディターを使用したバッチ同期タスクの設定

コードエディターを使用してバッチ同期タスクを設定する場合は、コードエディターの形式要件に基づいて、関連データソースのリーダーとライターのパラメーターを設定する必要があります。形式要件の詳細については、「コードエディターを使用したバッチ同期タスクの設定」をご参照ください。以下の情報は、コードエディターのリーダーとライターのパラメーターの設定の詳細について説明しています。

Vertica Readerのコード

{
"type": "job",
"steps": [
{
"stepType": "vertica", // プラグイン名
"parameter": {
"datasource": "", // データソースの名前
"where": "",
"column": [ // 列の名前
"id",
"name"
],
"splitPk": "id",
"connection": [
{
"table": [ // テーブルの名前
"table"
]
}
]
},
"name": "Reader",
"category": "reader"
},
{
"stepType": "stream",
"parameter": {
"print": false,
"fieldDelimiter": ","
},
"name": "Writer",
"category": "writer"
}
],
"version": "2.0",
"order": {
"hops": [
{
"from": "Reader",
"to": "Writer"
}
]
},
"setting": {
"errorLimit": {
"record": "0" // 許容されるダーティデータレコードの最大数
},
"speed": {
"throttle": true, // スロットリングを有効にするかどうかを指定します。値がfalseの場合はスロットリングが無効になり、値がtrueの場合はスロットリングが有効になります。mbpsパラメーターは、throttleパラメーターがtrueに設定されている場合にのみ有効になります。
"concurrent": 1, // 並列スレッドの最大数
                        "mbps":"12"// 最大転送速度。単位：MB/s。
}
}
}

Vertica Readerのコードのパラメーター

Vertica Writerのコード

{
"type":"job",
"version":"2.0",// バージョン番号
"steps":[
{
"stepType":"stream",
"parameter":{},
"name":"Reader",
"category":"reader"
},
{
"stepType":"vertica", // プラグイン名
"parameter":{
"datasource": "データソースの名前",
"column": [// 列の名前
"id",
"name"
],
"connection": [
{
"table": [// テーブルの名前
"vertica_table"
]
}
],
"preSql": [ // 同期タスクの実行前に実行するSQLステートメント
"delete from @table where db_id = -1"
],
"postSql": [// 同期タスクの実行後に実行するSQLステートメント
"update @table set db_modify_time = now() where db_id = 1"
]
},
"name":"Writer",
"category":"writer"
}
],
"setting":{
"errorLimit":{
"record":"0"// 許容されるダーティデータレコードの最大数
},
"speed":{
                    "throttle":true,// スロットリングを有効にするかどうかを指定します。値がfalseの場合はスロットリングが無効になり、値がtrueの場合はスロットリングが有効になります。mbpsパラメーターは、throttleパラメーターがtrueに設定されている場合にのみ有効になります。
                    "concurrent":1, // 並列スレッドの最大数
                    "mbps":"12"// 最大転送速度。単位：MB/s。
}
},
"order":{
"hops":[
{
"from":"Reader",
"to":"Writer"
}
]
}
}

Vertica Writerのコードのパラメーター