Descripción de parámetros relacionados con nodos

La configuración de un nodo varía según el tipo de nodo. Este tema es una descripción complementaria de las operaciones relacionadas con nodos de tarea, como CreateTask y UpdateTaskOutput. Los parámetros NodeParam, NodeContent y GraphParam se aplican a todas las operaciones relacionadas con nodos de tarea.
Solo los nodos como asignación SQL de instancia única, código de script y comando remoto de Elastic Compute Service (ECS) tienen variables de salida. Las configuraciones de las variables de salida varían según el tipo de nodo. Para obtener más información, consulte el tema relacionado de la operación UpdateTaskOutput.

SQL para instancia única

• DagId

• NodeName

• NodeType: 1

• NodeParam

• GraphParam

• NodeContent:

{
    "dbId":123456, // El ID de la base de datos.
    "sql":"/* Utilice la sintaxis de base de datos para el nodo actual para escribir sentencias SQL */", // La sentencia SQL.
    "dbType":"lindorm_sql" // El tipo de base de datos.
}

Script

• DagId

• NodeName

• NodeType: 28

• NodeParam

• GraphParam

• NodeOutput

{
    "outputs":[
        {
            "extractMethod":"json", // El valor está en formato JSON.
            "variableName":"var", // El nombre de la variable.
            "description":"demo desc" // La descripción de la variable.
        }
    ]
}

• NodeContent:

{
    "regionId":"cn-hangzhou", // El ID de la región.
    "gatewayId":"dg-xxxxxxxxxxxxxx", // El ID de la puerta de enlace.
    "gatewayInstanceId":"dg-node-xxxxxxxxxxxxxx", // El ID de la instancia de puerta de enlace.
    "scriptFileName":"demo.sh", // El nombre del archivo.
    "args":[ // Los parámetros de ejecución.
        "-n value",
        "-n1 value1"
    ]
}

Cambio de datos sin bloqueo

• DagId

• NodeName

• NodeType: 24

• NodeParam

• GraphParam

• NodeContent:

{
    "dbId":123456, // El ID de la base de datos.
    "sql":"/* Utilice la sintaxis de base de datos para el nodo actual para escribir sentencias SQL */", // La sentencia SQL.
    "dbType":"polardb" // El tipo de base de datos.
}

Asignación SQL para instancia única

• DagId

• NodeName

• NodeType: 32

• NodeParam

• GraphParam

• NodeOutput:

{
    "outputs":[
        {
            /*
            // La configuración de extracción de variables.
            {
                "row":0, // Filas. Un valor de -1 indica todas las filas.
                "column":-1, // Columnas. Un valor de -1 indica todas las columnas.
                "combiner":"," // El delimitador. Si selecciona todas las filas o columnas, debe especificar un delimitador. El valor devuelto de la variable es una cadena.
            }
            */
            "extractMethod":"{\"row\":0,\"column\":-1,\"combiner\":\",\"}", 
            "variableName":"var", // El nombre de la variable.
            "description":"For demo" // La descripción de la variable.
        }
    ]
}

• NodeContent:

{
    "dbId":123456, // El ID de la base de datos.
    "sql":"/* Utilice la sintaxis de base de datos para el nodo actual para escribir sentencias SQL. Solo se admiten sentencias SELECT. De forma predeterminada, el número máximo de filas devueltas es 30. *", // La sentencia SQL.
    "dbType":"lindorm_cql" // El tipo de base de datos.
}

Verificación de dependencias

• DagId

• NodeName

• NodeType: 2

• NodeParam

• GraphParam

• NodeContent:

{
    "dependentDAGId":132, // Objeto de dependencia: flujo de tareas.
    "dependentNodeId":"", // Objeto de dependencia: un solo nodo. De forma predeterminada, el objeto de dependencia es el flujo de tareas especificado.
    "dependentStartTimePattern":"yyyy-MM-dd HH:mm|-2d+0h+0m", // El desplazamiento de la hora de inicio.
    "dependentEndTimePattern":"yyyy-MM-dd HH:mm|+1d +0h+0m", // El desplazamiento de la hora de finalización.
    "multiSuccessStrategy":2, // La política de verificación de instancias. Un valor de 0 especifica que el nodo anterior más reciente se ejecutó correctamente. Un valor de 1 especifica que todos los nodos se ejecutaron correctamente. Un valor de 2 especifica que el nodo indicado se ejecutó correctamente.
    "multiSuccessStrategyIndex":1 // Política de verificación de instancias: El nodo x+1 se ejecutó correctamente.
}

Verificación de estado de una columna de tiempo en una tabla

• DagId

• NodeName

• NodeType: 2

• NodeParam

• GraphParam

• NodeContent:

{
    "dependentDAGId":132, // Objeto de dependencia: flujo de tareas.
    "dependentNodeId":"", // Objeto de dependencia: un solo nodo. De forma predeterminada, el objeto de dependencia es el flujo de tareas especificado.
    "dependentStartTimePattern":"yyyy-MM-dd HH:mm|-2d+0h+0m", // El desplazamiento de la hora de inicio.
    "dependentEndTimePattern":"yyyy-MM-dd HH:mm|+1d +0h+0m", // El desplazamiento de la hora de finalización.
    "multiSuccessStrategy":2, // La política de verificación de instancias. Un valor de 0 especifica que el nodo anterior más reciente se ejecutó correctamente. Un valor de 1 especifica que todos los nodos se ejecutaron correctamente. Un valor de 2 especifica que el nodo indicado se ejecutó correctamente.
    "multiSuccessStrategyIndex":1 // Política de verificación de instancias: El nodo x+1 se ejecutó correctamente.
}

Verificación de estado SQL

• DagId

• NodeName

• NodeType: 25

• NodeParam

• GraphParam

• NodeContent:

{
    "dbId":123456,
    "sql":"/* Utilice la sintaxis de base de datos para el nodo actual para escribir sentencias SQL*/ \n\n select 1 from abc",
    "dbType":"lindorm_cql"
}