Lindorm：Impor data inkremental dari SLS

Catatan penggunaan

Fitur ini tidak lagi dipublikasikan sejak 16 Juni 2023. Anda tidak dapat menggunakan fitur ini untuk instans Lindorm Tunnel Service (LTS) yang dibeli setelah tanggal tersebut. Namun, jika instans LTS Anda dibeli sebelum 16 Juni 2023, Anda masih dapat menggunakan fitur ini.

Prasyarat

• Anda telah masuk ke halaman aksi LTS.

• Anda telah menambahkan sumber data SQL Lindorm.

• Anda telah menambahkan sumber data Loghub.

Jenis tabel tujuan yang didukung

Tabel yang dibuat menggunakan Lindorm SQL.

Prosedur

1. Pada halaman aksi LTS, klik Import Lindorm/HBase > SLS Real-time Data Replication.

2. Pada halaman SLS Real-time Data Replication, klik Create Task.

3. Tentukan Channel Name kustom, pilih kluster sumber dan tujuan, lalu masukkan nama tabel yang akan disinkronkan atau dimigrasikan.

4. Klik Create. Setelah saluran dibuat, Anda dapat melihat detailnya.

Parameter

{
  "reader": {
    "columns": [
      "__client_ip__",
      "C_Source",
      "id",
      "name"
    ],
    "consumerSize": 2, // Jumlah konsumen yang berlangganan data Loghub. Nilai default: 1.
    "logstore": "LTS-test"
  },
  "writer": {
    "columns": [
      {
        "name": "col1",
        "value": "{{ concat('xx', name) }}" // Ekspresi didukung.
      },
      {
        "name": "col2",
        "value": "__client_ip__" // Pemetaan kolom.
      },
      {
        {
            "isPk":true,// Menentukan apakah ini adalah kunci primer.
            "name":"id",// Anda tidak perlu menentukan keluarga kolom untuk kunci primer.
            "value":"id"
        }
      }
    ]
    "tableName": "default.sls"
  }
}
            

Sintaks Jtwig sederhana didukung.

{
  "name": "hhh",
  "value": "{{ concat(title, id) }}"
}