新バージョンの同期タスクを作成します。サポートされる同期タスクの種類は、MySQL データベース内の全データを Hologres にリアルタイム同期するものと、MySQL データベース内の全データを Hive にバッチ同期するものです。
今すぐお試しください
テスト
RAM 認証
リクエストパラメーター
|
パラメーター |
型 |
必須 / 任意 |
説明 |
例 |
| ProjectId |
integer |
任意 |
DataWorks ワークスペース ID。この ID は、ListProjects API を呼び出すことで取得できます。 |
10000 |
| JobName |
string |
任意 |
同期タスクの名前。 |
mysql_to_holo_sync_8772 |
| Description |
string |
任意 |
同期タスクの説明。 |
Synchronize mysql to hologres |
| MigrationType |
string |
任意 |
同期タイプ。有効な値は以下のとおりです。
|
FullAndRealtimeIncremental |
| SourceDataSourceType |
string |
任意 |
ソースタイプ。このパラメーターは MySQL に設定してください。 |
MySQL |
| DestinationDataSourceType |
string |
任意 |
送信先タイプ。有効な値は Hologres および Hive です。 |
Hologres |
| SourceDataSourceSettings |
array<object> |
任意 |
ソースの設定。単一のソースのみがサポートされます。 |
|
|
array<object> |
任意 |
|||
| DataSourceName |
string |
任意 |
データソースの名前。 |
mysql_datasource_1 |
| DataSourceProperties |
object |
任意 |
データソースのプロパティ。 |
|
|
string |
任意 |
ソースのプロパティ。MySQL データソースのプロパティには、TimeZone および Encoding が含まれます。 |
TimeZone |
|
| DestinationDataSourceSettings |
array<object> |
任意 |
送信先の設定。単一の送信先のみがサポートされます。 |
|
|
array<object> |
任意 |
|||
| DataSourceName |
string |
任意 |
データソースの名前。 |
holo_datasource_1 |
| DataSourceProperties |
object |
任意 |
データソースのプロパティ。 |
|
|
string |
任意 |
送信先のプロパティ。Hologres データソースでは、プロパティの設定はできません。 |
TimeZone |
|
| ResourceSettings |
object |
任意 |
リソース設定。 |
|
| OfflineResourceSettings |
object |
任意 |
バッチ同期に使用されるリソース。 |
|
| ResourceGroupIdentifier |
string |
任意 |
バッチ同期に使用される Data Integration のリソースグループ識別子。 |
S_res_group_111_222 |
| RealtimeResourceSettings |
object |
任意 |
リアルタイム同期に使用されるリソース。 |
|
| ResourceGroupIdentifier |
string |
任意 |
リアルタイム同期に使用される Data Integration のリソースグループ識別子。 |
S_res_group_111_222 |
| RequestedCu |
number |
任意 |
増分同期および完全同期に使用されるリソースグループ内の計算ユニット (CU) 数。 |
2.0 |
| TransformationRules |
array<object> |
任意 |
ソースから選択した同期対象に適用する変換ルールのリスト。リスト内の各エントリは、1 つの変換ルールを定義します。 |
|
|
object |
任意 |
ソースから選択した同期対象に適用する変換ルール。 |
||
| RuleName |
string |
任意 |
ルールの名前。複数の変換ルールで RuleActionType パラメーターおよび RuleTargetType パラメーターの値が同一の場合、変換ルール名が一意であることを確認してください。 |
rename_rule_1 |
| RuleActionType |
string |
任意 |
操作タイプ。有効な値は以下のとおりです。
|
Rename |
| RuleTargetType |
string |
任意 |
操作を実行するオブジェクトのタイプ。有効な値は以下のとおりです。
|
Table |
| RuleExpression |
string |
任意 |
ルールの式。式は JSON 文字列である必要があります。 名前の変更ルールの例:{"expression":"${srcDatasourceName}_${srcDatabaseName}_0922","variables":[{"variableName":"srcDatabaseName","variableRules":[{"from":"fromdb","to":"todb"}]}]}
送信先に特定のフィールドを追加して値を割り当てるルールの例:{"columns":[{"columnName":"my_add_column","columnValueType":"Constant","columnValue":"123"}]}
送信先テーブルのプライマリキーを指定するルールの例:{"columns":["ukcolumn1","ukcolumn2"]}
DML メッセージを処理するルールの例:{"dmlPolicies":[{"dmlType":"Delete","dmlAction":"Filter","filterCondition":"id > 1"}]}
|
{"expression":"${srcDatasoureName}_${srcDatabaseName}"} |
| TableMappings |
array<object> |
任意 |
ソースから同期対象を選択するルールと、選択された同期対象に適用される変換ルールとの間のマッピングのリスト。リスト内の各エントリは、同期対象を選択するルールと、選択された同期対象に適用される変換ルールとのマッピングを表示します。 |
|
|
array<object> |
任意 |
ソースから同期対象を選択するルールと、選択された同期対象に適用される変換ルールとのマッピング。 |
||
| SourceObjectSelectionRules |
array<object> |
任意 |
ソースから同期対象を選択するルール。 |
|
|
object |
任意 |
ソースから同期対象を選択するルール。対象はデータベースまたはテーブルになります。 |
||
| ObjectType |
string |
任意 |
オブジェクトタイプ。有効な値は以下のとおりです。
|
Table |
| Expression |
string |
任意 |
式。 |
mysql_table_1 |
| TransformationRules |
array<object> |
任意 |
ソースから選択した同期対象に適用する変換ルールのリスト。 |
|
|
object |
任意 |
ソースから選択した同期対象に適用する変換ルール。 |
||
| RuleName |
string |
任意 |
ルールの名前。複数の変換ルールで RuleActionType パラメーターおよび RuleTargetType パラメーターの値が同一の場合、変換ルール名が一意であることを確認してください。 |
rename_rule_1 |
| RuleActionType |
string |
任意 |
操作タイプ。有効な値は以下のとおりです。
|
Rename |
| RuleTargetType |
string |
任意 |
操作を実行するオブジェクトのタイプ。有効な値は以下のとおりです。
|
Table |
| JobSettings |
object |
任意 |
同期タスクのディメンションに関する設定。設定には、DDL メッセージの処理ポリシー、ソースフィールドと送信先フィールド間のデータ型マッピングのポリシー、および同期タスクの実行時パラメーターが含まれます。 |
|
| DdlHandlingSettings |
array<object> |
任意 |
DDL メッセージの処理設定。 |
|
|
object |
任意 |
特定の DDL メッセージの処理設定。 |
||
| Type |
string |
任意 |
DDL 操作のタイプ。有効な値は以下のとおりです。
|
AddColumn |
| Action |
string |
任意 |
処理ポリシー。有効な値は以下のとおりです。
|
Critical |
| ColumnDataTypeSettings |
array<object> |
任意 |
ソースフィールドと送信先フィールド間のデータ型マッピングの設定。このパラメーターの値は配列である必要があります。 |
|
|
object |
任意 |
ソースフィールドと送信先フィールド間のデータ型マッピング。 |
||
| SourceDataType |
string |
任意 |
ソースフィールドのデータ型。 |
bigint |
| DestinationDataType |
string |
任意 |
送信先フィールドのデータ型。 |
text |
| RuntimeSettings |
array<object> |
任意 |
実行時設定。このパラメーターの値は配列である必要があります。 |
|
|
object |
任意 |
実行時設定。 |
||
| Name |
string |
任意 |
設定項目の名前。有効な値は以下のとおりです。
|
runtime.offline.concurrent |
| Value |
string |
任意 |
設定項目の値。 |
1 |
| CycleScheduleSettings |
object |
任意 |
定期スケジューリングの設定。 |
|
| CycleMigrationType |
string |
任意 |
定期スケジューリングを必要とする同期タイプ。有効な値は以下のとおりです。
|
Full |
| ScheduleParameters |
string |
任意 |
スケジューリングパラメーター。 |
bizdate=$bizdate |
| ChannelSettings |
string |
任意 |
同期タスクのチャネル制御設定。このパラメーターの値は JSON 文字列である必要があります。 |
{"structInfo":"MANAGED","storageType":"TEXTFILE","writeMode":"APPEND","partitionColumns":[{"columnName":"pt","columnType":"STRING","comment":""}],"fieldDelimiter":""} |
| ImportRuleSettings |
object |
任意 |
同期タスクのインポート設定。 |
|
| Source |
string |
任意 |
タスクのインポート元。値は DataStudio に設定します。これは DataStudio で作成された同期タスクを意味します。 |
Datastudio |
| FileId |
string |
任意 |
インポート対象のタスク ID。 |
10000 |
| SystemDebug |
string |
任意 |
システムデバッグを実行するかどうかを指定します。有効な値は true および false です。デフォルト値は false です。 |
false |
レスポンスフィールド
|
フィールド |
型 |
説明 |
例 |
|
object |
レスポンスパラメーター。 |
||
| RequestId |
string |
リクエスト ID。この ID を使用してログを照会したり、問題のトラブルシューティングを行ったりできます。 |
4F6AB6B3-41FB-5EBB-AFB2-0C98D49DA2BB |
| DIJobId |
integer |
同期タスク ID。 |
11792 |
例
成功レスポンス
JSONJSON
{
"RequestId": "4F6AB6B3-41FB-5EBB-AFB2-0C98D49DA2BB",
"DIJobId": 11792
}
エラーコード
|
HTTP ステータスコード |
エラーコード |
エラーメッセージ |
説明 |
|---|---|---|---|
| 500 | InternalError.System | An internal system error occurred. Try again later. | |
| 500 | InternalError.UserId.Missing | An internal system error occurred. Try again later. | |
| 429 | Throttling.Api | The request for this resource has exceeded your available limit. | |
| 429 | Throttling.System | The DataWorks system is busy. Try again later. | |
| 429 | Throttling.User | Your request is too frequent. Try again later. |
完全なリストについては、「エラーコード」をご参照ください。
変更履歴
完全なリストについては、「変更履歴」をご参照ください。