QueryDISyncTaskConfigProcessResult - : Central de Documentação do Alibaba Cloud

O DataWorks permite chamar apenas a operação CreateDISyncTask ou UpdateDISyncTask para criar ou atualizar um nó de sincronização em lote no Data Integration. Para criar ou atualizar um nó de sincronização em tempo real ou uma solução de sincronização, chame primeiro a operação GenerateDISyncTaskConfigForCreating ou GenerateDISyncTaskConfigForUpdating para gerar o ID de um thread assíncrono. Em seguida, chame a operação QueryDISyncTaskConfigProcessResult para obter os parâmetros gerados assincronamente com base nesse ID. Por fim, chame a operação CreateDISyncTask ou UpdateDISyncTask e use os parâmetros obtidos como parâmetros de solicitação para criar ou atualizar o nó de sincronização em tempo real ou a solução de sincronização.

O DataWorks oferece suporte à criação ou atualização de nós de sincronização em tempo real e soluções de sincronização no Data Integration exclusivamente no modo assíncrono.

Depuração

O OpenAPI Explorer calcula automaticamente o valor da assinatura. Recomendamos chamar esta operação no OpenAPI Explorer para maior conveniência. A ferramenta também gera dinamicamente códigos de exemplo da operação para diferentes SDKs.

Parâmetros de solicitação

Parâmetro	Tipo	Obrigatório	Exemplo	Descrição
Action	String	Sim	QueryDISyncTaskConfigProcessResult	A operação a ser executada.
ProjectId	Long	Sim	10000	O ID do workspace do DataWorks. Faça login no DataWorks console e acesse a página Workspace Management para obter o ID do workspace. Este parâmetro especifica o workspace do DataWorks ao qual a operação se aplica.
TaskType	String	Sim	DI_REALTIME	O tipo de objeto a ser criado ou atualizado no Data Integration em modo assíncrono. Valores válidos: DI_REALTIME: nó de sincronização em tempo real DI_SOLUTION: solução de sincronização O DataWorks permite criar ou atualizar nós de sincronização em tempo real e soluções de sincronização no Data Integration apenas no modo assíncrono.
RegionId	String	Sim	cn-zhangjiakou	O ID da região. Por exemplo, o ID da região China (Shanghai) é cn-shanghai e o da região China (Zhangjiakou) é cn-zhangjiakou. O sistema determina o valor deste parâmetro com base no endpoint usado para chamar a operação.
AsyncProcessId	Long	Sim	10	O ID do thread assíncrono. Chame a operação GenerateDISyncTaskConfigForCreating ou GenerateDISyncTaskConfigForUpdating para gerar este ID. A operação GenerateDISyncTaskConfigForCreating gera o ID do thread assíncrono usado para criar um nó de sincronização em tempo real ou uma solução de sincronização no Data Integration. A operação GenerateDISyncTaskConfigForUpdating gera o ID do thread assíncrono usado para atualizar um nó de sincronização em tempo real ou uma solução de sincronização no Data Integration.

Parâmetros de resposta

Parâmetro	Tipo	Exemplo	Descrição
Success	Boolean	true	Indica se a solicitação foi bem-sucedida. Valores válidos: true: a solicitação foi bem-sucedida. false: a solicitação falhou.
RequestId	String	0bc1411515937635973****	O ID da solicitação. Use este ID para localizar logs e solucionar problemas.
Data	Object		As informações retornadas sobre os parâmetros gerados assincronamente e usados para criar ou atualizar um nó de sincronização em tempo real ou uma solução de sincronização no Data Integration.
Status	String	success	Indica se os parâmetros foram obtidos. Valores válidos: success: indica que os parâmetros foram obtidos com êxito. fail: indica falha na obtenção dos parâmetros. Verifique o motivo da falha e solucione o problema com base nessa informação.
Message	String	fileId:[100] is invalid.	O motivo da falha na obtenção dos parâmetros. Se a obtenção for bem-sucedida, o valor retornado será 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"}]}}	Os parâmetros obtidos. Eles servem como parâmetros de solicitação para a operação CreateDISyncTask ou UpdateDISyncTask, permitindo criar ou atualizar um nó de sincronização em tempo real ou uma solução de sincronização no Data Integration.

Exemplos

Exemplos de solicitações

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

Exemplos de respostas de sucesso

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 erro

Código de status HTTP	Código de erro	Mensagem de erro	Descrição
400	Param.Invalid	The parameter is invalid.	Um ou mais parâmetros são inválidos.
403	Forbidden.Access	Access is forbidden.	Você não tem autorização para executar esta operação.
500	InternalError.System	An internal error occurred.	Ocorreu um erro interno.

Para obter uma lista de códigos de erro, visite o API Error Center.