TiDB Cloud
TiDB Self-Managed
Learning Center
お問い合わせ

TiFlashクエリ結果の実体化

このドキュメントでは、 TiFlashクエリの結果を指定された TiDB テーブルにINSERT INTO SELECTのトランザクションで保存する方法を紹介します。

v6.5.0 以降、TiDB はTiFlashクエリ結果のテーブルへの保存、つまりTiFlashクエリ結果の実体化をサポートしています。 INSERT INTO SELECTステートメントの実行中に、TiDB がSELECTサブクエリをTiFlashにプッシュ ダウンすると、 TiFlashクエリの結果をINSERT INTO句で指定された TiDB テーブルに保存できます。 v6.5.0 より前のバージョンの TiDB では、 TiFlashクエリの結果は読み取り専用であるため、 TiFlashクエリの結果を保存する場合は、アプリケーション レベルから取得し、別のトランザクションまたはプロセスで保存する必要があります。

ノート：

  • デフォルト ( tidb_allow_mpp = ON ) では、TiDB オプティマイザーは、クエリ コストに基づいて、クエリを TiKV またはTiFlashにプッシュ ダウンすることをインテリジェントに選択します。クエリがTiFlashにプッシュされるようにするには、システム変数tidb_enforce_mppをONに設定します。
  • 実験的段階では、この機能はデフォルトで無効になっています。この機能を有効にするには、システム変数tidb_enable_tiflash_read_for_write_stmtからONを設定します。

INSERT INTO SELECTの構文は次のとおりです。

INSERT [LOW_PRIORITY | HIGH_PRIORITY] [IGNORE]
    [INTO] tbl_name
    [PARTITION (partition_name [, partition_name] ...)]
    [(col_name [, col_name] ...)]
    SELECT ...
    [ON DUPLICATE KEY UPDATE assignment_list]value:
    {expr | DEFAULT}

assignment:
    col_name = valueassignment_list:
    assignment [, assignment] ...

たとえば、次のINSERT INTO SELECTステートメントを使用して、 SELECT句のテーブルt1からのクエリ結果をテーブルt2に保存できます。

INSERT INTO t2 (name, country)
SELECT app_name, country FROM t1;

  • 効率的な BI ソリューション

    多くの BI アプリケーションでは、分析クエリ要求は非常に重いものです。たとえば、多数のユーザーが同時にレポートにアクセスして更新する場合、BI アプリケーションは多数の同時クエリ要求を処理する必要があります。この状況に効果的に対処するために、 INSERT INTO SELECTを使用して、レポートのクエリ結果を TiDB テーブルに保存できます。その後、エンド ユーザーは、レポートが更新されたときに結果テーブルから直接データをクエリできます。これにより、計算と分析を何度も繰り返す必要がなくなります。同様に、ヒストリカル解析結果を保存することで、長時間のヒストリカルデータ解析の計算量をさらに削減できます。たとえば、毎日の販売利益を分析するために使用されるレポートAある場合、 INSERT INTO SELECTを使用してレポートAの結果を結果テーブルTに保存できます。次に、レポートBを生成して過去 1 か月の売上利益を分析する必要がある場合は、表Tの日次分析結果を直接使用できます。これにより、計算量が大幅に削減されるだけでなく、クエリの応答速度が向上し、システムの負荷が軽減されます。

  • TiFlashを使用したオンライン アプリケーションの提供

    TiFlashでサポートされる同時リクエストの数は、データの量とクエリの複雑さによって異なりますが、通常は 100 QPS を超えません。 INSERT INTO SELECTを使用してTiFlashクエリ結果を保存し、クエリ結果テーブルを使用して高度な同時オンライン リクエストをサポートできます。結果テーブルのデータは、バックグラウンドで低頻度 (たとえば、0.5 秒間隔) で更新できます。これは、 TiFlash の同時実行制限を十分に下回っていますが、データの鮮度を高いレベルで維持しています。

実行プロセス

  • INSERT INTO SELECTステートメントの実行中、 TiFlash は最初にSELECT節のクエリ結果をクラスター内の TiDBサーバーに返し、次に結果をターゲット テーブルに書き込みます。ターゲット テーブルには、 TiFlashレプリカを含めることができます。
  • INSERT INTO SELECTステートメントを実行すると、 ACIDプロパティが保証されます。

制限

  • INSERT INTO SELECTステートメントの TiDBメモリ制限は、システム変数tidb_mem_quota_queryを使用して調整できます。 v6.5.0 以降では、 txn-total-size-limitを使用してトランザクションメモリサイズを制御することはお勧めしません。

    詳細については、 TiDBメモリ制御を参照してください。

  • TiDB にはINSERT INTO SELECTステートメントの同時実行性に厳密な制限はありませんが、次のプラクティスを考慮することをお勧めします。

    • 「書き込みトランザクション」が 1 GiB に近いなど、大きい場合は、同時実行数を 10 以下に制御することをお勧めします。
    • 「書き込みトランザクション」が 100 MiB 未満などの小さい場合は、同時実行数を 30 以下に制御することをお勧めします。
    • テスト結果と特定の状況に基づいて同時実行数を決定します。

例

データ定義:

CREATE TABLE detail_data (
    ts DATETIME,                -- Fee generation time
    customer_id VARCHAR(20),    -- Customer ID
    detail_fee DECIMAL(20,2));  -- Amount of fee

CREATE TABLE daily_data (
    rec_date DATE,              -- Date when data is collected
    customer_id VARCHAR(20),    -- Customer ID
    daily_fee DECIMAL(20,2));   -- Amount of fee for per day

ALTER TABLE detail_data SET TIFLASH REPLICA 1;
ALTER TABLE daily_data SET TIFLASH REPLICA 1;

-- ... (detail_data table continues updating)
INSERT INTO detail_data(ts,customer_id,detail_fee) VALUES
('2023-1-1 12:2:3', 'cus001', 200.86),
('2023-1-2 12:2:3', 'cus002', 100.86),
('2023-1-3 12:2:3', 'cus002', 2200.86),
('2023-1-4 12:2:3', 'cus003', 2020.86),
('2023-1-5 12:2:3', 'cus003', 1200.86),
('2023-1-6 12:2:3', 'cus002', 20.86);

毎日の分析結果を保存:

SET @@tidb_enable_tiflash_read_for_write_stmt=ON;

INSERT INTO daily_data (rec_date, customer_id, daily_fee)
SELECT DATE(ts), customer_id, sum(detail_fee) FROM detail_data WHERE DATE(ts) = CURRENT_DATE() GROUP BY DATE(ts), customer_id;

毎日の分析データに基づいて毎月のデータを分析します。

SELECT MONTH(rec_date), customer_id, sum(daily_fee) FROM daily_data GROUP BY MONTH(rec_date), customer_id;

上記の例では、日次分析結果を具体化し、日次結果表に保存します。これに基づいて、月次データ分析が高速化され、データ分析効率が向上します。

このページは役に立ちましたか？