1. 连接PolarDB-X集群

本步骤将指导您如何连接通过k8s部署的PolarDB-X集群。

**说明：**本场景ECS实例已为您提前安装完成通过k8s部署的PolarDB-X集群。

执行如下命令，切换到账号galaxykube。

su galaxykube

执行如下命令，启动一个minikube。

**说明：**这里我们使用了阿里云的minikube镜像源以及USTC提供的docker镜像源来加速镜像的拉取。

minikube start --cpus 4 --memory 12288 --image-mirror-country cn --registry-mirror=https://docker.mirrors.sjtug.sjtu.edu.cn

返回结果如下，表示minikube已经正常运行。

执行如下命令，查看PolarDB-X集群登录密码。

kubectl get secret polardb-x -o jsonpath="{.data['polardbx_root']}" | base64 -d - | xargs echo "Password: "

返回结果如下，您可以查看到PolarDB-X集群登录密码。

执行如下命令，将PolarDB-X集群端口转发到3306端口。

**说明：**使用MySQL Client方式登录通过k8s部署的PolarDB-X集群前，您需要进行获取PolarDB-X集群登录密码和端口转发。

kubectl port-forward svc/polardb-x 3306

执行如下命令，连接PolarDB-X集群。

说明：

• 您需要将<PolarDB-X集群登录密码>替换为实际获取到的PolarDB-X集群登录密码。
• 如遇到mysql: [Warning] Using a password on the command line interface can be insecure.ERROR 2013 (HY000): Lost connection to MySQL server at 'reading initial communication packet', system error: 0报错，请您稍等一分钟，在终端一种重新执行转发端口命令，在终端二中重新执行连接PolarDB-X集群命令即可。

mysql -h127.0.0.1 -P3306 -upolardbx_root -p<PolarDB-X集群登录密码>

2. 模拟

本步骤将指导您如何使用Sysbench Select场景模拟业务流量。

2.1 准备压测数据

2.1.1 创建sysbench_test库

CREATE DATABASE sysbench_test;
USE sysbench_test;

2.1.2 准备sysbench-prepare.yaml

su galaxykube
cd
vim sysbench-prepare.yaml

apiVersion: batch/v1
kind: Job
metadata:
  name: sysbench-prepare-data-test
  namespace: default
spec:
  backoffLimit: 0
  template:
    spec:
      restartPolicy: Never
      containers:
        - name: sysbench-prepare
          image: severalnines/sysbench
          env:
            - name: POLARDB_X_USER
              value: polardbx_root
            - name: POLARDB_X_PASSWD
              valueFrom:
                secretKeyRef:
                  name: polardb-x
                  key: polardbx_root
          command: [ 'sysbench' ]
          args:
            - --db-driver=mysql
            - --mysql-host=$(POLARDB_X_SERVICE_HOST)
            - --mysql-port=$(POLARDB_X_SERVICE_PORT)
            - --mysql-user=$(POLARDB_X_USER)
            - --mysql_password=$(POLARDB_X_PASSWD)
            - --mysql-db=sysbench_test
            - --mysql-table-engine=innodb
            - --rand-init=on
            - --max-requests=1
            - --oltp-tables-count=1
            - --report-interval=5
            - --oltp-table-size=160000
            - --oltp_skip_trx=on
            - --oltp_auto_inc=off
            - --oltp_secondary
            - --oltp_range_size=5
            - --mysql_table_options=dbpartition by hash(`id`)
            - --num-threads=1
            - --time=3600
            - /usr/share/sysbench/tests/include/oltp_legacy/parallel_prepare.lua
            - run

2.1.3 初始化测试数据

kubectl apply -f sysbench-prepare.yaml

获取任务进行状态。

kubectl get jobs

返回结果如下，请您耐心等待大约1分钟，当任务状态COMPLETIONS为1/1时，表示数据已经初始化完成。

2.2 启动压测流量

2.2.1 创建启动sysbench-select.yaml

vim sysbench-select.yaml

apiVersion: batch/v1
kind: Job
metadata:
  name: sysbench-point-select-k-test
  namespace: default
