ApsaraDB RDS:rds_ccl拡張を使用してSQLスロットリングを実行する

シナリオ

次の構文の関数は、プライマリRDSインスタンスでのみ呼び出して、SQLスロットリングルールを作成できます。

構文

構文1: 指定されたSQL文でスロットリングを実行します。

SELECT rds_add_ccl_rule (
query_string varchar,
node_tag int,
max_concurrency int,
max_waiting int,
is_enabledブール値,
コメントvarchar, -- オプション
search_path varchar -- オプション
); 

構文2: query_idパラメーターに基づいてスロットリングを実行します。

SELECT rds_add_ccl_rule_with_query_id (
  query_id bigint,
  node_tag int,
  max_concurrency int,
  max_waiting int,
  is_enabledブール値,
  query_string varchar, -- オプション
  コメントvarchar-オプション
); 

Parameters

-- $$を使用してSQL文をラップします。
$$SELECT * からmy_table ;$$

-- SQL文に $$が含まれている場合は、$ccl $を使用してSQL文をラップします。
$ccl$SELECT * FROM my_table WHERE my_column = $$hello $$;$ ccl$ 

使用上の注意

• 構文1では、commentとsearch_pathを引用符のペア ('') に設定できます。 パラメーターをNULLに設定すると、関数は操作を実行せず、値を直接返します。 引用符のペアは空の文字列を示します。

• 構文2では、次の点に注意してください。

  • query_stringとcommentを引用符のペア ('') に設定できます。 パラメーターをNULLに設定すると、関数は操作を実行せず、値を直接返します。 引用符のペアは空の文字列を示します。

  • query_idとquery_stringに他の値を設定した場合、AliPGは指定したquery_idに基づいてSQLスロットリングを実行します。

• この関数はccl_idを返します。 ccl_idは、現在のデータベース内のSQLスロットリングルールの一意の識別子です。

例

ccl_tblテーブルは、プライマリRDSインスタンスのccl_testデータベースに作成されます。 RDSインスタンスの次の要件を満たすSQLスロットリングルールを作成できます。

1. SELECT * FROM ccl_tblステートメントはすべてスロットリングされます。 この例では、query_idは1に設定されています。

2. このタイプの最大3つのSQL文を同時に実行できます。

3. このタイプの最大2つのSQL文が待機状態のままになります。

4. ルールは作成後すぐに有効になります。

• 構文1

  SELECT rds_add_ccl_rule (
    $$SELECT * FROM ccl_tbl $;, -- $$を使用してスロットルされ、ラップされるSQL文。
    1、-- SQLスロットリングはプライマリRDSインスタンスでのみ実行されます。
    3、-このタイプの最大3つのSQLステートメントを同時に実行できます。
    2、-このタイプの最大2つのSQLステートメントは待機状態にとどまることができます。
    true, -- ルールは作成後すぐに有効になります。
    'limit constant select', -- ルールの説明。
    ''-- search_pathのデフォルト値が使用されます。
  );

• 構文2

  SELECT rds_add_ccl_rule_with_query_id (
    1、スロットルするSQL文の -- query_id。
    1、-- SQLスロットリングはプライマリRDSインスタンスでのみ実行されます。
    3、-このタイプの最大3つのSQLステートメントを同時に実行できます。
    2、-このタイプの最大2つのSQLステートメントは待機状態にとどまることができます。
    true, -- ルールは作成後すぐに有効になります。
    ''-SQL文のテキスト。 この例では、このパラメーターは指定されていません。	
    'limit constant select', -- ルールの説明。
  );

シナリオ

次の構文のステートメントは、プライマリRDSインスタンスまたは読み取り専用RDSインスタンスで実行して、作成されたSQLスロットリングルールを照会できます。

構文

• RDSインスタンス上のすべてのデータベースに対して作成されたSQLスロットリングルールを照会します。

  SELECT * FROM rds_enabled_ccl_rule;

  説明

  クエリ結果では、querice_stringとcommentの値は表示制限により切り捨てられ、各値の最初の200文字のみが表示されます。 完全な値を表示するには、SELECT * FROM rds_show_current_db_ccl_rule(); ステートメントを実行します。

• RDSインスタンスの現在のデータベースに対して作成されたSQLスロットリングルールを照会します。

  SELECT * FROM rds_show_current_db_ccl_rule();

シナリオ

次の構文の関数は、プライマリRDSインスタンスでのみ呼び出すことができ、次の操作で使用できます。

• SQLスロットリングルールを作成するときにis_enabledがfalseに設定されている場合、この関数を呼び出してルールを有効にできます。

