ApsaraDB for HBase:ログサービスからの増分データのインポート

注記

Lindorm Tunnel Service (LTS) は、2023年3月10日以降、Log Service からの増分データインポートをサポートしなくなりました。 2023年3月10日以降に LTS を購入した場合、この機能は使用できなくなります。 2023年3月10日より前に LTS を購入した場合は、引き続きこの機能を使用できます。

前提条件

• LTSを購入済みであること。 LTSコンソールのアカウント名とパスワードを設定し、LTSコンソールにログオンしていること。

• LTSコンソールでApsaraDB for HBaseデータソースを追加済みであること。

• LTSコンソールでloghub（SLS）データソースを追加済みであること。

サポートされているエディション

• Kerberosが無効になっているセルフマネージド HBase V1.xおよびV2.x。

• Alibaba Cloud E-MapReduce（EMR）HBase。

• クラスターモードで実行されているApsaraDB for HBase Standard EditionおよびApsaraDB for HBase Performance-enhanced Edition。 シングルノードモードのApsaraDB for HBaseはサポートされていません。

タスクの作成

1. LTSコンソールの左側のナビゲーションペインで、[データのインポート] > [SLS増分インポート] を選択します。

2. [新しいジョブの作成] をクリックします。 [ソースクラスター] ドロップダウンリストから、[SLS] を選択します。 [ターゲットクラスター（hbase、phoenix）] ドロップダウンリストから、HBaseを選択します。 テーブルマッピングフィールドを設定します。

3. [作成] をクリックします。 ジョブが作成されると、[SLS増分インポート]ページでジョブの詳細を表示できます。

テーブルマッピングパラメーターの説明

{
  "reader": {
    "columns": [
      "__client_ip__",
      "C_Source",
      "id",
      "name"
    ],
    "consumerSize": 2, // loghub (SLS) データをサブスクライブするコンシューマーの数を指定します。デフォルト値：1。
    "logstore": "bds-test"
  },
  "writer": {
    "columns": [
      {
        "name": "f:col1",
        "value": "{{ concat('xx', name) }}" // サポートされている式を指定します。
      },
      {
        "name": "f:col2",
        "value": "__client_ip__" // マップされた列名を指定します。
      },
      {
        "name": "f:*" // 一致しない列はデフォルトの一致設定に従うように指定します。
      }
    ],
    "rowkey": {
      "value": "{{ concat('idg',id) }}"
    },
    "tableName": "default:sls"
  }
}

• 次の単純な式を使用できます：

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