Description of node-related parameters

The configuration of a node varies based on the node type. This topic is a supplementary description of task node-related operations, such as CreateTask and UpdateTaskOutput. The NodeParam, NodeContent, and GraphParam parameters apply to all task node-related operations.
Only nodes such as single-instance SQL assignment, script code, and Elastic Compute Service (ECS) remote command have output variables. The configurations of output variables vary based on the node type. For more information, see the related topic of the UpdateTaskOutput operation.

SQL for single instance

• DagId

• NodeName

• NodeType: 1

• NodeParam

• GraphParam

• NodeContent:

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

Script

• DagId

• NodeName

• NodeType: 28

• NodeParam

• GraphParam

• NodeOutput

{
    "outputs":[
        {
            "extractMethod":"json", // The value is in the JSON format.
            "variableName":"var", // The name of the variable.
            "description":"demo desc" // The description of the variable.
        }
    ]
}

• NodeContent:

{
    "regionId":"cn-hangzhou", // The region ID.
    "gatewayId":"dg-xxxxxxxxxxxxxx", // The gateway ID.
    "gatewayInstanceId":"dg-node-xxxxxxxxxxxxxx", // The ID of the gateway instance.
    "scriptFileName":"demo.sh", // The file name.
    "args":[ // The running parameters.
        "-n value",
        "-n1 value1"
    ]
}

Lock-free data change

• DagId

• NodeName

• NodeType: 24

• NodeParam

• GraphParam

• NodeContent:

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

SQL assignment for single instance

• DagId

• NodeName

• NodeType: 32

• NodeParam

• GraphParam

• NodeOutput:

{
    "outputs":[
        {
            /*
            // The variable extraction settings.
            {
                "row":0, // Rows. A value of -1 indicates all rows.
                "column":-1, // Columns. A value of -1 indicates all columns.
                "combiner":"," // The delimiter. If you select all rows or columns, you must specify a delimiter. The returned value of the variable is a string.
            }
            */
            "extractMethod":"{\"row\":0,\"column\":-1,\"combiner\":\",\"}", 
            "variableName":"var", // The name of the variable.
            "description":"For demo" // The description of the variable.
        }
    ]
}

• NodeContent:

{
    "dbId":123456, // The 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. *", // The SQL statement.
    "dbType":"lindorm_cql" // The database type.
}

Dependency check

• 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 the specified task flow.
    "dependentStartTimePattern":"yyyy-MM-dd HH:mm|-2d+0h+0m", // The offset of the start time.
    "dependentEndTimePattern":"yyyy-MM-dd HH:mm|+1d +0h+0m", // The offset of the end time.
    "multiSuccessStrategy":2, // The instance check policy. A value of 0 specifies that the most previous node is successful. A value of 1 specifies that all nodes are successful. A value of 2 specifies that the specified node is successful
    "multiSuccessStrategyIndex":1 // Instance check policy: The node x+1 is successful.
}

Status check of a time column in a 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 the specified task flow.
    "dependentStartTimePattern":"yyyy-MM-dd HH:mm|-2d+0h+0m", // The offset of the start time.
    "dependentEndTimePattern":"yyyy-MM-dd HH:mm|+1d +0h+0m", // The offset of the end time.
    "multiSuccessStrategy":2, // The instance check policy. A value of 0 specifies that the most previous node is successful. A value of 1 specifies that all nodes are successful. A value of 2 specifies that the specified node is successful
    "multiSuccessStrategyIndex":1 // Instance check policy: The node x+1 is successful.
}

SQL status check

• DagId

• NodeName

• NodeType: 25

• NodeParam

• GraphParam

• NodeContent:

{
    "dbId":123456,
    "sql":"/* Use the database syntax for the current node to write SQL statements*/ \n\n select 1 from abc",
    "dbType":"lindorm_cql"
}