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

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 para diferentes SDKs.

Parâmetros da solicitação

Parâmetro	Tipo	Obrigatório	Exemplo	Descrição
Action	String	Sim	CreateTask	Operação a ser executada. Defina o valor como CreateTask.
Tid	Long	Não	3***	ID do locatário. Nota Para visualizar o ID do locatário, acesse o console do Data Management (DMS) e passe o ponteiro sobre a foto de perfil no canto superior direito. Para mais informações, consulte Visualizar informações sobre o locatário atual.
DagId	Long	Sim	7***	ID do fluxo de tarefas. Chame a operação ListTaskFlow ou ListLhTaskFlowAndScenario para consultar esse ID.
NodeName	String	Sim	zhttest	Nome do nó.
NodeType	String	Sim	36	Tipo do nó. Para mais informações sobre os valores válidos deste parâmetro, consulte Parâmetro NodeType.
NodeContent	String	Não	test	Configuração do nó.
TimeVariables	String	Não	test	Variáveis de tempo do nó.
NodeOutput	String	Não	test	Variáveis de saída do nó.
GraphParam	String	Não	test	Posição do nó no Grafo Acíclico Direcionado (DAG).

Observação sobre parâmetros de configuração de nó

Os parâmetros de configuração variam conforme o tipo de nó. Este tópico complementa a descrição das operações relacionadas a nós de tarefa, como CreateTask e UpdateTaskOutput. Os parâmetros NodeParam, NodeContent e GraphParam aplicam-se a todas essas operações.

Atualmente, apenas nós como SQL de instância única, código de script e comando remoto ECS possuem variáveis de saída. A configuração dessas variáveis difere conforme o tipo de nó. Para mais informações, consulte o tópico sobre a operação UpdateTaskOutput.

Comando remoto SSH

DagId
NodeName
NodeType: 45

NodeParam: variável de tempo do nó.

 
 
     
         
            "name":"var",// Variable name
             
            Variable format
            As shown in the example, the date can have one or more offsets, including minutes (m), hours (h), days (d), weeks (w), months (M), or years (y). The offsets are optional, and you can specify the offsets in a different order than described here.

GraphParam: posição e layout do nó.

 
 
    "x":136, // X-coordinate of the node
    "y":69, // Y-coordinate of the node
    
    /* Layout mode of the node:
    1. Vertical
    2. Horizontal

NodeOutput:

 
 
     
         
            // Variable extraction settings
            "extractMethod":"json", // JSON
            "variableName":"var", // Variable name
            "description":"demo desc" // Variable description

NodeContent:

 
 
  "command":"sh /opt/hello.sh", // Primary command
  "groupId": 123 // ID in cluster management

SQL de instância única

DagId
NodeName
NodeType: 1
NodeParam
GraphParam

NodeContent:

 
 
    "dbId":123456, // Database ID
    "sql":"/* Use the database syntax for the current node to write SQL statements*/", // SQL statement
    "dbType":"lindorm_sql" // Database type

Código de script

DagId
NodeName
NodeType: 28
NodeParam

GraphParam

NodeOutput

 
 
     
         
            "extractMethod":"json", // JSON
            "variableName":"var", // Variable name
            "description":"demo desc" // Variable description