• この関数を呼び出して、無効なSQLスロットリングルールを有効にします。

構文

SELECT rds_enable_ccl_rule(ccl_id int);

Parameters

使用上の注意

なし

例

SELECT rds_enable_ccl_rule(1);

シナリオ

次の構文の関数は、プライマリRDSインスタンスまたは読み取り専用RDSインスタンスで呼び出して、SQLスロットリングルールをロードできます。 ロードされたルールのみを使用してSQLスロットリングを実行できます。

この関数は、次のシナリオで使用できます。

• プライマリRDSインスタンス:

  • SQLスロットリングルールの作成時にis_enabledがtrueに設定されている場合、ルールは自動的にプライマリRDSインスタンスにロードされます。 人間の介入は必要ありません。

  • SQLスロットリングルールを作成するときにis_enabledがfalseに設定され、rds_enable_ccl_rule関数が呼び出されてルールが有効化されると、ルールは自動的にプライマリRDSインスタンスにロードされます。 人間の介入は必要ありません。

  • プライマリRDSインスタンスが再起動された場合、この関数を呼び出してSQLスロットリングルールを手動でロードする必要があります。

• 読み取り専用RDSインスタンス:

  読み取り専用RDSインスタンスでSQLスロットリングルールを有効にする場合は、SQLスロットリングルールを作成するときにnode_tagを2または3に設定し、読み取り専用RDSインスタンスで関数を呼び出してルールをロードする必要があります。

構文

SELECT rds_load_ccl_rule(ccl_id int);

Parameters

使用上の注意

• プライマリRDSインスタンスでrds_add_ccl_rule関数を呼び出し、node_tagを2または3に設定してルールを作成した後にのみ、SQLスロットリングルールを読み取り専用RDSインスタンスにロードできます。

• 無効なルールはロードできません。 無効化されたルールを読み取り専用RDSインスタンスにロードする場合は、まずプライマリRDSインスタンスで無効化されたルールを有効にする必要があります。 詳細については、「SQLスロットリングルールの有効化」をご参照ください。

例

SELECT rds_enable_ccl_rule(1);

シナリオ

次の構文の関数は、プライマリRDSインスタンスでのみ呼び出して、SQLスロットリングルールのmax_concurrencyとmax_waitingの値を変更できます。

構文

SELECT rds_update_ccl_rule ()
ccl_id int,
new_max_concurrency int、new_max_waiting int
); 

Parameters

使用上の注意

• SQLスロットリングルールを変更すると、その変更はすぐに有効になります。

• SQLスロットリングルールでは、同時SQL文の最大数と待機中のSQL文の最大数を変更できます。

例

SELECT rds_update_ccl_rule ()
 2、-- ccl_id
 4、-同時SQL文の新しい最大数は4です。
 5 -- 待機中のSQL文の新しい最大数は5です。
);

シナリオ

次の構文の関数は、プライマリRDSインスタンスでのみ呼び出して、SQLスロットリングルールを無効にできます。 無効なルールは、SQLスロットリングに使用できなくなりました。

構文

• SQLスロットリングルールを無効にします。

  SELECT rds_disable_ccl_rule(ccl_id int);

• データベースのすべてのSQLスロットリングルールを無効にします。

  SELECT rds_disable_all();

Parameters

使用上の注意

• 無効なルールはロードできません。 無効化されたルールを読み取り専用RDSインスタンスにロードする場合は、まずプライマリRDSインスタンスで無効化されたルールを有効にする必要があります。 詳細については、「SQLスロットリングルールの有効化」をご参照ください。

• SQLスロットリングルールを無効にすると、ルールはプライマリRDSインスタンスから自動的にアンロードされ、SQLスロットリングに使用できなくなります。

例

SELECT rds_disable_ccl_rule(1);

シナリオ

次の構文の関数は、プライマリRDSインスタンスまたは読み取り専用RDSインスタンスで呼び出して、SQLスロットリングルールをアンロードできます。 アンロードされたルールは、SQLスロットリングの実行に使用できなくなりました。

この関数は、次のシナリオで使用できます。

• プライマリRDSインスタンス:

  • プライマリRDSインスタンスでrds_disable_ccl_ruleまたはrds_disable_all関数を呼び出してSQLスロットリングルールを無効にすると、ルールはプライマリRDSインスタンスから自動的にアンロードされます。 人間の介入は必要ありません。

  • プライマリRDSインスタンスでrds_del_ccl_rule関数を呼び出してSQLスロットリングルールを削除すると、ルールは自動的にプライマリRDSインスタンスからアンロードされます。 人間の介入は必要ありません。

  • この関数を呼び出して、プライマリRDSインスタンスからルールをアンロードすることもできます。

