perf: api限流相关flyway

This commit is contained in:
fit2cloud-chenyw 2024-07-16 13:46:46 +08:00
parent b5b34e5052
commit c7038a233d
2 changed files with 62 additions and 41 deletions

View File

@ -1,50 +1,71 @@
DROP TABLE IF EXISTS `core_copilot_msg`;
CREATE TABLE `core_copilot_msg` (
`id` bigint NOT NULL COMMENT 'ID',
`user_id` bigint DEFAULT NULL COMMENT '用户ID',
`dataset_group_id` bigint DEFAULT NULL COMMENT '数据集ID',
`msg_type` varchar(255) DEFAULT NULL COMMENT 'user or api',
`engine_type` varchar(255) DEFAULT NULL COMMENT 'mysql oracle ...',
`schema_sql` longtext COMMENT 'create sql',
`question` longtext COMMENT '用户提问',
`history` longtext COMMENT '历史信息',
`copilot_sql` longtext COMMENT 'copilot 返回 sql',
`api_msg` longtext COMMENT 'copilot 返回信息',
`sql_ok` int DEFAULT NULL COMMENT 'sql 状态',
`chart_ok` int DEFAULT NULL COMMENT 'chart 状态',
`chart` longtext COMMENT 'chart 内容',
`chart_data` longtext COMMENT '视图数据',
`exec_sql` longtext COMMENT '执行请求的SQL',
`msg_status` int DEFAULT NULL COMMENT 'msg状态0失败 1成功',
`err_msg` longtext COMMENT 'de错误信息',
`create_time` bigint DEFAULT NULL COMMENT '创建时间',
PRIMARY KEY (`id`)
CREATE TABLE `core_copilot_msg`
(
`id` bigint NOT NULL COMMENT 'ID',
`user_id` bigint DEFAULT NULL COMMENT '用户ID',
`dataset_group_id` bigint DEFAULT NULL COMMENT '数据集ID',
`msg_type` varchar(255) DEFAULT NULL COMMENT 'user or api',
`engine_type` varchar(255) DEFAULT NULL COMMENT 'mysql oracle ...',
`schema_sql` longtext COMMENT 'create sql',
`question` longtext COMMENT '用户提问',
`history` longtext COMMENT '历史信息',
`copilot_sql` longtext COMMENT 'copilot 返回 sql',
`api_msg` longtext COMMENT 'copilot 返回信息',
`sql_ok` int DEFAULT NULL COMMENT 'sql 状态',
`chart_ok` int DEFAULT NULL COMMENT 'chart 状态',
`chart` longtext COMMENT 'chart 内容',
`chart_data` longtext COMMENT '视图数据',
`exec_sql` longtext COMMENT '执行请求的SQL',
`msg_status` int DEFAULT NULL COMMENT 'msg状态0失败 1成功',
`err_msg` longtext COMMENT 'de错误信息',
`create_time` bigint DEFAULT NULL COMMENT '创建时间',
PRIMARY KEY (`id`)
);
DROP TABLE IF EXISTS `core_copilot_token`;
CREATE TABLE `core_copilot_token` (
`id` bigint NOT NULL COMMENT 'ID',
`type` varchar(255) DEFAULT NULL COMMENT 'free or license',
`token` longtext,
`update_time` bigint DEFAULT NULL,
PRIMARY KEY (`id`)
);
INSERT INTO `core_copilot_token` VALUES (1, 'free', null, null);
INSERT INTO `core_copilot_token` VALUES (2, 'license', null, null);
DROP TABLE IF EXISTS `core_copilot_config`;
CREATE TABLE `core_copilot_config` (
`id` bigint NOT NULL COMMENT 'ID',
`copilot_url` varchar(255) DEFAULT NULL,
`username` varchar(255) DEFAULT NULL,
`pwd` varchar(255) DEFAULT NULL,
CREATE TABLE `core_copilot_token`
(
`id` bigint NOT NULL COMMENT 'ID',
`type` varchar(255) DEFAULT NULL COMMENT 'free or license',
`token` longtext,
`update_time` bigint DEFAULT NULL,
PRIMARY KEY (`id`)
);
INSERT INTO `core_copilot_config` VALUES (1, 'https://copilot-demo.test.fit2cloud.dev:5000', 'xlab', 'Q2Fsb25nQDIwMTU=');
INSERT INTO `core_copilot_token`
VALUES (1, 'free', null, null);
INSERT INTO `core_copilot_token`
VALUES (2, 'license', null, null);
UPDATE `core_sys_setting` SET `pkey` = 'ai.baseUrl', `pval` = 'https://maxkb.fit2cloud.com/ui/chat/2ddd8b594ce09dbb?mode=embed', `type` = 'text', `sort` = 0 WHERE `id` = 3;
DROP TABLE IF EXISTS `core_copilot_config`;
CREATE TABLE `core_copilot_config`
(
`id` bigint NOT NULL COMMENT 'ID',
`copilot_url` varchar(255) DEFAULT NULL,
`username` varchar(255) DEFAULT NULL,
`pwd` varchar(255) DEFAULT NULL,
PRIMARY KEY (`id`)
);
INSERT INTO `core_copilot_config`
VALUES (1, 'https://copilot-demo.test.fit2cloud.dev:5000', 'xlab', 'Q2Fsb25nQDIwMTU=');
UPDATE `core_sys_setting`
SET `pkey` = 'ai.baseUrl',
`pval` = 'https://maxkb.fit2cloud.com/ui/chat/2ddd8b594ce09dbb?mode=embed',
`type` = 'text',
`sort` = 0
WHERE `id` = 3;
DROP TABLE IF EXISTS `core_api_traffic`;
CREATE TABLE `core_api_traffic`
(
`id` bigint NOT NULL COMMENT 'ID',
`api` varchar(255) NOT NULL COMMENT 'api',
`threshold` int NOT NULL DEFAULT '2' COMMENT '阈值',
`alive` int NOT NULL DEFAULT '0' COMMENT '活动并发',
PRIMARY KEY (`id`)
);

View File

@ -57,7 +57,7 @@ public class DeTrafficAop {
coreApiTrafficMapper.releaseAlive(api);
}
}
DEException.throwException(errorMsg);
DEException.throwException(String.format(errorMsg, api, value));
return null;
}
}