異步生成同時(shí)任務(wù)的JSON。
接口說(shuō)明
DataWorks 目前僅支持直接使用 CreateDISyncTask 接口創(chuàng)建數(shù)據(jù)集成離線同步任務(wù),而數(shù)據(jù)集成實(shí)時(shí)同步任務(wù)和其他同步類型的任務(wù)則需要先調(diào)用 GenerateDISyncTaskConfigForCreating 和 QueryDISyncTaskConfigProcessResult 接口,獲取異步生成創(chuàng)建數(shù)據(jù)集成同步任務(wù)需要的參數(shù),再將該參數(shù)作為 CreateDISyncTask 接口的入?yún)ⅲ褂?CreateDISyncTask 接口創(chuàng)建相應(yīng)的實(shí)時(shí)同步任務(wù)和其他同步類型的同步任務(wù)。 僅支持使用異步方式創(chuàng)建數(shù)據(jù)集成實(shí)時(shí)同步任務(wù)和其他同步類型的同步任務(wù)。
調(diào)試
您可以在OpenAPI Explorer中直接運(yùn)行該接口,免去您計(jì)算簽名的困擾。運(yùn)行成功后,OpenAPI Explorer可以自動(dòng)生成SDK代碼示例。
授權(quán)信息
請(qǐng)求參數(shù)
名稱 | 類型 | 必填 | 描述 | 示例值 |
---|---|---|---|---|
ProjectId | long | 是 | DataWorks 工作空間的 ID。您可以登錄 DataWorks 控制臺(tái),進(jìn)入工作空間配置頁(yè)面獲取工作空間 ID。 該參數(shù)用來(lái)確定本次 API 調(diào)用操作使用的 DataWorks 工作空間。 | 10000 |
TaskType | string | 是 | 使用異步方式創(chuàng)建數(shù)據(jù)集成同步任務(wù)的任務(wù)類型。取值如下:
僅支持使用異步方式生成數(shù)據(jù)集成實(shí)時(shí)同步任務(wù)和其他同步類型的同步任務(wù)。 | DI_REALTIME |
TaskParam | string | 是 | 數(shù)據(jù)集成同步任務(wù)的腳本。 目前支持創(chuàng)建的同步任務(wù)類型如下:
SelectedTables 用于多庫(kù)模式選擇同步表,Tables 用于單庫(kù)模式選擇同步表。
同步 MySQL 數(shù)據(jù)至 MaxCompute,示例語(yǔ)句如下。
同步 MySQL 數(shù)據(jù)至 Kafka,示例語(yǔ)句如下。
同步 MySQL 數(shù)據(jù)至 Hologres,示例語(yǔ)句如下。
| { "type": "realtime", "version": "1.0", "setting": { "resourceGroup": "S_res_group_280749521950784_1623033752022", "taskType": "oneclick_to_odps" }, "steps": [{ "stepType": "mysql", "parameter": { "connection": [ { "datasourceType": "mysql", "datasource": "mysql_pub1", "selectedTables": [ { "dbName": "mysql_db", "schema": [ { "tableInfos": [ { "table": "molin_di_test_in_pk_v4" }] } ] } ] } ] }, "name": "Reader", "category": "reader" }, { "stepType": "odps", "parameter": { "datasource": "odps_source" }, "name": "Writer", "category": "writer" } ] } |
ClientToken | string | 否 | 冪等參數(shù)。用于避免多次調(diào)用導(dǎo)致操作重復(fù)。 | ABFUOEUOTRTRJKE |
返回參數(shù)
示例
正常返回示例
JSON
格式
{
"Success": true,
"RequestId": "0bc1411515937635973****",
"Data": {
"Status": "true",
"ProcessId": 10,
"Message": "XXX is invalid."
}
}
錯(cuò)誤碼
HTTP status code | 錯(cuò)誤碼 | 錯(cuò)誤信息 | 描述 |
---|---|---|---|
400 | Invalid.DI.Parameter | The parameter is invalid. | 參數(shù)錯(cuò)誤 |
400 | Invalid.DI.Parameter.File.Existed | The file name already exists. | 參數(shù)不合法,文件名已存在 |
403 | Forbidden.DI.NoPrivilege | No access. | 沒(méi)有權(quán)限訪問(wèn) |
500 | InternalError.DI.Parameter | A DI internal error occurred. | 數(shù)據(jù)集成內(nèi)部業(yè)務(wù)錯(cuò)誤 |
訪問(wèn)錯(cuò)誤中心查看更多錯(cuò)誤碼。