CreateTask - - Centre de documentation Alibaba Cloud

Débogage

OpenAPI Explorer calcule automatiquement la valeur de la signature. Pour plus de commodité, nous vous recommandons d'appeler cette opération dans OpenAPI Explorer. OpenAPI Explorer génère dynamiquement l'exemple de code pour différents SDK.

Paramètres de requête

Paramètre	Type	Obligatoire	Exemple	Description
Action	String	Oui	CreateTask	L'opération que vous souhaitez effectuer. Définissez la valeur sur CreateTask.
Tid	Long	Non	3***	ID du locataire. Remarque Pour afficher l'ID du locataire, accédez à la console Data Management (DMS) et placez le pointeur sur la photo de profil dans le coin supérieur droit. Pour plus d'informations, consultez Afficher les informations sur le locataire actuel.
DagId	Long	Oui	7***	ID du flux de tâches. Vous pouvez appeler l'opération ListTaskFlow ou ListLhTaskFlowAndScenario pour interroger l'ID du flux de tâches.
NodeName	String	Oui	zhttest	Nom du nœud.
NodeType	String	Oui	36	Type du nœud. Pour plus d'informations sur les valeurs valides de ce paramètre, consultez Paramètre NodeType.
NodeContent	String	Non	test	Configuration du nœud.
TimeVariables	String	Non	test	Variables temporelles du nœud.
NodeOutput	String	Non	test	Variables de sortie du nœud.
GraphParam	String	Non	test	Position du nœud sur le graphe acyclique dirigé (DAG).

Remarque sur les paramètres de configuration des nœuds

Les paramètres de configuration des nœuds varient selon les types de nœuds. Cette rubrique constitue une description complémentaire des opérations liées aux nœuds de tâches, telles que CreateTask et UpdateTaskOutput. Les paramètres NodeParam, NodeContent et GraphParam s'appliquent à toutes les opérations liées aux nœuds de tâches.

Actuellement, seuls certains nœuds, tels que SQL sur instance unique, code de script et commande distante ECS, disposent de variables de sortie. La configuration des variables de sortie diffère selon le type de nœud. Pour plus d'informations, consultez la rubrique relative à l'opération UpdateTaskOutput.

Commande distante SSH

DagId
NodeName
NodeType : 45

NodeParam : variable temporelle du nœud.

 
 
     
         
            "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 : position et mise en page du nœud.

 
 
    "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 sur instance unique

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

Code 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

Modification de données sans verrouillage

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

Affectation SQL sur instance unique

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

Vérification des dépendances

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

Vérification de l'état d'une colonne temporelle dans une table

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

Vérification de l'état 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

Paramètres de réponse

Paramètre	Type	Exemple	Description
RequestId	String	CFD8FE00-36D9-4C1B-940D-65A7B73D9066	ID de la requête. Vous pouvez utiliser cet ID pour interroger les journaux et résoudre les problèmes.
ErrorCode	String	InvalidParameterValid	Code d'erreur renvoyé si la requête a échoué.
ErrorMessage	String	InvalidParameterValid	Message d'erreur renvoyé si la requête a échoué.
Success	Boolean	true	Indique si la requête a abouti. Valeurs possibles : true : la requête a abouti. false : la requête a échoué.
NodeId	Long	3***	ID du nœud de tâche renvoyé lors de la création de la tâche.

Exemples

Exemple de requête

 
 
 
 
&Common request parameters

Exemple de réponse en cas de succès

Format 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>

Format JSON

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

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

Codes d'erreur

Pour obtenir la liste des codes d'erreur, visitez le Centre d'erreurs de l'API.