TiDB Lightning監視

tidb-lightning プロメテウスを介したメトリック収集をサポートします。このドキュメントでは、 TiDB Lightningのモニター構成と監視メトリックについて説明します。

モニター構成

TiDB Lightning を手動でインストールする場合は、以下の手順に従ってください。

tidb-lightningのメトリックは、検出されれば Prometheus によって直接収集できます。 tidb-lightning.tomlのメトリック ポートを設定できます。

[lightning]
# HTTP port for debugging and Prometheus metrics pulling (0 to disable)
pprof-port = 8289

...

Prometheus がサーバーを検出するように設定する必要があります。たとえば、 scrape_configsセクションにサーバーアドレスを直接追加できます。

...
scrape_configs:
  - job_name: 'tidb-lightning'
    static_configs:
      - targets: ['192.168.20.10:8289']

Grafanaダッシュボード

グラファナ Prometheus メトリックをダッシュボードとして視覚化するための Web インターフェースです。

1行目: 速度

場合によっては、インポート速度がゼロに低下し、他の部分が追いつくことがあります。これは正常です。

2行目: 進捗状況

行3: リソース

4行目: 割り当て

5行目: 読み取り速度

いずれかの期間が長すぎる場合は、 TiDB Lightningが使用するディスクが遅すぎるか、I/O でビジー状態であることを示します。

6行目: ストレージ

7行目: インポート速度

監視メトリクス

このセクションでは、 tidb-lightningの監視メトリックについて説明します。

tidb-lightningによって提供されるメトリックは、名前空間lightning_*の下にリストされます。

• lightning_importer_engine (カウンター)

  開いているエンジン ファイルと閉じているエンジン ファイルをカウントします。ラベル:

  • タイプ：
    • open
    • closed

• lightning_idle_workers (ゲージ)

  アイドル状態のワーカーをカウントします。ラベル:

  • 名前：
    • table : table-concurrencyの余り。通常はプロセス終了まで 0 です。
    • index : index-concurrencyの余り。通常はプロセス終了まで 0 です。
    • region : region-concurrencyの余り。通常はプロセス終了まで 0 です。
    • io : io-concurrencyの余り。通常は設定された値（デフォルトは5）に近い。0に近い場合はディスクが遅すぎることを意味する。
    • closed-engine : 閉じられたがまだクリーンアップされていないエンジンの数。通常はインデックス + テーブル同時実行数に近い値です (デフォルトは 8)。0 に近い値は、 TiDB Lightningが TiKV Importer よりも高速であることを意味し、 TiDB Lightning が停止する可能性があります。

• lightning_kv_encoder (カウンター)

  オープンおよびクローズされた KV エンコーダーをカウントします。KV エンコーダーは、SQL INSERTステートメントを KV ペアに変換するメモリ内 TiDB インスタンスです。正常な状況では、ネット値が制限される必要があります。ラベル:

  • タイプ：
    • open
    • closed

• lightning_tables (カウンター)

  処理されたテーブルとそのステータスをカウントします。ラベル:

  • 状態: テーブルの状態。どのフェーズを完了する必要があるかを示します。
    • pending : まだ処理されていません
    • written : すべてのデータがエンコードされて送信されました
    • closed : 対応するエンジンファイルはすべて閉じられています
    • imported : すべてのエンジン ファイルがターゲット クラスターにインポートされました
    • altered_auto_inc : AUTO_INCREMENT IDが変更されました
    • checksum : チェックサムを実行
    • analyzed : 統計分析を実行
    • completed : テーブルは完全にインポートされ、検証されました
  • 結果: 現在のフェーズの結果
    • success : フェーズが正常に完了しました
    • failure : フェーズが失敗しました (完了しませんでした)

• lightning_engines (カウンター)

  処理されたエンジン ファイルの数とそのステータスをカウントします。ラベル:

  • 状態: エンジンの状態。どのフェーズを完了する必要があるかを示します。
    • pending : まだ処理されていません
    • written : すべてのデータがエンコードされて送信されました
    • closed : エンジンファイルが閉じられました
    • imported : エンジン ファイルがターゲット クラスターにインポートされました
    • completed : エンジンが完全にインポートされました
  • 結果: 現在のフェーズの結果
    • success : フェーズが正常に完了しました
    • failure : フェーズが失敗しました (完了しませんでした)

• lightning_chunks (カウンター)

  処理されたチャンクの数とそのステータスをカウントします。ラベル:

  • 状態: チャンクの状態。チャンクがどのフェーズにあるかを示します。
    • estimated : (状態ではない) この値は現在のタスク内のチャンクの合計数を示します
    • pending : 読み込まれているがまだ処理されていない
    • running : データがエンコードされ送信されています
    • finished : チャンク全体が処理されました
    • failed : 処理中にエラーが発生しました

• lightning_import_seconds (ヒストグラム)

  テーブルのインポートに必要な時間のバケット化されたヒストグラム。

• lightning_row_read_bytes (ヒストグラム)

  単一の SQL 行のサイズのバケット化されたヒストグラム。

• lightning_row_encode_seconds (ヒストグラム)

  単一の SQL 行を KV ペアにエンコードするのに必要な時間のバケット化されたヒストグラム。

• lightning_row_kv_deliver_seconds (ヒストグラム)

  1 つの SQL 行に対応する KV ペアのセットを配信するために必要な時間のバケット化されたヒストグラム。

• lightning_block_deliver_seconds (ヒストグラム)

  KV ペアのブロックをインポーターに配信するために必要な時間のバケット化されたヒストグラム。

• lightning_block_deliver_bytes (ヒストグラム)

  インポーターに配信された KV ペアのブロックの非圧縮サイズのバケット化されたヒストグラム。

• lightning_chunk_parser_read_block_seconds (ヒストグラム)

  データ ファイル パーサーがブロックを読み取るために必要な時間のバケット化されたヒストグラム。

• lightning_checksum_seconds (ヒストグラム)

  テーブルのチェックサムを計算するために必要な時間のバケット化されたヒストグラム。

• lightning_apply_worker_seconds (ヒストグラム)

  アイドル状態のワーカーを取得するのに必要な時間のバケット化されたヒストグラム ( lightning_idle_workersゲージも参照)。ラベル:

  • 名前：
    • table
    • index
    • region
    • io
    • closed-engine