自学网站开发需要看什么书,wordpress 主题 后门,网站开发商业计划书,做网站视频一般上传到哪里【Apache Doris】审计日志插件 | 快速体验 一、 环境信息1.1 硬件信息1.2 软件信息 二、 审计日志插件介绍三、 快速 体验3.1 AuditLoader 配置3.1.1 下载 Audit Loader 插件3.1.2 解压安装包3.1.3 修改 plugin.conf 3.2 创建库表3.3 初始化3.4 验证 一、 环境信息
1.1 硬件信… 【Apache Doris】审计日志插件 | 快速体验 一、 环境信息1.1 硬件信息1.2 软件信息 二、 审计日志插件介绍三、 快速 体验3.1 AuditLoader 配置3.1.1 下载 Audit Loader 插件3.1.2 解压安装包3.1.3 修改 plugin.conf 3.2 创建库表3.3 初始化3.4 验证 一、 环境信息
1.1 硬件信息
CPU 48CCPU型号x86_64内存 185GB
1.2 软件信息
系统 CentOSApahce Doris版本 2.0.2JAVA版本1.8.0
二、 审计日志插件介绍
Doris默认装了是审计日志即会将执行的SQL都记录到fe/log/fe.audit.log日志里但如果需要映射到表、通过SQL的方式去查询解析这些日志的话则需要安装配置审计日志插件。
Doris 的审计日志插件是在 FE 的插件框架基础上开发的是一个可选插件。用户可以在运行时安装或卸载这个插件。
审计日志插件可以将 FE 的审计日志定期的导入到指定 Doris 集群中以方便用户通过 SQL 对审计日志进行查看和分析。 三、 快速 体验
3.1 AuditLoader 配置
3.1.1 下载 Audit Loader 插件
Audit Loader 插件在 Doris 的发行版中默认提供通过官网下载 Doris 安装包解压并进入目录后即可在 extensions/audit_loader 子目录下找到 auditloader.zip 文件。
3.1.2 解压安装包
unzip auditloader.zip解压生成如下3个文件
auditloader.jar插件代码包。plugin.properties插件属性文件。plugin.conf插件配置文件。 3.1.3 修改 plugin.conf
以下配置可供修改
frontend_host_portFE 节点 IP 地址和 HTTP 端口格式为 fe_ip:fe_http_port。 默认值为 127.0.0.1:8030。database审计日志库名默认即可、需要与上一步的【创建库表】一致。audit_log_table审计日志表名默认即可、需要与上一步的【创建库表】一致。slow_log_table慢查询日志表名默认即可、需要与上一步的【创建库表】一致。enable_slow_log是否开启慢查询日志导入功能。默认值为 false。user集群用户名。该用户必须具有对应表的 INSERT 权限。password集群用户密码。 3.2 创建库表
在 Doris 中需要创建审计日志的库和表表结构如下
若需开启慢查询日志导入功能还需要额外创建慢表 doris_slow_log_tbl__其表结构与 doris_audit_log_tbl__ 一致。
其中 dynamic_partition 属性根据自己的需要选择审计日志保留的天数。
create database doris_audit_db__;create table doris_audit_db__.doris_audit_log_tbl__
(query_id varchar(48) comment Unique query id,time datetime not null comment Query start time,client_ip varchar(32) comment Client IP,user varchar(64) comment User name,catalog varchar(128) comment Catalog of this query,db varchar(96) comment Database of this query,state varchar(8) comment Query result state. EOF, ERR, OK,error_code int comment Error code of failing query.,error_message string comment Error message of failing query.,query_time bigint comment Query execution time in millisecond,scan_bytes bigint comment Total scan bytes of this query,scan_rows bigint comment Total scan rows of this query,return_rows bigint comment Returned rows of this query,stmt_id int comment An incremental id of statement,is_query tinyint comment Is this statemt a query. 1 or 0,frontend_ip varchar(32) comment Frontend ip of executing this statement,cpu_time_ms bigint comment Total scan cpu time in millisecond of this query,sql_hash varchar(48) comment Hash value for this query,sql_digest varchar(48) comment Sql digest for this query,peak_memory_bytes bigint comment Peak memory bytes used on all backends of this query,stmt string comment The original statement, trimed if longer than 2G
) engineOLAP
duplicate key(query_id, time, client_ip)
partition by range(time) ()
distributed by hash(query_id) buckets 1
properties(dynamic_partition.time_unit DAY,dynamic_partition.start -30,dynamic_partition.end 3,dynamic_partition.prefix p,dynamic_partition.buckets 1,dynamic_partition.enable true,replication_num 3
);create table doris_audit_db__.doris_slow_log_tbl__
(query_id varchar(48) comment Unique query id,time datetime not null comment Query start time,client_ip varchar(32) comment Client IP,user varchar(64) comment User name,catalog varchar(128) comment Catalog of this query,db varchar(96) comment Database of this query,state varchar(8) comment Query result state. EOF, ERR, OK,error_code int comment Error code of failing query.,error_message string comment Error message of failing query.,query_time bigint comment Query execution time in millisecond,scan_bytes bigint comment Total scan bytes of this query,scan_rows bigint comment Total scan rows of this query,return_rows bigint comment Returned rows of this query,stmt_id int comment An incremental id of statement,is_query tinyint comment Is this statemt a query. 1 or 0,frontend_ip varchar(32) comment Frontend ip of executing this statement,cpu_time_ms bigint comment Total scan cpu time in millisecond of this query,sql_hash varchar(48) comment Hash value for this query,sql_digest varchar(48) comment Sql digest for this query,peak_memory_bytes bigint comment Peak memory bytes used on all backends of this query,stmt string comment The original statement, trimed if longer than 2G
) engineOLAP
duplicate key(query_id, time, client_ip)
partition by range(time) ()
distributed by hash(query_id) buckets 1
properties(dynamic_partition.time_unit DAY,dynamic_partition.start -30,dynamic_partition.end 3,dynamic_partition.prefix p,dynamic_partition.buckets 1,dynamic_partition.enable true,replication_num 3
);3.3 初始化
INSTALL PLUGIN FROM [source] [PROPERTIES (keyvalue, ...)]source 支持三种类型
指向一个 zip 文件的绝对路径。指向一个插件目录的绝对路径。指向一个 http 或 https 协议的 zip 文件下载路径
Example
安装一个本地 zip 文件插件
INSTALL PLUGIN FROM /home/users/doris/auditdemo.zip;安装一个本地目录中的插件
INSTALL PLUGIN FROM /home/users/doris/auditdemo/;下载并安装一个插件注意需要放置一个和 .zip 文件同名的 md5 文件, 如 http://mywebsite.com/plugin.zip.md5 。其中内容为 .zip 文件的 MD5 值。
INSTALL PLUGIN FROM http://mywebsite.com/plugin.zip;下载并安装一个插件,同时设置了zip文件的md5sum的值
INSTALL PLUGIN FROM http://mywebsite.com/plugin.zip PROPERTIES(md5sum 73877f6029216f4314d712086a146570);执行install成功后会在fe/plugins/目录下自动生成AuditLoader目录 3.4 验证
执行如下sql验证是否安装注册成功Status为INSTALLED则说明安装成功 直接通过sql查询审计日志快速体验。
select*
fromdoris_audit_db__.doris_audit_log_tbl__
wheretime 2023-11-11 00:00:00and stmt like %ssb_test.part%
order bytime desc
limit 10;【Apache Doris】审计日志插件 | 快速体验 分享至此结束体验过程中若遇到问题欢迎留言交流
