ノード関連パラメーターの説明

ノードの構成はノードタイプによって異なります。本トピックは、CreateTask や UpdateTaskOutput などのタスクノード関連操作について補足的に説明するものです。NodeParam、NodeContent、および GraphParam パラメーターは、すべてのタスクノード関連操作に適用されます。
シングルインスタンス SQL 割り当て、スクリプトコード、Elastic Compute Service (ECS) リモートコマンドなどのノードのみが出力変数を持ちます。出力変数の構成はノードタイプによって異なります。詳細については、UpdateTaskOutput 操作の関連トピックをご参照ください。

シングルインスタンス用 SQL

• DagId

• NodeName

• NodeType: 1

• NodeParam

• GraphParam

• NodeContent:

{
    "dbId":123456, // データベース ID。
    "sql":"/* 現在のノードのデータベース構文を使用して SQL ステートメントを記述 */", // SQL ステートメント。
    "dbType":"lindorm_sql" // データベースタイプ。
}

スクリプト

• DagId

• NodeName

• NodeType: 28

• NodeParam

• GraphParam

• NodeOutput

{
    "outputs":[
        {
            "extractMethod":"json", // 値は JSON 形式。
            "variableName":"var", // 変数名。
            "description":"デモの説明" // 変数の説明。
        }
    ]
}

• NodeContent:

{
    "regionId":"cn-hangzhou", // リージョン ID。
    "gatewayId":"dg-xxxxxxxxxxxxxx", // ゲートウェイ ID。
    "gatewayInstanceId":"dg-node-xxxxxxxxxxxxxx", // ゲートウェイインスタンスの ID。
    "scriptFileName":"demo.sh", // ファイル名。
    "args":[ // 実行パラメーター。
        "-n value",
        "-n1 value1"
    ]
}

ロックフリーなデータ変更

• DagId

• NodeName

• NodeType: 24

• NodeParam

• GraphParam

• NodeContent:

{
    "dbId":123456, // データベース ID。
    "sql":"/* 現在のノードのデータベース構文を使用して SQL ステートメントを記述 */", // SQL ステートメント。
    "dbType":"polardb" // データベースタイプ。
}

シングルインスタンス用 SQL 割り当て

• DagId

• NodeName

• NodeType: 32

• NodeParam

• GraphParam

• NodeOutput:

{
    "outputs":[
        {
            /*
            // 変数抽出設定。
            {
                "row":0, // 行。-1 はすべての行を示す。
                "column":-1, // 列。-1 はすべての列を示す。
                "combiner":"," // デリミタ。すべての行または列を選択する場合、デリミタを指定する必要がある。変数の戻り値は文字列となる。
            }
            */
            "extractMethod":"{\"row\":0,\"column\":-1,\"combiner\":\",\"}", 
            "variableName":"var", // 変数名。
            "description":"デモ用" // 変数の説明。
        }
    ]
}

• NodeContent:

{
    "dbId":123456, // データベース ID。
    "sql":"/* 現在のノードのデータベース構文を使用して SQL ステートメントを記述。SELECT 文のみサポートされる。デフォルトでは、戻り行数の最大値は 30 行。 *", // SQL ステートメント。
    "dbType":"lindorm_cql" // データベースタイプ。
}

依存関係チェック

• DagId

• NodeName

• NodeType: 2

• NodeParam

• GraphParam

• NodeContent:

{
    "dependentDAGId":132, // 依存オブジェクト：タスクフロー。
    "dependentNodeId":"", // 依存オブジェクト：シングルノード。デフォルトでは、依存オブジェクトは指定されたタスクフローとなる。
    "dependentStartTimePattern":"yyyy-MM-dd HH:mm|-2d+0h+0m", // 開始時刻のオフセット。
    "dependentEndTimePattern":"yyyy-MM-dd HH:mm|+1d +0h+0m", // 終了時刻のオフセット。
    "multiSuccessStrategy":2, // インスタンスチェックポリシー。0 は直前のノードが成功することを示す。1 はすべてのノードが成功することを示す。2 は指定されたノードが成功することを示す。
    "multiSuccessStrategyIndex":1 // インスタンスチェックポリシー：ノード x+1 が成功。
}

テーブル内の時間列のステータスチェック

• DagId

• NodeName

• NodeType: 2

• NodeParam

• GraphParam

• NodeContent:

{
    "dependentDAGId":132, // 依存オブジェクト：タスクフロー。
    "dependentNodeId":"", // 依存オブジェクト：シングルノード。デフォルトでは、依存オブジェクトは指定されたタスクフローとなる。
    "dependentStartTimePattern":"yyyy-MM-dd HH:mm|-2d+0h+0m", // 開始時刻のオフセット。
    "dependentEndTimePattern":"yyyy-MM-dd HH:mm|+1d +0h+0m", // 終了時刻のオフセット。
    "multiSuccessStrategy":2, // インスタンスチェックポリシー。0 は直前のノードが成功することを示す。1 はすべてのノードが成功することを示す。2 は指定されたノードが成功することを示す。
    "multiSuccessStrategyIndex":1 // インスタンスチェックポリシー：ノード x+1 が成功。
}

SQL ステータスチェック

• DagId

• NodeName

• NodeType: 25

• NodeParam

• GraphParam

• NodeContent:

{
    "dbId":123456,
    "sql":"/* 現在のノードのデータベース構文を使用して SQL ステートメントを記述*/ \n\n select 1 from abc",
    "dbType":"lindorm_cql"
}