Importa um nó de fluxo de trabalho definido pelo FlowSpec e seus nós filhos para o DataStudio.
Descrição da operação
-
Esta operação não oferece suporte à importação de vários fluxos de trabalho. Se mais de um fluxo de trabalho for definido no FlowSpec, todos os fluxos de trabalho, exceto o primeiro, serão ignorados.
-
Esta é uma operação assíncrona. A resposta retorna um objeto de tarefa assíncrona. Chame GetJobStatus para consultar o status de execução da tarefa.
Experimente agora
Testar
Autorização RAM
|
Ação |
Nível de acesso |
Tipo de recurso |
Chave de condição |
Ação dependente |
|
dataworks:* |
update |
*Todos os recursos.
|
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 para esta invocação 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?
Importante 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 já existir, a operação se tornará uma atualização. A operação se tornará uma criação somente quando nenhum ID for especificado ou o ID não existir. |
{ "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" } ] } ] } ] } } |
Elementos de resposta
|
Elemento |
Tipo |
Descrição |
Exemplo |
|
object |
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 de quando a tarefa assíncrona foi criada. |
1706581425000 |
| Error |
string |
A mensagem de erro retornada 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 contém o ID do fluxo de trabalho criado pela 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": false,
"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.