开发指南—DAL语句—SQL限流

创建限流规则

• 语法

CREATE CCL_RULE [ IF NOT EXISTS ] `ccl_rule_name`
ON `database`.`table`
TO '<usename>'@'<host>'
FOR { UPDATE | SELECT | INSERT | DELETE }
[ filter_options ]
with_options
filter_options:
    [ FILTER  BY KEYWORD(‘KEYWORD1’, ’KEYWORD2’,…) ]
    [ FILTER  BY TEMPLATE(‘template_id’) ]
    
 with_options:
    WITH MAX_CONCURRENCY = value1 [ , WAIT_QUEUE_SIZE = value2 ] [ , WAIT_TIMEOUT = value3 ] [ ,FAST_MATCH = { 0 , 1 }]

• 表 1. 参数说明

• 
  说明 仅当一个SQL语句满足所有的匹配参数条件时，才会根据该规则的WITH选项进行限流。
• 限流结果一条SQL匹配到该规则后，根据限流规则中WITH选项里配置的参数，会出现如下几种结果：

• • RUN（可运行）若并发度还未达到最大并发度（即MAX_CONCURRENCY参数值），该SQL正常执行不会被限流。
    
  • WAIT（等待中）若并发度已经达到最大并发度，但等待队列长度还未达到最大长度（即WAIT_QUEUE_SIZE参数值），该SQL进入等待状态，直到进入可运行（RUN）状态，或者等待超时（WAIT_TIMEOUT）状态。
    您可以通过如下命令查看由于匹配到限流规则而等待的SQL语句：
    

mysql> SHOW FULL PROCESSLIST;

• • 返回结果示例如下：
    

+----+---------------+-----------------+----------+-------------------------------+------+-------+-----------------------+-----------------+

• • 从上述查询结果可以看出：SQL语句select 1由于限流规则selectrulereal而处于等待（Waiting）状态。
  • WAIT_TIMEOUT（等待超时）SQL语句进入等待状态后，当等待时间超过最长等待时间（即WAIT_TIMEOUT参数值）时，该语句将会返回错误。
    例如，设置了一条最长等待时间为10秒的限流规则，执行SELECT sleep(11)语句时会因为等待超时而报错，示例如下：
    

ERROR 3009 (HY000): 11a07e23fd800000[polardbx]Exceeding the max concurrency 0 of ccl rule selectrulereal after waiting for 10060 ms

• • KILL（结束）并发度和等待队列长度均已经达到最大值，客户端将收到提示超过最大并发度的报错，报错信息中会包含匹配上的限流规则的名称。
    例如，在并发度和等待队列长度均已经达到最大值后执行SELECT 1;命令，会出现如下报错：
    

ERROR 3009 (HY000): 11a07c4425c00000[polardbx]Exceeding the max concurrency 0 of ccl rule selectrulereal

• • 上述结果表示：该SQL语句SELECT 1;由于超出了限流规则selectrulereal设置的最大并发度而执行失败。

• 示例假设需要创建一条名为selectrule的规则，用于限制由'ccltest'@'%'用户发起的，包含cclmatched关键字的，且对任意表执行SELECT操作的SQL语句，同时将最大并发度设置为10。
  规则创建语句如下：
  

CREATE CCL_RULE IF NOT EXISTS `selectrule` ON . TO 'ccltest'@'%'
FOR SELECT
FILTER BY KEYWORD('cclmatched')
WITH MAX_CONCURRENCY=10;

查看限流规则

• 语法

• • 查看指定限流规则语法如下：
    

SHOW CCL_RULE `ccl_rule_name1` [, `ccl_rule_name2` ]

• • 查看所有限流规则语法如下：
    

SHOW CCL_RULES

• 示例使用如下命令查看当前数据库下所有的限流规则：
  

mysql> SHOW CCL_RULES \G

• 返回结果如下：
  

 1. row **
                     NO.: 1
               RULE_NAME: selectrulereal
                 RUNNING: 2
                 WAITING: 29
                  KILLED: 0
         MATCH_HIT_CACHE: 21374
             TOTAL_MATCH: 21406
       ACTIVE_NODE_COUNT: 2
MAX_CONCURRENCY_PER_NODE: 1
WAIT_QUEUE_SIZE_PER_NODE: 100
            WAIT_TIMEOUT: 600
              FAST_MATCH: 1
                SQL_TYPE: SELECT
                    USER: ccltest@%
                   TABLE: .
                KEYWORDS: ["SELECT"]
              TEMPLATEID: NULL
            CREATED_TIME: 2020-11-26 17:04:08

• 表 2. 参数说明

删除限流规则

说明 被删除的限流规则会立即失效，此时该规则下等待队列中的SQL语句全部会被正常执行。

• 删除指定限流规则：

DROP CCL_RULE [ IF EXISTS ] `ccl_rule_name1` [, `ccl_rule_name2`, ...]

• 删除所有限流规则：

CLEAR CCL_RULES

慢SQL限流

• 一键开启按语句类型分，默认为SELECT类型，相同语句类型的命令，有更新作用。语法结构如下：

SLOW_SQL_CCL GO [ SQL_TYPE [MAX_CONCURRENCY] [SLOW_SQL_TIME] [MAX_CCL_RULE]]

• • SQL_TYPE取值：ALL，SELECT，UPDATE，INSERT，默认为SELECT。
  • MAX_CONCURRENCY默认值为CPU核数的一半。
  • SLOW_SQL_TIME默认值为系统参数SLOW_SQL_TIME的值。
  • MAX_CCL_RULE的默认值为1000。

• 动作：

• • 遍历整个实例的session，识别出该语句类型慢SQL的TemlateId。
  • 创建针对慢SQL的限流触发器，名称为：_SYSTEM_SLOW_SQL_CCL_TRIGGER_{SQL_TYPE}_。
  • 传递慢SQL的TemplateId给限流触发器，由限流触发器创建限流规则。
  • Kill所有该语句类型的慢TemplateId查询。

• 一键关闭删除由SLOW_SQL_CCL创建的限流触发器，连带着会删除由限流触发器创建的限流规则。语法结构如下：
  

SLOW_SQL_CCL BACK

• 查看限流情况。语法结构如下：

SLOW_SQL_CCL SHOW

• plan_cache和ccl_rules里以模版ID作为join key的一次inner join。
• 如何干预慢SQL的阈值？

• • 设置SLOW_SQL_CCL GO中的语法。
  • 在一键开启SQL限流之前，设置用户变量slow_sql_time。如下：

set @slow_sql_time=2000;
slow_sql_ccl go;

• • 在控制台上设置系统参数SLOW_SQL_TIME。

• 说明 后面的设置方式会被前面的设置方式所覆盖。