Data Management:CreateTask

Deskripsi parameter terkait konfigurasi node

Konfigurasi node bervariasi berdasarkan tipe node. Dokumen ini merupakan deskripsi tambahan untuk operasi terkait tugas alur kerja, seperti CreateTask dan UpdateTaskOutput. Konfigurasi NodeParam, NodeContent, dan GraphParam bersifat umum.
Saat ini, hanya node tugas "Penugasan SQL instans tunggal", "Kode skrip", dan "Perintah jarak jauh ECS" yang memiliki variabel keluaran, dan metode konfigurasinya berbeda. Untuk informasi lebih lanjut, lihat dokumentasi operasi UpdateTaskOutput.

SQL instans tunggal

• DagId

• NodeName

• NodeType: NORMAL_SQL

• NodeParam

• GraphParam

• NodeContent: Berikut adalah contohnya:

{
    "dbId":123456, // ID database
    "sql":"/* Gunakan sintaks database dari database yang dipilih oleh node saat ini untuk menulis SQL */", // Pernyataan SQL
    "dbType":"lindorm_sql" // Tipe database
}
```.

## Kode skrip
- DagId
- NodeName
- NodeType: AZKABAN_COMMAND_REMOTE
- NodeParam
- GraphParam
- NodeOutput
```Json
{
    "outputs":[
        {
            "extractMethod":"json", // Tetap sebagai json
            "variableName":"var",  // Nama variabel
            "description":"demo desc" // Deskripsi variabel
        }
    ]
}

• NodeContent: Berikut adalah contohnya:

{
    "regionId":"cn-hangzhou", // Wilayah
    "gatewayId":"dg-xxxxxxxxxxxxxx", // ID gateway
    "gatewayInstanceId":"dg-node-xxxxxxxxxxxxxx", // ID instans gateway
    "scriptFileName":"demo.sh", // Nama file
    "args":[ // Parameter runtime
        "-n value",
        "-n1 value1"
    ]
}

Perubahan data tanpa kunci

• DagId

• NodeName

• NodeType: NLOCK_DATA_CORRECT

• NodeParam

• GraphParam

• NodeContent: Berikut adalah contohnya:

{
    "dbId":123456, // ID database
    "sql":"/* Gunakan sintaks database dari database yang dipilih oleh node saat ini untuk menulis SQL */", // Pernyataan SQL
    "dbType":"polardb" // Tipe database
}
```.

## Penugasan SQL instans tunggal
- DagId
- NodeName
- NodeType: SQL_ASSIGNMENT
- NodeParam
- GraphParam
- NodeOutput: Berikut adalah contohnya:
```Json
{
    "outputs":[
        {
            /*
            // Pengaturan ekstraksi variabel
            {
                "row":0, // Baris, -1 menunjukkan semua baris
                "column":-1, // Kolom, -1 menunjukkan semua kolom
                "combiner":"," // Pemisah. Saat semua baris atau semua kolom dipilih, penghubung perlu ditentukan. Nilai pengembalian variabel adalah string
            }
            */
            "extractMethod":"{\"row\":0,\"column\":-1,\"combiner\":\",\"}", 
            "variableName":"var", // Nama variabel
            "description":"For demo" // Deskripsi variabel
        }
    ]
}

• NodeContent: Berikut adalah contohnya:

{
    "dbId":123456, // ID database
    "sql":"/* Gunakan sintaks database dari database yang dipilih oleh node saat ini untuk menulis SQL. Hanya pernyataan SELECT yang didukung, dan jumlah maksimum baris yang dikembalikan secara default adalah 30 */", // Pernyataan SQL
    "dbType":"lindorm_cql" // Tipe database
}
```.

## Pemeriksaan dependensi
- DagId
- NodeName
- NodeType: DEPENDENCY_CHECK
- NodeParam
- GraphParam
- NodeContent: Berikut adalah contohnya:  
```Json
{
    "dependentDAGId":132,  // Dependensi: alur kerja tugas
    "dependentNodeId":"", // Dependensi: node tunggal. Jika dikosongkan, dependensinya adalah alur kerja tugas yang ditentukan
    "dependentStartTimePattern":"yyyy-MM-dd HH:mm|-2d+0h+0m", // Titik pengatur waktu mulai
    "dependentEndTimePattern":"yyyy-MM-dd HH:mm|+1d+0h+0m", // Titik pengatur waktu selesai
    "multiSuccessStrategy":2, //  Kebijakan pemeriksaan instans: 0. Keberhasilan terakhir; 1. Semua berhasil; 2. Keberhasilan tunggal yang ditentukan
    "multiSuccessStrategyIndex":1 // Kebijakan pemeriksaan instans: waktu ke-x+1
}
```.

## Pemeriksaan status kolom waktu tabel
- DagId
- NodeName
- NodeType: TABLE_TIME_CHECK
- NodeParam
- GraphParam
- NodeContent: Berikut adalah contohnya:  
```Json
{
    "dependentDAGId":132,  // Dependensi: alur kerja tugas
    "dependentNodeId":"", // Dependensi: node tunggal. Jika dikosongkan, dependensinya adalah alur kerja tugas yang ditentukan
    "dependentStartTimePattern":"yyyy-MM-dd HH:mm|-2d+0h+0m", // Titik pengatur waktu mulai
    "dependentEndTimePattern":"yyyy-MM-dd HH:mm|+1d+0h+0m", // Titik pengatur waktu selesai
    "multiSuccessStrategy":2, //  Kebijakan pemeriksaan instans: 0. Keberhasilan terakhir; 1. Semua berhasil; 2. Keberhasilan tunggal yang ditentukan
    "multiSuccessStrategyIndex":1 // Kebijakan pemeriksaan instans: waktu ke-x+1
}
```.

## Pemeriksaan status SQL
- DagId
- NodeName
- NodeType: SQL_STATUS_CHECK
- NodeParam
- GraphParam
- NodeContent: Berikut adalah contohnya:  
```Json
{
    "dbId":123456,
    "sql":"/* Gunakan sintaks database dari database yang dipilih oleh node saat ini untuk menulis SQL */ \n\n select 1 from abc",
    "dbType":"lindorm_cql"
}
```.