QueryDISyncTaskConfigProcessResult - - Centro de documentación de Alibaba Cloud

Obtiene los parámetros generados de forma asíncrona a partir del ID de un hilo asíncrono. Estos parámetros se utilizan para crear o actualizar un nodo de sincronización en tiempo real o una solución de sincronización en Data Integration.

DataWorks permite llamar únicamente a la operación CreateDISyncTask o UpdateDISyncTask para crear o actualizar un nodo de sincronización por lotes en Data Integration. Para crear o actualizar un nodo de sincronización en tiempo real o una solución de sincronización, primero debe llamar a la operación GenerateDISyncTaskConfigForCreating o GenerateDISyncTaskConfigForUpdating para generar el ID de un hilo asíncrono. Después, llame a la operación QueryDISyncTaskConfigProcessResult para obtener los parámetros generados de forma asíncrona mediante dicho ID. Por último, invoque la operación CreateDISyncTask o UpdateDISyncTask y utilice estos parámetros como argumentos de solicitud para crear o actualizar el nodo de sincronización en tiempo real o la solución de sincronización.

DataWorks solo admite la creación o actualización de nodos de sincronización en tiempo real y soluciones de sincronización en Data Integration mediante el modo asíncrono.

Depuración

OpenAPI Explorer calcula automáticamente el valor de la firma. Para mayor comodidad, se recomienda ejecutar esta operación en OpenAPI Explorer. Esta herramienta genera dinámicamente el código de ejemplo de la operación para diferentes SDK.

Parámetros de solicitud

Parámetro	Tipo	Obligatorio	Ejemplo	Descripción
Action	String	Sí	QueryDISyncTaskConfigProcessResult	La operación que desea ejecutar.
ProjectId	Long	Sí	10000	El ID del espacio de trabajo de DataWorks. Inicie sesión en la consola de DataWorks y vaya a la página Workspace Management para obtener el ID del espacio de trabajo. Este parámetro especifica el espacio de trabajo de DataWorks al que se aplica la operación.
TaskType	String	Sí	DI_REALTIME	El tipo de objeto que desea crear o actualizar en Data Integration mediante el modo asíncrono. Valores válidos: DI_REALTIME: nodo de sincronización en tiempo real DI_SOLUTION: solución de sincronización DataWorks solo permite crear o actualizar nodos de sincronización en tiempo real y soluciones de sincronización en Data Integration mediante el modo asíncrono.
RegionId	String	Sí	cn-zhangjiakou	El ID de la región. Por ejemplo, el ID de la región China (Shanghai) es cn-shanghai y el de la región China (Zhangjiakou) es cn-zhangjiakou. El sistema determina el valor de este parámetro según el endpoint utilizado para invocar la operación.
AsyncProcessId	Long	Sí	10	El ID del hilo asíncrono. Llame a la operación GenerateDISyncTaskConfigForCreating o GenerateDISyncTaskConfigForUpdating para generar este ID. La operación GenerateDISyncTaskConfigForCreating genera el ID del hilo asíncrono necesario para crear un nodo de sincronización en tiempo real o una solución de sincronización en Data Integration. La operación GenerateDISyncTaskConfigForUpdating genera el ID del hilo asíncrono necesario para actualizar un nodo de sincronización en tiempo real o una solución de sincronización en Data Integration.

Parámetros de respuesta

Parámetro	Tipo	Ejemplo	Descripción
Success	Boolean	true	Indica si la solicitud se realizó correctamente. Valores válidos: true: La solicitud se completó con éxito. false: La solicitud falló.
RequestId	String	0bc1411515937635973****	El ID de la solicitud. Use este identificador para localizar registros y solucionar problemas.
Data	Object		La información devuelta correspondiente a los parámetros generados de forma asíncrona, los cuales se emplean para crear o actualizar un nodo de sincronización en tiempo real o una solución de sincronización en Data Integration.
Status	String	success	Indica si se obtuvieron los parámetros. Valores válidos: success: indica que los parámetros se obtuvieron correctamente. fail: indica que no fue posible obtener los parámetros. Consulte el motivo del fallo y solucione el problema con base en dicha información.
Message	String	fileId:[100] is invalid.	El motivo por el cual no se pudieron obtener los parámetros. Si la obtención es exitosa, se devuelve el valor null.
TaskContent	String	{"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"}]}}	Los parámetros obtenidos. Estos se utilizan como parámetros de solicitud en la operación CreateDISyncTask o UpdateDISyncTask para crear o actualizar un nodo de sincronización en tiempo real o una solución de sincronización en Data Integration.

Ejemplos

Solicitudes de ejemplo

http(s)://[Endpoint]/?Action=QueryDISyncTaskConfigProcessResult
&ProjectId=10000
&TaskType=DI_REALTIME
&AsyncProcessId=10
&<Common request parameters>

Respuestas de éxito de ejemplo

Formato XML

HTTP/1.1 200 OK
Content-Type:application/xml

<QueryDISyncTaskConfigProcessResultResponse>
    <Success>true</Success>
    <RequestId>0bc1411515937635973****</RequestId>
    <Data>
        <Status>success</Status>
        <Message>fileId:[100] is invalid.</Message>
        <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"}]}}</TaskContent>
    </Data>
</QueryDISyncTaskConfigProcessResultResponse>

Formato JSON

HTTP/1.1 200 OK
Content-Type:application/json

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

Códigos de error

Código de estado HTTP	Código de error	Mensaje de error	Descripción
400	Param.Invalid	The parameter is invalid.	Mensaje de error devuelto cuando uno o más parámetros no son válidos.
403	Forbidden.Access	Access is forbidden.	Mensaje de error devuelto cuando no tiene autorización para realizar esta operación.
500	InternalError.System	An internal error occurred.	Mensaje de error devuelto cuando ocurre un error interno.

Para consultar la lista completa de códigos de error, visite el Centro de errores de API.