• 読み取り専用RDSインスタンス:

  読み取り専用RDSインスタンスのSQLスロットリングルールを無効にする場合は、読み取り専用RDSインスタンスでこの関数を呼び出すことができます。

構文

SELECT rds_unload_ccl_rule(ccl_id int、db_name varcharデフォルト '');

Parameters

使用上の注意

SQLスロットリングルールがアンロードされると、そのルールを使用してSQLスロットリングを実行できなくなります。 ルールを再利用する場合は、ルールをリロードする必要があります。 詳細については、「SQLスロットリングルールの読み込み」をご参照ください。

例

SELECT rds_unload_ccl_rule(1,'');

シナリオ

次の構文の関数は、プライマリRDSインスタンスでのみ呼び出して、SQLスロットリングルールを削除できます。 ルールが削除されると、プライマリRDSインスタンスから自動的にアンロードされます。

構文

SELECT rds_del_ccl_rule(ccl_id int);

Parameters

使用上の注意

なし

例

SELECT rds_del_ccl_rule(1);

次の結果を返すことができます。

rds_del_ccl_rule
----------------------
 -7851264404688445170
(1行) 

• query_idは、PostgreSQLのSQL文の特別な識別子です。 同じタイプのSQL文は、同じquery_id値を持ちます。

  例：

  -次のステートメントは同じquery_id値を持ちます。
  SELECT * FROM tbl WHERE a = 1;
  SELECT * FROM tbl WHERE a = 2; 

• query_idには、SQL文のオブジェクトに関するoid情報が含まれます。 異なるデータベースで同じ名前のテーブルは、同じオブジェクトではありません。 異なるスキーマで同じ名前のテーブルは、同じオブジェクトではありません。 SQL文を使用して異なるデータベース内の異なるオブジェクトをクエリする場合、SQL文のデータベース内のquery_id値は異なります。

• SQL文を使用してグローバルテーブルまたはグローバル関数をクエリする場合、SQL文は異なるデータベースで同じquery_id値を持ちます。

  • 例1: pg_databaseはグローバルテーブルです。 異なるデータベースで同じステートメントを実行すると、異なるデータベースで同じquery_id値が使用されます。

    • ccl_testデータベースで次のステートメントを実行します。

      SELECT rds_get_query_id($$SELECT * FROM pg_database $;$);

      次の結果を返すことができます。

      rds_get_query_id
      ----------------------
       -8733244708994363681
      (1行) 

    • ccl_test2データベースで次のステートメントを実行します。

      SELECT rds_get_query_id($$SELECT * FROM pg_database $;$);

      次の結果を返すことができます。

      rds_get_query_id
      ----------------------
       -8733244708994363681
      (1行) 

  • 例2: pg_sleepはグローバル関数です。 異なるデータベースで同じステートメントを実行すると、異なるデータベースで同じquery_id値が使用されます。

    • ccl_testデータベースで次のステートメントを実行します。

      SELECT rds_get_query_id($$SELECT pg_sleep(1);$$);

      次の結果を返すことができます。

      rds_get_query_id
      --------------------
       440101247839410938
      (1行) 

    • ccl_test2データベースで次のステートメントを実行します。

      SELECT rds_get_query_id($$SELECT pg_sleep(1);$$);

      次の結果を返すことができます。

      rds_get_query_id
      --------------------
       440101247839410938
      (1行) 

• 関数呼び出しのシナリオでは、パラメーターのデータ型が変更された場合、またはFROM句の存在が変更された場合、query_idが変更されます。

  たとえば、pg_sleep関数を呼び出すと、query_idの値は状況によって異なります。

  • FROM句なし

    SELECT rds_get_query_id($$SELECT pg_sleep(1);$$);

    次の結果を返すことができます。

    rds_get_query_id
    --------------------
     440101247839410938
    (1行) 

  • FROM句付き

    SELECT rds_get_query_id($$SELECT * FROM pg_sleep(1);$$);

    次の結果を返すことができます。

    rds_get_query_id
    ----------------------
     -3404018605099167039
    (1行) 

  • パラメータのデータ型の変更

    select rds_get_query_id($$SELECT * FROM pg_sleep(1.0);$$);

    次の結果を返すことができます。

    rds_get_query_id
    ---------------------
     3073869725037049158
    (1行)