一、InfluxDB介绍
InfluxDB 是一个开源的分布式时序、事件和指标数据库。它具有高可用性和可扩展性,可处理来自存储设备、传感器、应用程序等的海量数据,方便用户查询和分析数据等操作。
它是一个基于Go语言的开源数据库,专门为区块链、物联网、实时分析、监控等大数据领域打造,能够支持各种类型的数据,包括数值、字符串、嵌套和地理空间数据。
InfluxDB 的主要特点包括:
- 基于标签索引,使得查询效率更高,支持高峰值瞬间查询。
- 支持 SQL 语句查询和动态创建数据库的机制。
- 支持在分布式系统上多节点水平扩展,提高性能。
二、InfluxDB安装
InfluxDB 支持 Windows、Linux 和 macOS,可以通过官方网站下载相应版本的安装包。
以下是安装 InfluxDB 的步骤:
1. Linux平台安装
# 添加官方仓库 $ curl -sL https://repos.influxdata.com/influxdb.key | sudo apt-key add - $ echo "deb https://repos.influxdata.com/debian buster stable" | sudo tee /etc/apt/sources.list.d/influxdb.list # 安装数据库服务 $ sudo apt-get update && sudo apt-get install influxdb
2. macOS安装
# 安装 Homebrew 包管理器 $ /usr/bin/ruby -e "$(curl -fsSL https://raw.githubusercontent.com/Homebrew/install/master/install)" # 使用 Homebrew 安装 InfluxDB $ brew update $ brew install influxdb
三、InfluxDB基础
1. 创建数据库
InfluxDB 中不需要显式地创建数据库,可以通过写入数据来动态创建。当你写入数据时,如果该数据库不存在,将自动创建该数据库。因此,写入数据是操作 InfluxDB 的首选方式。
以下是创建 InfluxDB 数据库的示例:
$ influx -precision rfc3339 Connected to http://localhost:8086 version 2.0.0 > CREATE DATABASE mydb > SHOW DATABASES name: databases name ---- _internal mydb
2. 测量(Measurement)和标签(Tag)
InfluxDB 采用了一种特别的模型,即使用测量(Measurement)和标签(Tag)来描述一组数据。一个测量表示一组数据,一个标签则是用于过滤、深入挖掘数据。因此,正确的测量和标签非常重要。
以下是创建 InfluxDB 测量和标签的示例:
> INSERT cpu,host=serverA,region=uswest value=0.64 > INSERT cpu,host=serverA,region=uswest value=0.67 > INSERT cpu,host=serverB,region=uswest value=0.52 > SELECT * FROM cpu name: cpu time host region value ---- ---- ------ ----- 1638004310260996301 serverA uswest 0.64 1638004322905133200 serverA uswest 0.67 1638004383085653232 serverB uswest 0.52
3. 查询语句
InfluxDB 查询语句采用类 SQL 语法,但是也有自己的一些特性。为了方便查询,InfluxDB 还提供了一些内置函数,如 min、max、count、sum、mean 等。以下是一些常用的查询操作示例:
> SELECT * FROM cpu WHERE host = 'serverA' > SELECT * FROM cpu WHERE host =~ /server.*/ AND value > 0.5 > SELECT count(*) FROM cpu WHERE time > now() - 1h > SELECT mean(value) FROM cpu WHERE time > now() - 30m GROUP BY host
四、InfluxDB高级应用
1. InfluxDB曲线图
InfluxDB 有一个实时的曲线图展示功能,可以动态地展示数据的变化情况。
以下是一个简单的 InfluxDB 曲线图示例:
InfluxDB Chart <script src="https://cdn.jsdelivr.net/npm/@influxdata/influxdb-client@1.20.0/dist/influxdb-browser.js"></script> <script src="https://code.highcharts.com/highcharts.js"></script> <script> const client = new InfluxDB("http://localhost:8086"); const queryApi = client.getQueryApi("mydb"); queryApi.query("from(bucket: 'my-bucket') |> range(start: v.timeRangeStart, stop: v.timeRangeStop) |> yield()", { next(response, done) { const series = []; response.tables.forEach((table) => { table.records.forEach((record) => { series.push({ x: new Date(record.time), y: record.value }); }); }); Highcharts.chart('container', { series: [{ name: 'MySeries', data: series, turboThreshold: 0 }] }); done(); }, error(error) { console.error(error); }, complete() { console.log('Query completed successfully'); } }); </script>