ProxySQL Scheduler

Scheduler

scheduler特性是在ProxySQL v1.2.0引入的。

scheduler是一个类似cron的调度器，已经被集成到ProxySQL中了，粒度可以达到毫秒级。通过admin即可配置：目前不支持配置文件配置，将来也没这个打算

Motivation

scheduler可以以规定的间隔执行你自定义的脚本，其主要目的是这个脚本能够监控到外部异常事件的发生从而能够重新配置ProxySQL

Implementation

通过两个表来实现这个功能

Admin> SHOW TABLES LIKE '%scheduler%';
+-------------------+
| tables            |
+-------------------+
| scheduler         |
| runtime_scheduler |
+-------------------+
2 rows in set (0.00 sec)

具体细节：

• 通过scheduler表配置调度器
• runtime_scheduler表示调度器在runtime状态的表现形式

scheduler表结构：

Admin> SHOW CREATE TABLE schedulerG
*************************** 1. row ***************************
       table: scheduler
Create Table: CREATE TABLE scheduler (
    id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
    active INT CHECK (active IN (0,1)) NOT NULL DEFAULT 1,
    interval_ms INTEGER CHECK (interval_ms>=100 AND interval_ms<=100000000) NOT NULL,
    filename VARCHAR NOT NULL,
    arg1 VARCHAR,
    arg2 VARCHAR,
    arg3 VARCHAR,
    arg4 VARCHAR,
    arg5 VARCHAR,
    comment VARCHAR NOT NULL DEFAULT '')
1 row in set (0.00 sec)

字段描述：

• id：调度器唯一标识
• active：如果是1，那么调度器是生效的，否则不生效
• interval_ms：间隔多少毫秒执行。最小值是100毫秒
• filename：可执行文件全路径
• arg1~arg5：传递到job的参数，最多5个
• comment：解释job功能的comment

runtime_scheduler有着相同的表结构：

Admin> SHOW CREATE TABLE runtime_schedulerG
*************************** 1. row ***************************
       table: runtime_scheduler
Create Table: CREATE TABLE runtime_scheduler (
    id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
    active INT CHECK (active IN (0,1)) NOT NULL DEFAULT 1,
    interval_ms INTEGER CHECK (interval_ms>=100 AND interval_ms<=100000000) NOT NULL,
    filename VARCHAR NOT NULL,
    arg1 VARCHAR,
    arg2 VARCHAR,
    arg3 VARCHAR,
    arg4 VARCHAR,
    arg5 VARCHAR,
    comment VARCHAR NOT NULL DEFAULT '')
1 row in set (0.00 sec)

至于其他的配置表，配置后都需要load到runtime或者持久化到磁盘，所以针对schedule也有一些新命令：

• LOAD SCHEDULER TO RUNTIME 或者 LOAD SCHEDULER FROM MEMORY ： load the configuration from main.scheduler to runtime, and becomes effective;
• LOAD SCHEDULER TO MEMORY 或者 LOAD SCHEDULER FROM DISK ：load the configuration from disk.scheduler to main.scheduler;
• SAVE SCHEDULER FROM RUNTIME 或者 SAVE SCHEDULER TO MEMORY ： save the configuration from runtime to main.scheduler;
• SAVE SCHEDULER FROM MEMORY 或者SAVE SCHEDULER TO DISK ：save the configuration from main.scheduler to disk.scheduler, and becomes persistent across restart.

调度器是通过调用fork()，然后调用execve()来实现的，如果执行execve()失败，错误日志将会记录到error log中。

参考文档