Kueri hasil tugas sinkronisasi asinkron untuk mengaktifkan pembuatan real-time - DataWorks - Alibaba Cloud - DataWorks

Deskripsi operasi

DataWorks memungkinkan Anda untuk langsung memanggil operasi CreateDISyncTask guna membuat atau operasi UpdateDISyncTask guna memperbarui tugas sinkronisasi batch di Data Integration. Untuk membuat atau memperbarui tugas sinkronisasi real-time, Anda harus terlebih dahulu memanggil operasi GenerateDISyncTaskConfigForCreating, GenerateDISyncTaskConfigForUpdating, dan QueryDISyncTaskConfigProcessResult untuk menghasilkan parameter yang diperlukan secara asinkron, lalu meneruskan parameter tersebut ke operasi CreateDISyncTask atau UpdateDISyncTask. Hanya pembuatan atau pembaruan asinkron yang didukung untuk tugas sinkronisasi real-time di Data Integration.

Coba sekarang

Coba API ini di OpenAPI Explorer tanpa perlu penandatanganan manual. Panggilan yang berhasil akan secara otomatis menghasilkan contoh kode SDK sesuai dengan parameter Anda. Unduh kode tersebut dengan kredensial bawaan yang aman untuk penggunaan lokal.

Test

RAM authorization

Tidak ada otorisasi untuk operasi ini. Jika Anda mengalami masalah saat menjalankan operasi ini, hubungi dukungan teknis.

Parameter permintaan

Parameter	Type	Required	Description	Example
ProjectId	integer	Yes	ID workspace DataWorks. Anda dapat masuk ke konsol DataWorks dan membuka halaman Workspace untuk mendapatkan ID tersebut. Anda harus mengonfigurasi parameter ini untuk menentukan workspace DataWorks tempat operasi API diterapkan.	10000
TaskType	string	Yes	Jenis objek yang ingin Anda buat atau perbarui di Data Integration dalam mode asinkron. Nilai yang valid: DI_REALTIME: tugas sinkronisasi real-time DI_SOLUTION: solusi sinkronisasi DataWorks memungkinkan Anda membuat atau memperbarui tugas sinkronisasi real-time dan solusi sinkronisasi di Data Integration hanya dalam mode asinkron. Nilai yang valid: DI_OFFLINE DI_REALTIME DI_SOLUTION	DI_REALTIME
AsyncProcessId	integer	Yes	ID thread asinkron. Anda dapat memanggil operasi GenerateDISyncTaskConfigForCreating atau GenerateDISyncTaskConfigForUpdating untuk mendapatkan ID tersebut. Operasi GenerateDISyncTaskConfigForCreating digunakan untuk menghasilkan ID thread asinkron yang dipakai untuk membuat tugas sinkronisasi real-time di Data Integration. Operasi GenerateDISyncTaskConfigForUpdating digunakan untuk menghasilkan ID thread asinkron yang dipakai untuk memperbarui tugas sinkronisasi real-time di Data Integration.	10

Elemen respons

Element	Type	Description	Example
	object	Hasil yang dikembalikan.
Success	boolean	Menunjukkan apakah permintaan berhasil. Nilai yang valid: true false	true
RequestId	string	ID permintaan. Anda dapat menemukan log dan memecahkan masalah berdasarkan ID ini.	0bc1411515937635973****
Data	object	Informasi yang dikembalikan untuk parameter yang dihasilkan secara asinkron dan digunakan untuk membuat atau memperbarui tugas sinkronisasi real-time di Data Integration.
Status	string	Menunjukkan apakah parameter berhasil diperoleh. Nilai yang valid: success: Parameter berhasil diperoleh. fail: Parameter gagal diperoleh. Anda dapat melihat alasan kegagalan dan memecahkan masalah berdasarkan alasan tersebut.	success
Message	string	Alasan parameter gagal diperoleh. Jika parameter berhasil diperoleh, nilai null akan dikembalikan.	fileId:[100] is invalid.
TaskContent	string	Parameter yang diperoleh. Parameter ini digunakan sebagai parameter permintaan operasi CreateDISyncTask atau UpdateDISyncTask untuk membuat atau memperbarui tugas sinkronisasi real-time di Data Integration.	{"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"}]}}

Contoh

Respons sukses

JSONformat

{
  "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\"}]}}"
  }
}

Kode kesalahan

HTTP status code	Error code	Error message
400	Param.Invalid	The parameter is invalid.
500	InternalError.System	An internal error occurred.
403	Forbidden.Access	Access is forbidden.

Lihat Error Codes untuk daftar lengkap.

Catatan rilis

Lihat Release Notes untuk daftar lengkap.