非同期同期タスク結果の取得とリアルタイム作成の有効化 - DataWorks

操作説明

DataWorks では、現在、データ統合のオフライン同期タスクについては、CreateDISyncTask API オペレーションを直接使用して作成するか、UpdateDISyncTask API オペレーションを使用して更新することが可能です。一方、データ統合のリアルタイム同期タスクについては、まず GenerateDISyncTaskConfigForCreating、GenerateDISyncTaskConfigForUpdating、および QueryDISyncTaskConfigProcessResult の各 API オペレーションを呼び出して、リアルタイム同期タスクの作成または更新に必要なパラメーターを非同期で生成し、そのパラメーターを CreateDISyncTask または UpdateDISyncTask のリクエストパラメーターとして指定して、対応するリアルタイム同期タスクを作成または更新する必要があります。リアルタイム同期タスクの作成および更新は、非同期方式のみがサポートされています。

今すぐお試しください

この API を OpenAPI Explorer でお試しください。手作業による署名は必要ありません。呼び出しに成功すると、入力したパラメーターに基づき、資格情報が組み込まれた SDK コードが自動的に生成されます。このコードをダウンロードしてローカルで使用できます。

テスト

RAM 認証

この操作の認証情報はありません。問題が発生した場合は、アカウントマネージャーにご連絡ください。

リクエストパラメーター

パラメーター	型	必須 / 任意	説明	例
ProjectId	integer	必須	DataWorks ワークスペースの ID です。DataWorks コンソール（https://workbench.data.aliyun.com/console）にログインし、「ワークスペース」ページに移動して、ID を確認してください。本 API オペレーションを適用する DataWorks ワークスペースを指定するために、このパラメーターを設定する必要があります。	10000
TaskType	string	必須	非同期モードでデータ統合で作成または更新するオブジェクトの種類です。有効な値は以下のとおりです。 DI_REALTIME：リアルタイム同期タスク DI_SOLUTION：同期ソリューションDataWorks では、データ統合におけるリアルタイム同期タスクおよび同期ソリューションの作成・更新は、非同期モードでのみ可能です。有効な値： DI_OFFLINE DI_REALTIME DI_SOLUTION	DI_REALTIME
AsyncProcessId	integer	必須	非同期スレッドの ID です。GenerateDISyncTaskConfigForCreating または GenerateDISyncTaskConfigForUpdating API オペレーションを呼び出すことで取得できます。 GenerateDISyncTaskConfigForCreating は、データ統合におけるリアルタイム同期タスクの作成に使用される非同期スレッドの ID を生成します。 GenerateDISyncTaskConfigForUpdating は、データ統合におけるリアルタイム同期タスクの更新に使用される非同期スレッドの ID を生成します。	10

レスポンスフィールド

フィールド	型	説明	例
	object	応答結果です。
Success	boolean	リクエストが成功したかどうかを示します。有効な値は以下のとおりです。 true false	true
RequestId	string	リクエスト ID です。この ID を使用してログを特定し、問題のトラブルシューティングを行えます。	0bc1411515937635973****
Data	object	データ統合におけるリアルタイム同期タスクの作成または更新に使用される、非同期で生成されたパラメーターに関する情報です。
Status	string	パラメーターの取得状況を示します。有効な値は以下のとおりです。 success：パラメーターの取得に成功しました。 fail：パラメーターの取得に失敗しました。失敗理由を確認し、それに基づいてトラブルシューティングを行ってください。	success
Message	string	パラメーターの取得に失敗した理由です。パラメーターの取得に成功した場合は、null が返されます。	fileId:[100] is invalid.
TaskContent	string	取得されたパラメーターです。このパラメーターは、データ統合におけるリアルタイム同期タスクの作成または更新を行う CreateDISyncTask または UpdateDISyncTask API オペレーションのリクエストパラメーターとして使用されます。	{"extend":{"mode":"migration_holo","resourceGroup":"280749","name":"h"},"type":"job","steps":[{"stepType":"mysql","parameter":{"connection":[{"datasourceType":"mysql","datasource":"mm","selectedTables":[{"schema":[{"tableInfos":[{"enable":true,"table":"m_v1","tableName":"m_v1"}]}],"dbName":"m"}]}]},"name":"reader","category":"reader"},{"stepType":"holo","parameter":{"datasource":"h","tableMappingRule":{"datasource":[{"tableRule":[{"srcTable":"m_v1","mergeIntoCycleType":"DEFAULT","hourDeltaEnable":false,"dstTable":"m.m_v1","dayDeltaEnable":false,"primaryKeyInfo":{"column":["id"],"type":"pk"},"dstCreateTableInfo":{"indexType":"m_v1","dataColumn":[{"columnSize":0,"name":"id","index":0,"comment":"","newDigit":0,"type":"int8","digit":0,"primaryKey":true}],"schemaName":"m","tableName":"m_v1"},"srcDbName":"m"}],"srcDatasourceName":"mm"}],"totalTableMapping":1},"writeMode":"replay"},"name":"writer","category":"writer"}],"version":"2.0","order":{"hops":[{"from":"reader","to":"writer"}]}}

例

成功レスポンス

JSONJSON

{
  "Success": true,
  "RequestId": "0bc1411515937635973****",
  "Data": {
    "Status": "success",
    "Message": "fileId:[100] is invalid.",
    "TaskContent": "{\"extend\":{\"mode\":\"migration_holo\",\"resourceGroup\":\"280749\",\"name\":\"h\"},\"type\":\"job\",\"steps\":[{\"stepType\":\"mysql\",\"parameter\":{\"connection\":[{\"datasourceType\":\"mysql\",\"datasource\":\"mm\",\"selectedTables\":[{\"schema\":[{\"tableInfos\":[{\"enable\":true,\"table\":\"m_v1\",\"tableName\":\"m_v1\"}]}],\"dbName\":\"m\"}]}]},\"name\":\"reader\",\"category\":\"reader\"},{\"stepType\":\"holo\",\"parameter\":{\"datasource\":\"h\",\"tableMappingRule\":{\"datasource\":[{\"tableRule\":[{\"srcTable\":\"m_v1\",\"mergeIntoCycleType\":\"DEFAULT\",\"hourDeltaEnable\":false,\"dstTable\":\"m.m_v1\",\"dayDeltaEnable\":false,\"primaryKeyInfo\":{\"column\":[\"id\"],\"type\":\"pk\"},\"dstCreateTableInfo\":{\"indexType\":\"m_v1\",\"dataColumn\":[{\"columnSize\":0,\"name\":\"id\",\"index\":0,\"comment\":\"\",\"newDigit\":0,\"type\":\"int8\",\"digit\":0,\"primaryKey\":true}],\"schemaName\":\"m\",\"tableName\":\"m_v1\"},\"srcDbName\":\"m\"}],\"srcDatasourceName\":\"mm\"}],\"totalTableMapping\":1},\"writeMode\":\"replay\"},\"name\":\"writer\",\"category\":\"writer\"}],\"version\":\"2.0\",\"order\":{\"hops\":[{\"from\":\"reader\",\"to\":\"writer\"}]}}"
  }
}

エラーコード

HTTP ステータスコード	エラーコード	エラーメッセージ
400	Param.Invalid	The parameter is invalid.
500	InternalError.System	An internal error occurred.
403	Forbidden.Access	Access is forbidden.

完全なリストについては、「エラーコード」をご参照ください。

変更履歴

完全なリストについては、「変更履歴」をご参照ください。