Lista los trabajos de migración.
Pruébelo ahora
Test
Autorización de RAM
|
Action |
Nivel de acceso |
Tipo de recurso |
Clave de condición |
Acción dependiente |
|
odps:ListMmsJobs |
list |
*project
|
Ninguna | Ninguna |
Sintaxis de la solicitud
GET /api/v1/mms/datasources/{sourceId}/jobs HTTP/1.1
Parámetros de ruta
|
Parámetro |
Tipo |
Obligatorio |
Descripción |
Ejemplo |
| sourceId |
integer |
Sí |
El ID del origen de datos. |
2000002 |
Parámetros de la solicitud
|
Parámetro |
Tipo |
Obligatorio |
Descripción |
Ejemplo |
| name |
string |
No |
El nombre del origen de datos. |
demo |
| srcDbName |
string |
No |
El nombre de la base de datos de origen. |
test_db_1 |
| srcTableName |
string |
No |
El nombre de la tabla de origen. |
test_table_1 |
| dstDbName |
string |
No |
El proyecto MaxCompute de destino. |
mms_test |
| dstTableName |
string |
No |
La tabla MaxCompute de destino. |
test_table_1 |
| status |
string |
No |
El estado del trabajo de migración. Valores válidos:
|
DOING |
| stopped |
integer |
No |
Indica si el trabajo está detenido. |
false |
| timerId |
integer |
No |
El ID del temporizador. |
1 |
| pageNum |
integer |
No |
El número de la página a devolver. |
1 |
| pageSize |
integer |
No |
El número de elementos a devolver por página. Valores válidos:
|
10 |
| sorter.status |
string |
No |
Ordenamiento por estado. Valores válidos:
|
desc |
Elementos de la respuesta
|
Elemento |
Tipo |
Descripción |
Ejemplo |
|
object |
Los datos devueltos. |
||
| requestId |
string |
El ID de la solicitud. |
1112E7C7-C65F-57A2-A7C7-3B178AA257B6 |
| data |
object |
Los detalles de los datos devueltos. |
|
| total |
integer |
El número total de registros. |
100 |
| objectList |
array<object> |
La lista de trabajos de migración. |
|
|
array<object> |
El objeto del trabajo de migración. |
||
| id |
integer |
El ID del trabajo de migración. |
18 |
| name |
string |
El nombre del trabajo de migración. |
migrate_db_1 |
| sourceId |
integer |
El ID del origen de datos. |
2000015 |
| dbId |
integer |
El ID de la base de datos de origen. |
196 |
| sourceName |
string |
El nombre del origen de datos. |
demo |
| srcDbName |
string |
El nombre de la base de datos de origen. |
test_db_1 |
| srcSchemaName |
string |
El nombre del esquema de origen. Este es el esquema en un espacio de nombres de nivel 3. |
test_table_1 |
| dstDbName |
string |
El proyecto MaxCompute de destino. |
mms_test |
| dstSchemaName |
string |
El esquema MaxCompute de destino. |
test_table_1 |
| status |
string |
El estado del trabajo de migración. Valores válidos:
|
DONE |
| type |
string |
El alcance de la migración. Valores válidos: Database, Tables y Partitions. Valores válidos:
|
Tables |
| taskNum |
integer |
El número de tareas de migración en el trabajo. |
10 |
| stopped |
boolean |
Indica si el trabajo de migración está detenido. |
false |
| createTime |
string |
Indica si el trabajo de migración está detenido. |
2024-12-17 15:44:17 |
| taskDone |
integer |
El número de tareas de migración completadas. |
10 |
| config |
object |
La configuración del trabajo de migración. |
|
| partitions |
array |
Cuando type se establece en Partitions, especifique los ID de las particiones de las tablas a migrar. |
|
|
integer |
El ID de la partición de una tabla a migrar. |
[123, 132] |
|
| tables |
array |
Cuando type se establece en Tables, especifique los nombres de las tablas a migrar. |
|
|
string |
El nombre de una tabla a migrar. |
["student", "scores"] |
|
| taskType |
string |
Obsoleto. Valores válidos: MOCK, HIVE (tarea hive udtf), HIVE_DATAX (tarea hive datax), COPY_TASK (ODPS Copy Task), ODPS_INSERT_OVERWRITE (tarea ODPS simple insert overwrite), MC2MC_VERIFY, OSS, HIVE_OSS, HIVE_SPARK y BIGQUERY. |
BIGQUERY |
| tableBlackList |
array |
Cuando type se establece en Database, especifique las tablas a excluir de la migración. |
|
|
string |
Cuando type se establece en Database, la tabla a excluir de la migración. |
["student", "scores"] |
|
| tableWhiteList |
array |
Cuando type se establece en Database, especifique las tablas a migrar. Si no especifica tableWhiteList, se migran todas las tablas de la base de datos especificada. |
|
|
string |
Cuando type se establece en Database, la tabla a migrar. |
["student", "scores"] |
|
| partitionFilters |
object |
La expresión de filtro de partición. Especifique la expresión de filtro de partición para cada tabla. |
|
|
string |
La expresión de filtro de partición. Ejemplo: p1 >= '2022-03-04' and (p2 = 10 or p3 > 20) and p4 in ('abc', 'cde'). Notas: p1, p2 y p3 son nombres de particiones. Los valores de partición son cadenas o números. Las cadenas se encierran entre comillas dobles o simples. Solo se permiten valores de cadena para columnas de partición distintas de los tipos INT y BIGINT. Los operadores de comparación incluyen los siguientes: >, >=, =, <, <= y <>. Se admite el operador IN. Los operadores lógicos incluyen AND y OR. Utilice paréntesis para agrupar condiciones. |
{ "student": "p1 >= '2022-03-04' and (p2 = 10 or p3 > 20) and p4 in ('abc', 'cde')" } |
|
| schemaOnly |
boolean |
Obsoleto. |
false |
| tableMapping |
object |
La asignación de nombres de tablas de origen a nombres de tablas de destino. |
|
|
string |
La asignación de un nombre de tabla de origen a un nombre de tabla de destino. |
{'a': 'a1'} |
|
| increment |
boolean |
Habilita la migración incremental. Solo se migran las particiones nuevas o modificadas. Las particiones modificadas se vuelven a migrar. |
true |
| enableVerification |
boolean |
Habilita la verificación. El método actual ejecuta SELECT COUNT tanto en el origen como en el destino y compara los recuentos de filas. |
true |
| tunnelQuota |
string |
Obsoleto. |
Depcreated |
| columnMapping |
object |
La asignación de nombres de columnas de origen a nombres de columnas de destino. |
|
|
string |
La asignación de un nombre de columna de origen a un nombre de columna de destino. |
{"c-1": "c_1"} |
|
| others |
object |
Otros ajustes de configuración. |
{"spark.executor.mem": "2g"} |
| eta |
string |
El tiempo estimado de finalización de la migración. Un valor eta menor aumenta la prioridad del trabajo de migración. |
2025-05-06 |
| pageNum |
integer |
El número de página. |
1 |
| pageSize |
integer |
El número de entradas devueltas en cada página. |
10 |
Ejemplos
Respuesta exitosa
JSON Formato
{
"requestId": "1112E7C7-C65F-57A2-A7C7-3B178AA257B6",
"data": {
"total": 100,
"objectList": [
{
"id": 18,
"name": "migrate_db_1",
"sourceId": 2000015,
"dbId": 196,
"sourceName": "demo",
"srcDbName": "test_db_1",
"srcSchemaName": "test_table_1",
"dstDbName": "mms_test",
"dstSchemaName": "test_table_1",
"status": "DONE",
"type": "Tables",
"taskNum": 10,
"stopped": false,
"createTime": "2024-12-17 15:44:17\n",
"taskDone": 10,
"config": {
"partitions": [
0
],
"tables": [
"[\"student\", \"scores\"]"
],
"taskType": "BIGQUERY",
"tableBlackList": [
"[\"student\", \"scores\"]"
],
"tableWhiteList": [
"[\"student\", \"scores\"]"
],
"partitionFilters": {
"key": "{\n\"student\": \"p1 >= '2022-03-04' and (p2 = 10 or p3 > 20) and p4 in ('abc', 'cde')\" \n}"
},
"schemaOnly": false,
"tableMapping": {
"key": "{'a': 'a1'}"
},
"increment": true,
"enableVerification": true,
"tunnelQuota": "Depcreated",
"columnMapping": {
"key": "{\"c-1\": \"c_1\"}"
},
"others": {
"spark.executor.mem": "2g"
}
},
"eta": "2025-05-06"
}
],
"pageNum": 1,
"pageSize": 10
}
}
Códigos de error
Consulte Códigos de error para ver la lista completa.
Notas de la versión
Consulte Notas de la versión para ver la lista completa.