NodeContent:

 
 
    "regionId":"cn-hangzhou", // Region
    "gatewayId":"dg-xxxxxxxxxxxxxx", // Gateway ID
    "gatewayInstanceId":"dg-node-xxxxxxxxxxxxxx", // Gateway instance ID
    "scriptFileName":"demo.sh", // File name
    "args":[ // Running parameters

Alteração de dados sem bloqueio

DagId
NodeName
NodeType: 24
NodeParam
GraphParam

NodeContent:

 
 
    "dbId":123456, // Database ID
    "sql":"/* Use the database syntax for the current node to write SQL statements*/", // SQL statement
    "dbType":"polardb" // Database type

Atribuição SQL de instância única

DagId
NodeName
NodeType: 32
NodeParam
GraphParam

NodeOutput:

 
 
     
         
             
            // Variable extraction settings
             
                "row":0, // Rows. -1 indicates all rows.
                "column":-1, // Columns. -1 indicates all columns.
                "combiner":"," // Delimiter. If you select all rows or columns, you must specify a delimiter. The returned value of the variable is a string.
             
             
              
            "variableName":"var", // Variable name
            "description":"For demo" // Variable description

NodeContent:

 
 
    "dbId":123456, // Database ID
    "sql":"/* Use the database syntax for the current node to write SQL statements. Only SELECT statements are supported. By default, the maximum number of rows returned is 30 *", // SQL statement
    "dbType":"lindorm_cql" // Database type

Verificação de dependência

DagId
NodeName
NodeType: 2
NodeParam
GraphParam

NodeContent:

 
 
    "dependentDAGId":132, // Dependency object: task flow
    "dependentNodeId":"", // Dependency object: a single node. By default, the dependency object is a specified task flow.
    "dependentStartTimePattern":"yyyy-MM-dd HH:mm |-2d +0h +0m", // Start time offset
    "dependentEndTimePattern":"yyyy-MM-dd HH:mm | + 1d +0h +0m", // End time offset
    "multiSuccessStrategy":2, // Instance check policy: 0. The last node successful 1. All nodes successful 2. Specified node successful
    "multiSuccessStrategyIndex":1 // Instance check policy: Node x+1 successful

Verificação de status de coluna temporal em tabela

DagId
NodeName
NodeType: 2
NodeParam
GraphParam

NodeContent:

 
 
    "dependentDAGId":132, // Dependency object: task flow
    "dependentNodeId":"", // Dependency object: a single node. By default, the dependency object is a specified task flow.
    "dependentStartTimePattern":"yyyy-MM-dd HH:mm |-2d +0h +0m", // Start time offset
    "dependentEndTimePattern":"yyyy-MM-dd HH:mm | + 1d +0h +0m", // End time offset
    "multiSuccessStrategy":2, // Instance check policy: 0. The last node successful 1. All nodes successful 2. Specified node successful
    "multiSuccessStrategyIndex":1 // Instance check policy: Node x+1 successful

Verificação de status SQL

DagId
NodeName
NodeType: 25
NodeParam
GraphParam

NodeContent:

 
 
     
    "sql":"/* Use the database syntax for the current node to write SQL statements*/ \n\n select 1 from abc",

Impala

DagId
NodeName
NodeType: 46
NodeParam
GraphParam

NodeContent:

 
 
    // Instance ID
     
    // SQL statement

CDP Hive/SparkSQL

Parâmetros de resposta

Parâmetro	Tipo	Exemplo	Descrição
RequestId	String	CFD8FE00-36D9-4C1B-940D-65A7B73D9066	ID da solicitação. Utilize este ID para consultar logs e solucionar problemas.
ErrorCode	String	InvalidParameterValid	Código de erro retornado se a solicitação falhar.
ErrorMessage	String	InvalidParameterValid	Mensagem de erro retornada se a solicitação falhar.
Success	Boolean	true	Indica se a solicitação foi bem-sucedida. Valores válidos: true: solicitação bem-sucedida. false: falha na solicitação.
NodeId	Long	3***	ID do nó de tarefa retornado após a criação da tarefa.

Exemplos

Solicitações de exemplo

 
 
 
 
&Common request parameters

Respostas de sucesso de exemplo

Formato XML

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

<CreateTaskResponse>
    <RequestId>CFD8FE00-36D9-4C1B-940D-65A7B73D9066</RequestId>
    <ErrorCode>InvalidParameterValid</ErrorCode>
    <ErrorMessage>InvalidParameterValid</ErrorMessage>
    <Success>true</Success>
</CreateTaskResponse>

Formato JSON

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

{
  "RequestId" : "CFD8FE00-36D9-4C1B-940D-65A7B73D9066",
  "ErrorCode" : "InvalidParameterValid",
  "ErrorMessage" : "InvalidParameterValid",
  "Success" : true
}

Códigos de erro

Para obter uma lista de códigos de erro, visite o Centro de Erros de API.