spec:
  backoffLimit: 0
  template:
    spec:
      restartPolicy: Never
      containers:
        - name: sysbench-point-select-k
          image: severalnines/sysbench
          env:
            - name: POLARDB_X_USER
              value: polardbx_root
            - name: POLARDB_X_PASSWD
              valueFrom:
                secretKeyRef:
                  name: polardb-x
                  key: polardbx_root
          command: [ 'sysbench' ]
          args:
            - --db-driver=mysql
            - --mysql-host=$(POLARDB_X_SERVICE_HOST)
            - --mysql-port=$(POLARDB_X_SERVICE_PORT)
            - --mysql-user=$(POLARDB_X_USER)
            - --mysql_password=$(POLARDB_X_PASSWD)
            - --mysql-db=sysbench_test
            - --mysql-table-engine=innodb
            - --rand-init=on
            - --max-requests=0
            - --oltp-tables-count=1
            - --report-interval=5
            - --oltp-table-size=32000000
            - --oltp_skip_trx=on
            - --oltp_auto_inc=off
            - --oltp_secondary
            - --oltp_range_size=5
            - --mysql-ignore-errors=all
            - --num-threads=8
            - --time=3600
            - --random_points=1
            - /usr/share/sysbench/tests/include/oltp_legacy/select_random_points.lua
            - run

2.2.2 开始压测

kubectl apply -f sysbench-select.yaml

执行如下命令，查找压测脚本运行的POD。

kubectl get pods

返回结果如下， 以‘sysbench-point-select-k-test-’开头的POD即为目标POD。

执行如下命令，查看QPS等信息。

**说明：**您需要将命令中的目标POD替换为以‘sysbench-point-select-k-test-’开头的POD。

kubectl logs -f 目标POD

3. 体验SQL限流和SQL Advisor

本步骤将指导您体验SQL限流和SQL Advisor。

3.1 发现慢查询，进行限流

**说明：**本步骤有关SQL语句的操作都在终端二窗口中操作，查看QPS等信息在终端三窗口中操作，终端一窗口只负责PolarDB-X集群端口转发。

SQL限流。 SQL限流是PolarDB-X提供的对符合特定规则的SQL进行限制的功能。在本实验场景中假设步骤二中发起的Sysbench Select流量严重影响了其他业务，所以我们首先用SQL限流对Select SQL进行限流。

执行如下SQL语句，查看当前正在运行的请求。

show full processlist where info is not null

返回结果如下，您可查看到有如下SQL正在执行。

执行如下SQL语句，创建针对这条SQL的限流规则。

create ccl_rule block_select on sysbench_test.* to 'polardbx_root'@'%' for select filter by keyword('pad') with max_concurrency=0;

执行如下SQL语句，查看SQL限流具体拦截情况。

show ccl_rules;

返回结果如下，您可查看SQL限流具体拦截情况

3.2 Advisor优化

用SQL Advisor优化慢SQL。 在对慢SQL进行限制后，我们的系统就可以恢复正常状态了，那么接下来就可以对SQL进行优化。PolarDB-X 提供内置的SQL Advisor功能，可以针对某条SQL给出具体的优化建议。

执行如下，使用SQL Advisor功能分析SQL语句。

explain advisor SELECT id, k, c, pad from sbtest1 where k in(10)\G

返回结果如下，在ADVISE_INDEX部分，就是SQL Advisor给出的建议。

执行SQL Advisor给出的建议SQL语句。

ALTER TABLE `sysbench_test`.`sbtest1` ADD GLOBAL INDEX `__advise_index_gsi_sbtest1_k`(`k`) DBPARTITION BY HASH(`k`);

执行如下SQL语句，解除SQL限流。

drop ccl_rule block_select;

执行解除SQL限流的SQL语句后，您可查看到qps在优化后进行了大幅度的提升。

Show slow;
Clear slow;
Show physical slow;
show info from table_name;

Analyze table table_name;
Show statistics;

Explain sql;
Explain execute sql;
Explain Analyze sql;
Trace sql;
Show trace;
Explain advisor sql;

来源

• 七天玩转 PolarDB-X 开源训练营 (opens new window)