Lindorm:SLS からの増分データのインポート

使用上の注意

この機能は 2023 年 6 月 16 日に非公開になりました。この日以降に購入された Lindorm Tunnel Service (LTS) インスタンスでは、この機能を使用できません。LTS インスタンスが 2023 年 6 月 16 日より前に購入された場合は、引き続きこの機能を使用できます。

前提条件

• LTS 操作ページにログオンしている。

• Lindorm SQL データソースを追加している。

• Loghub データソースを追加している。

サポートされている宛先テーブルの種類

Lindorm SQL を使用して作成されたテーブル。

手順

1. LTS 操作ページで、[Import Lindorm/HBase] [>] [SLS Real-time Data Replication] をクリックします。

2. [SLS Real-time Data Replication] ページで、[Create Task] をクリックします。

3. カスタムの [Channel Name] を指定し、ソースクラスターと宛先クラスターを選択してから、同期または移行するテーブルを入力します。

4. [Create] をクリックします。チャンネルが作成されると、その詳細を表示できます。

パラメーター

{
  "reader": {
    "columns": [
      "__client_ip__",
      "C_Source",
      "id",
      "name"
    ],
    "consumerSize": 2, // Loghub データをサブスクライブするコンシューマーの数。デフォルト値: 1。
    "logstore": "LTS-test"
  },
  "writer": {
    "columns": [
      {
        "name": "col1",
        "value": "{{ concat('xx', name) }}" // 式がサポートされています。
      },
      {
        "name": "col2",
        "value": "__client_ip__" // カラムマッピング。
      },
      {
        {
            "isPk":true,// これがプライマリキーであるかどうかを指定します。
            "name":"id",// プライマリキーのカラムファミリーを指定する必要はありません。
            "value":"id"
        }
      }
    ]
    "tableName": "default.sls"
  }
}
            

単純な Jtwig 構文 がサポートされています。

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