[大数据] java 与 grafana

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 大数据 -> java 与 grafana -> 正文阅读

[大数据]java 与 grafana

文章目录

使用 grafana 监控 sql 执行耗时与次数数据存储在 influxDB 中

效果

grafana下载
 influx db 下载

influx_db 建库

创建 sqlp 数据库

create database sqlp;

添加数据保留策略这里设置为1天

 create retention policy "1d" on "sqlp"  duration 24h replication 1 DEFAULT ;

java 上报数据

使用 influxdb-java

<dependency>
			<groupId>org.influxdb</groupId>
			<artifactId>influxdb-java</artifactId>
			<version>2.22</version>
</dependency>

数据保存时用表名作为 measurement
并添加一个 sql_type 的 tag (select, insert, update, select count)
可以用 druid filter 统计耗时

@Slf4j
public class MyDruidFilter extends FilterEventAdapter {
    
    // 覆盖执行方法
    @Override
    public boolean preparedStatement_execute(FilterChain chain, PreparedStatementProxy statement) throws SQLException {
        long start = System.currentTimeMillis();
        try {
            this.statementExecuteBefore(statement, statement.getSql());
            boolean firstResult = chain.preparedStatement_execute(statement);
            this.statementExecuteAfter(statement, statement.getSql(), firstResult);
            return firstResult;
        } catch (SQLException var4) {
            this.statement_executeErrorAfter(statement, statement.getSql(), var4);
            throw var4;
        } catch (RuntimeException var5) {
            this.statement_executeErrorAfter(statement, statement.getSql(), var5);
            throw var5;
        } catch (Error var6) {
            this.statement_executeErrorAfter(statement, statement.getSql(), var6);
            throw var6;
        } finally {
            long consumeTime = System.currentTimeMillis() - start;
            SqlMonitor.monitorTime(statement.getSql().toString(), "b_file", consumeTime);
        }
    }
}

monitor time 方法

public static void monitorTime(String sql, String table, Long consumeTimeInMs) {
        sql = sql.replaceAll("\n", "");
        String tag = "default";
        if (sql.startsWith("SELECT COUNT")) {
            tag = "count";
        } else if (sql.startsWith("SELECT")) {
            tag = "select";
        } else if (sql.startsWith("INSERT")) {
            tag = "insert";
        } else if (sql.startsWith("UPDATE")) {
            tag = "update";
        }
        Point point = Point.measurement(table)
            .tag("sql_type", tag)
            .addField("consume_time", consumeTimeInMs)
            .addField("sql_count", 1)
            .build();
        InfluxDBUtil.write(INFLUX_DB, point);
    }