Description des paramètres liés aux nœuds

La configuration d'un nœud varie en fonction du type de nœud. Cette rubrique fournit une description complémentaire des opérations liées aux nœuds de tâche, 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âche.
Seuls les nœuds tels que l'affectation SQL pour instance unique, le code de script et la commande à distance Elastic Compute Service (ECS) possèdent des variables de sortie. Les configurations des variables de sortie varient en fonction du type de nœud. Pour plus d'informations, consultez la rubrique associée à l'opération UpdateTaskOutput.

SQL pour instance unique

• DagId

• NodeName

• NodeType: 1

• NodeParam

• GraphParam

• NodeContent:

{
    "dbId":123456, // L'identifiant de la base de données.
    "sql":"/* Utilisez la syntaxe de la base de données pour le nœud actuel afin de rédiger des instructions SQL */", // L'instruction SQL.
    "dbType":"lindorm_sql" // Le type de base de données.
}

Script

• DagId

• NodeName

• NodeType: 28

• NodeParam

• GraphParam

• NodeOutput

{
    "outputs":[
        {
            "extractMethod":"json", // La valeur est au format JSON.
            "variableName":"var", // Le nom de la variable.
            "description":"description de la démo" // La description de la variable.
        }
    ]
}

• NodeContent:

{
    "regionId":"cn-hangzhou", // L'identifiant de la région.
    "gatewayId":"dg-xxxxxxxxxxxxxx", // L'identifiant de la passerelle.
    "gatewayInstanceId":"dg-node-xxxxxxxxxxxxxx", // L'identifiant de l'instance de passerelle.
    "scriptFileName":"demo.sh", // Le nom du fichier.
    "args":[ // Les paramètres d'exécution.
        "-n value",
        "-n1 value1"
    ]
}

Modification de données sans verrouillage

• DagId

• NodeName

• NodeType: 24

• NodeParam

• GraphParam

• NodeContent:

{
    "dbId":123456, // L'identifiant de la base de données.
    "sql":"/* Utilisez la syntaxe de la base de données pour le nœud actuel afin de rédiger des instructions SQL */", // L'instruction SQL.
    "dbType":"polardb" // Le type de base de données.
}

Affectation SQL pour instance unique

• DagId

• NodeName

• NodeType: 32

• NodeParam

• GraphParam

• NodeOutput:

{
    "outputs":[
        {
            /*
            // Les paramètres d'extraction de variable.
            {
                "row":0, // Lignes. Une valeur de -1 indique toutes les lignes.
                "column":-1, // Colonnes. Une valeur de -1 indique toutes les colonnes.
                "combiner":"," // Le délimiteur. Si vous sélectionnez toutes les lignes ou colonnes, vous devez spécifier un délimiteur. La valeur renvoyée de la variable est une chaîne.
            }
            */
            "extractMethod":"{\"row\":0,\"column\":-1,\"combiner\":\",\"}", 
            "variableName":"var", // Le nom de la variable.
            "description":"Pour la démonstration" // La description de la variable.
        }
    ]
}

• NodeContent:

{
    "dbId":123456, // L'identifiant de la base de données.
    "sql":"/* Utilisez la syntaxe de la base de données pour le nœud actuel afin de rédiger des instructions SQL. Seules les instructions SELECT sont prises en charge. Par défaut, le nombre maximal de lignes renvoyées est de 30. */", // L'instruction SQL.
    "dbType":"lindorm_cql" // Le type de base de données.
}

Vérification des dépendances

• DagId

• NodeName

• NodeType: 2

• NodeParam

• GraphParam

• NodeContent:

{
    "dependentDAGId":132, // Objet de dépendance : flux de tâches.
    "dependentNodeId":"", // Objet de dépendance : un nœud unique. Par défaut, l'objet de dépendance est le flux de tâches spécifié.
    "dependentStartTimePattern":"yyyy-MM-dd HH:mm|-2d+0h+0m", // Le décalage de l'heure de début.
    "dependentEndTimePattern":"yyyy-MM-dd HH:mm|+1d +0h+0m", // Le décalage de l'heure de fin.
    "multiSuccessStrategy":2, // La stratégie de vérification d'instance. Une valeur de 0 indique que le nœud le plus précédent a réussi. Une valeur de 1 indique que tous les nœuds ont réussi. Une valeur de 2 indique que le nœud spécifié a réussi.
    "multiSuccessStrategyIndex":1 // Stratégie de vérification d'instance : le nœud x+1 a réussi.
}

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

• DagId

• NodeName

• NodeType: 2

• NodeParam

• GraphParam

• NodeContent:

{
    "dependentDAGId":132, // Objet de dépendance : flux de tâches.
    "dependentNodeId":"", // Objet de dépendance : un nœud unique. Par défaut, l'objet de dépendance est le flux de tâches spécifié.
    "dependentStartTimePattern":"yyyy-MM-dd HH:mm|-2d+0h+0m", // Le décalage de l'heure de début.
    "dependentEndTimePattern":"yyyy-MM-dd HH:mm|+1d +0h+0m", // Le décalage de l'heure de fin.
    "multiSuccessStrategy":2, // La stratégie de vérification d'instance. Une valeur de 0 indique que le nœud le plus précédent a réussi. Une valeur de 1 indique que tous les nœuds ont réussi. Une valeur de 2 indique que le nœud spécifié a réussi.
    "multiSuccessStrategyIndex":1 // Stratégie de vérification d'instance : le nœud x+1 a réussi.
}

Vérification de l'état SQL

• DagId

• NodeName

• NodeType: 25

• NodeParam

• GraphParam

• NodeContent:

{
    "dbId":123456,
    "sql":"/* Utilisez la syntaxe de la base de données pour le nœud actuel afin de rédiger des instructions SQL */ \n\n select 1 from abc",
    "dbType":"lindorm_cql"
}