Importa um nó de fluxo de trabalho definido pelo FlowSpec e seus nós filhos internos para o Data Studio.
Descrição da operação
-
Esta operação não oferece suporte à importação de múltiplos fluxos de trabalho. Se mais de um fluxo de trabalho for definido no FlowSpec, todos os fluxos de trabalho após o primeiro serão ignorados.
-
Esta é uma operação assíncrona. Chamar esta operação retorna um objeto de tarefa assíncrona. Para consultar o status de execução da tarefa, chame GetJobStatus.
Experimente agora
Testar
Autorização RAM
|
Ação |
Nível de acesso |
Tipo de recurso |
Chave de condição |
Ação dependente |
|
dataworks:* |
update |
*All Resource
|
Nenhuma | Nenhuma |
Parâmetros da solicitação
|
Parâmetro |
Tipo |
Obrigatório |
Descrição |
Exemplo |
| ProjectId |
integer |
Sim |
O ID do espaço de trabalho do DataWorks. Você pode fazer login no console do DataWorks e acessar a página de gerenciamento de espaços de trabalho para obter o ID. Este parâmetro especifica o espaço de trabalho do DataWorks usado para esta chamada de API. |
123456 |
| Spec |
string |
Sim |
As informações do FlowSpec que descrevem o fluxo de trabalho. Para obter detalhes sobre a especificação, consulte FlowSpec. Nota
Como obter rapidamente um modelo do FlowSpec?
Nota
<notice>Esta operação oferece suporte à criação de um fluxo de trabalho e seus nós internos ao mesmo tempo. Preste atenção aos IDs especificados no FlowSpec. Se um ID especificado já existir, a operação se tornará uma atualização. Somente quando nenhum ID for especificado ou o ID não existir, a operação se tornará uma criação.></notice> |
{ "version": "1.1.0", "kind": "CycleWorkflow", "spec": { "name": "Asynchronous_Workflow_Creation_Test", "id": "632647691239009XXXX", "type": "CycleWorkflow", "workflows": [ { "script": { "path": "XX/OpenAPI_Test/Workflow_Test/Asynchronous_Workflow_Creation_Test", "runtime": { "command": "WORKFLOW" } }, "id": "632647691239009XXXX", "trigger": { "type": "Scheduler", "cron": "00 03 00 * * ?", "startTime": "1970-01-01 00:00:00", "endTime": "9999-01-01 00:00:00", "timezone": "Asia/Shanghai", "delaySeconds": 0 }, "strategy": { "timeout": 0, "instanceMode": "T+1", "rerunMode": "Allowed", "rerunTimes": 3, "rerunInterval": 180000, "failureStrategy": "Break" }, "name": "Asynchronous_Workflow_Creation_Test", "inputs": {}, "outputs": { "nodeOutputs": [ { "data": "632647691239009XXXX", "artifactType": "NodeOutput", "refTableName": "Asynchronous_Workflow_Creation_Test" } ] }, "nodes": [ { "recurrence": "Normal", "id": "742981001612325XXXX", "timeout": 0, "instanceMode": "T+1", "rerunMode": "Allowed", "rerunTimes": 3, "rerunInterval": 180000, "script": { "path": "XX/OpenAPI_Test/Workflow_Test/Asynchronous_Workflow_Creation_Test/111", "runtime": { "command": "ODPS_SQL" }, "content": "select now();\n" }, "trigger": { "type": "Scheduler", "cron": "00 24 00 * * ?", "startTime": "1970-01-01 00:00:00", "endTime": "9999-01-01 00:00:00", "timezone": "Asia/Shanghai", "delaySeconds": 0 }, "name": "111", "inputs": {}, "outputs": { "nodeOutputs": [ { "data": "742981001612325XXXX", "artifactType": "NodeOutput", "refTableName": "111" } ] } }, { "recurrence": "Normal", "id": "595182137303408XXXX", "timeout": 0, "instanceMode": "T+1", "rerunMode": "Allowed", "rerunTimes": 3, "rerunInterval": 180000, "script": { "path": "XX/OpenAPI_Test/Workflow_Test/Asynchronous_Workflow_Creation_Test/222", "runtime": { "command": "ODPS_SQL" }, "content": "select now();\n select 1;" }, "trigger": { "type": "Scheduler", "cron": "00 00 00 * * ?", "startTime": "1970-01-01 00:00:00", "endTime": "9999-01-01 00:00:00", "timezone": "Asia/Shanghai", "delaySeconds": 0 }, "name": "222", "inputs": {}, "outputs": { "nodeOutputs": [ { "data": "595182137303408XXXX", "artifactType": "NodeOutput", "refTableName": "222" } ] } } ], "dependencies": [ { "nodeId": "595182137303408XXXX", "depends": [ { "type": "Normal", "output": "742981001612325XXXX", "refTableName": "111" } ] } ] } ] } } |
| DryRun |
boolean |
Não |
Especifica se esta operação deve ser chamada no modo de validação. Se este parâmetro for definido como true, apenas a validade da especificação do fluxo de trabalho de entrada será validada. A mesma lógica de pré-processamento e validação da importação real é reutilizada (com regras idênticas), mas nenhum dado é persistido e nenhuma operação de gravação é executada. O resultado da validação é retornado por meio de uma tarefa assíncrona. Se a validação falhar, a tarefa assíncrona falhará, e os detalhes do erro incluirão o código de erro, a mensagem de erro e um JSONPath que localiza o nó específico (como $.spec.workflows[0].nodes[1]). Valor padrão: false. Nesse caso, o fluxo de trabalho é importado normalmente. |
false |
Elementos de resposta
|
Elemento |
Tipo |
Descrição |
Exemplo |
|
object |
O esquema da resposta. |
||
| RequestId |
string |
O ID da solicitação. Você pode usar este ID para solucionar problemas. |
7C352CB7-CD88-50CF-9D0D-E81BDF020E7F |
| AsyncJob |
object |
As informações de status da tarefa assíncrona. |
|
| Completed |
boolean |
Indica se a tarefa assíncrona foi concluída. |
false |
| CreateTime |
integer |
O timestamp em que a tarefa assíncrona foi criada. |
1706581425000 |
| Error |
string |
A mensagem de erro quando a tarefa assíncrona falha. |
target folder already exists: XXXX |
| Id |
string |
O ID da tarefa assíncrona. |
1234567691239009XXXX |
| Progress |
integer |
O progresso da tarefa assíncrona. Valores válidos: 0 a 100. |
0 |
| Response |
string |
O conteúdo que a tarefa assíncrona deve retornar. Nota
Atualmente, este campo armazena o ID do fluxo de trabalho criado na tarefa assíncrona. |
632647691239009XXXX |
| Status |
string |
O status da tarefa assíncrona. Valores válidos:
|
Running |
| Type |
string |
O tipo de operação da tarefa assíncrona. Valores válidos:
|
Create |
Exemplos
Resposta de sucesso
JSON formato
{
"RequestId": "7C352CB7-CD88-50CF-9D0D-E81BDF020E7F.",
"AsyncJob": {
"Completed": true,
"CreateTime": 1706581425000,
"Error": "target folder already exists: XXXX.",
"Id": "1234567691239009XXXX.",
"Progress": 0,
"Response": "632647691239009XXXX.",
"Status": "Running.",
"Type": "Create."
}
}
Códigos de erro
Consulte Códigos de Erro para uma lista completa.
Notas de versão
Consulte Notas de Versão para uma lista completa.