ApsaraDB RDS:ステートメントキュー

機能テスト

ステートメントキューは、ステートメントアウトライン機能と連携して、アプリケーションコードのオンライン更新をサポートできます。 詳細については、「ステートメントアウトライン」をご参照ください。 次の例では、Sysbenchを使用してupdate_non_indexスクリプトを実行します。

• テスト環境

  • テーブルのスキーマ

    テーブル 'sbtest1' の作成 (
      'id' int(10) 符号なしNOT NULL AUTO_INCREMENT、
      'k' int (10) unsigned NOT NULL DEFAULT '0',
      'c' char(120) NOT NULL DEFAULT ''、
      'pad'char (60) NOT NULL DEFAULT ''、
      主要なキー ('id') 、
      キー 'k_1 ' ('k')
    エンジン=InnoDB AUTO_INCREMENT=2デフォルト料金=utf8 MAX_ROWS=1000000; 

  • ステートメント

    更新sbtest1 SET c='xyz' WHERE id=0;

  • Script

    . /sysbench \
    -- mysql-host= {$ip} \
    -- mysql-port= {$port} \
    -- mysql-db=test \
    -- test=./sysbench/share/sysbench/update_non_index.lua \
    -- oltp-tables-count=1 \
    -- oltp_table_size=1 \
    -- num-threads=128 \
    -- mysql-user=u0 

• テストの実行手順

  1. オンラインモードでステートメントアウトラインを作成します。

     mysql> CALL DBMS_OUTNN.add_optimizer_outline ('test', '', 1, 
                                                  ' /* + ccl_queue_field(id) */ ' 、
                              "UPDATE sbtest1 SET c='xyz' WHERE id=0");
     クエリOK、影響を受ける0行 (0.01秒) 

  2. 作成したステートメントアウトラインを表示します。

     mysql> dbms_outln.show_outline() を呼び出します。------ -------- ------------------------------------------------------------------ ---------------------------------- -------------------------------- ------------------ --------------------------------------------- +
     | ID | スキーマ | DIGEST | タイプ | スコープ | POS | ヒント | ヒット | オーバーフロー | DIGEST_TEXT |
     ------ -------- ------------------------------------------------------------------ ---------------------------------- -------------------------------- ------------------ --------------------------------------------- +
     | 1 | test | 7b945614749e541e0600753367884acff5df7e7ee2f5fb0af5ea58897910f023 | OPTIMIZER | | 1 | /* + ccl_queue_field(id) */ | 0 | 0 | UPDATE 'sbtest1' SET 'c' = ? どこ 'id' = ? |
     ------ -------- ------------------------------------------------------------------ ---------------------------------- -------------------------------- ------------------ --------------------------------------------- +
     1行セット (0.00秒) 

  3. ステートメントのアウトラインが有効になっていることを確認します。

     mysql> UPDATE sbtest1 SET c='xyz' WHERE id=0について説明します。---- ----------- ---------------------------------------------------------------------------------------------------------------
     | id | select_type | table | partitions | type | possible_keys | key | key_len | ref | rows | filtered | Extra |
     ---- ----------- ---------------------------------------------------------------------------------------------------------------
     | 1 | UPDATE | sbtest1 | NULL | range | PRIMARY | PRIMARY | 4 | const | 1 | 100.00 | Using where |
     ---- ----------- ---------------------------------------------------------------------------------------------------------------
     セットの1列、1警告 (0.00秒)
     
     mysql> 警告を表示します。+ ------ ------ + ----------------------------------------------------------------------------------------------------------------------------- +
     | レベル | コード | メッセージ |
     + ------ ------ + ----------------------------------------------------------------------------------------------------------------------------- +
     | 注 | 1003 | update /* + ccl_queue_field(id) */ 'test'.'sbtest1' set 'test'.'sbtest1'.'c' = 'xyz' ここで ('test'.'sbtest1'.'id' = 0) |
     + ------ ------ + ----------------------------------------------------------------------------------------------------------------------------- +
     1行セット (0.00秒) 

  4. 使用されているステートメントキューのステータスを照会します。

     mysql> dbms_ccl.show_ccl_queue() を呼び出します。------ ------- ------------------- -----------------------------------------
     | ID | TYPE | CONCURRENCY_COUNT | 一致 | 実行中 | 待機中 |
     ------ ------- ------------------- -----------------------------------------
     | 1 | キュー | 64 | 0 | 0 | 0 |
     | 2 | キュー | 64 | 0 | 0 | 0 |
     | 3 | キュー | 64 | 0 | 0 | 0 |
     | 4 | キュー | 64 | 0 | 0 | 0 |
     ------ ------- ------------------- -----------------------------------------
     セットの4列 (0.00秒) 

  5. テストを開始します。

     sysbench \
     -- mysql-host= {$ip} \
     -- mysql-port= {$port} \
     -- mysql-db=test \
     -- test=./sysbench/share/sysbench/update_non_index.lua \
     -- oltp-tables-count=1 \
     -- oltp_table_size=1 \
     -- num-threads=128 \
     -- mysql-user=u0 

  6. テスト結果を確認します。

     mysql> dbms_ccl.show_ccl_queue() を呼び出します。------ ------- ------------------- -----------------------------------------
     | ID | TYPE | CONCURRENCY_COUNT | 一致 | 実行中 | 待機中 |
     ------ ------- ------------------- -----------------------------------------
     | 1 | キュー | 64 | 10996 | 63 | 4 |
     | 2 | キュー | 64 | 0 | 0 | 0 |
     | 3 | キュー | 64 | 0 | 0 | 0 |
     | 4 | キュー | 64 | 0 | 0 | 0 |
     ------ ------- ------------------- -----------------------------------------
     セットの4列 (0.03秒)
     
     mysql> dbms_outln.show_outline() を呼び出します。------ --------- ---------- ---------------------------------------------------------------- --------------------------------------------- +
     | ID | スキーマ | DIGEST | タイプ | スコープ | POS | ヒント | ヒット | オーバーフロー | DIGEST_TEXT |
     ------ --------- ---------- ---------------------------------------------------------------- --------------------------------------------- +
     | 1 | test | xxxxxxxxx | OPTIMIZER | | 1 | /* + ccl_queue_field(id) */ | 115795 | 0 | UPDATE 'sbtest1' SET 'c' = ? どこ 'id' = ? |
     ------ --------- ---------- ---------------------------------------------------------------- --------------------------------------------- +
     1行セット (0.00秒) 

     説明

     クエリ結果に基づいて、合計115,795のステートメントがステートメントアウトラインのルールにヒットし、合計10,996のステートメントがステートメントキューのルールにヒットし、合計63のステートメントが同時に実行され、4つのステートメントがキューで待機しています。

パフォーマンステスト

• テスト環境

  • アプリケーションは、Alibaba Cloud ECS (Elastic Compute Service) インスタンスにデプロイされています。

  • RDSインスタンスは、8 CPUコアと16 GBのメモリを提供し、拡張SSD (ESSD) を使用します。

  • RDSインスタンスはRDS High-availability Editionを実行し、非同期データレプリケーションを使用します。

• テスト ケース

  次のテストケースは、IDが1に設定されているレコードに対して同時更新を実行するために使用されます。

  pathtest = string.match(test, "(.*/)")
  
  pathtestの場合
   dofile(pathtest .. "oltp_common.lua")
  else
   require("oltp_common")
  終了
  
  関数thread_init()
   drv = sysbench.sql.driver()
   con = drv:connect()
  終了
  
  関数event()
   ローカルval_name
   val_name = "'sdnjkmoklvnseajinvijsfdnvkjsnfjvn" .. sb_rand_uniform(1、4096) .. "'"
   query = "UPDATE sbtest1 SET c=" .. val_name .. "WHERE id=1"
   rs = db_query (クエリ)
  終了 

• テスト結果

  ステートメントキュー機能を有効にすると、1秒あたりのクエリ数 (QPS) が大幅に増加し、同時クエリの数が多い場合はその増加が顕著になります。

  説明

  ステートメントキュー機能が無効になっている場合、ストレステストのスレッド数が4,096すると、プライマリ /セカンダリの切り替えが発生します。 その結果、QPSは0となる。