当前位置：首页 > news >正文

时序数据库：Influxdb详解

news 来源：原创 2025/7/6 16:18:27

文章目录

一、简介
- 1、简介
- 2、官网
二、部署
- 1、安装
- 2、配置
- - （1）用户初始化
三、入门（Web UI）
- 1、加载数据
- - （1）上传数据文件
  - （2）代码接入模板
- 2、管理存储桶
- - （1）创建桶
  - （2）修改桶
- 3、演示：测试录入数据
- 4、Telegraf集成
- 5、管理抓取任务
- 6、管理 API Token
- 7、使用Data Explorer
- - （1）查询构造器
  - （2）FLUX 脚本编辑器
  - （3）数据预览区
  - （4）数据导出为CSV
- 8、使用Notebook
四、Flux语法
五、HTTP API
六、Java操作Influxdb
- 1、导包
- 2、POJO
- 3、同步写入
- 4、异步写入
- 5、查询

一、简介

1、简介

关系型数据库也是支持时间戳的，也能够基于时间戳进行查询。但是，从我们的使用场景出发，需要注意数据库的写入性能。通常，关系型数据库会采用 B+树数据结构，在数据写入时，有可能会触发叶裂变，从而产生了对磁盘的随机读写，降低写入速度。

当前市面上的时序数据库通常都是采用 LSM Tree 的变种，顺序写磁盘来增强数据的写入能力。通常时序数据库都会保证在单点每秒数十万的写入能力。

时序数据库一般用于指标监控场景。这个场景的数据有一个非常明显的特点就是冷热差别明显。通常，指标监控只会使用近期一段时间的数据。

2、官网

官网：https://www.influxdata.com/

二、部署

1、安装

wget https://dl.influxdata.com/influxdb/releases/influxdb2-2.4.0-linux-amd64.tar.gz
# 解压
tar -zxvf influxdb2-2.4.0-linux-amd64.tar.gz# 启动
./influxd

2、配置

（1）用户初始化

1、访问http://192.168.56.10:8086/
在这里插入图片描述
2、点击GET STARTED后，需要填写用户名、密码、组织和初始化的数据库（Bucket）
admin/admin123

下一步之后，点击CONFIGURE LATER

在这里插入图片描述

3、进入到初始化页面
在这里插入图片描述

三、入门（Web UI）

1、加载数据

（1）上传数据文件

在这里插入图片描述
在 Web UI 上，你可以用文件的方式上传数据，前提是文件中的数据符合 InfluxDB 支持的类型，包括 CSV、带 Flux 注释的 CSV 和 InfluxDB 行协议。

点开一个文件上传的页面，会有对应的示例：

（2）代码接入模板

在这里插入图片描述
在这里提供了一些代码相关的Demo，非常方便：

在这里插入图片描述

2、管理存储桶

可以将 InfluxDB 中的 bucket 理解为普通关系型数据库中的 database。

在这里插入图片描述

（1）创建桶

创建桶，可以选择自动删除超过多长时间的数据。
在这里插入图片描述

（2）修改桶

可以直接修改桶的数据过期时间。
修改桶的名称是敏感行为，谨慎操作！
在这里插入图片描述

3、演示：测试录入数据

在这里插入图片描述

4、Telegraf集成

Telegraf 是 InfluxDB 生态中的一个数据采集组件，它可以将各种时序数据自动采集到InfluxDB。现在，Telegraf 不仅仅是 InfluxDB 的数据采集组件了，很多时序数据库都支持与 Telegraf 进行协作，不少类似的时序数据收集组件选择在 Telegraf 的基础上二次开发。

这里先略过了。
在这里插入图片描述

5、管理抓取任务

抓取任务就是你给定一个 URL，InfluxDB 每隔一段时间去访问这个链接，把访问到的数据入库。

目标 URL 暴露出来的数据格式必须得是 Prometheus 数据格式。

在这里插入图片描述

此处略了。

6、管理 API Token

token用于API的使用。
在这里插入图片描述

7、使用Data Explorer

在这里插入图片描述

（1）查询构造器

在这里插入图片描述

（2）FLUX 脚本编辑器

可以手动将查询构造器切换为 FLUX 脚本编辑器。
在这里插入图片描述

（3）数据预览区

数据预览区可以将你的数据展示出来。下图是一个效果图。
在这里插入图片描述

（4）数据导出为CSV

在这里插入图片描述

8、使用Notebook

在这里插入图片描述

四、Flux语法

暂略。

五、HTTP API

使用API时，需要在Header头携带Authorization，value值为Token空格 + 你的token
在这里插入图片描述

# 查询目前所有的 Token 信息，包括他们拥有什么权限
http://192.168.56.10:8086/api/v2/authorizations

官方文档：https://docs.influxdata.com/influxdb/v2/api/

六、Java操作Influxdb

客户端参考：https://github.com/influxdata/influxdb-client-java

1、导包

<dependency><groupId>com.influxdb</groupId><artifactId>influxdb-client-java</artifactId><version>6.5.0</version>
</dependency>

2、POJO


import com.influxdb.annotations.Column;
import com.influxdb.annotations.Measurement;import java.time.Instant;/*** @description: 这是一个POJO类，对应将POJO类写入InfluxDB*/
@Measurement(name="temperature")
public class DemoPOJO {/** 注意类上的@Measurement注解，我们既可以使用Measurement注解来指定一个POJO类的测量名称* 但是使用@Measurement注解会将测量名称直接写死在代码里* 当测量名称会在运行时发生改变时，我们可以使用@Column(menasurement=true)注解* 这样会将POJO类中被注解的值作为测量名称。* **///@Column(measurement = true)//String measurementName;/** 相当于InfluxDB行协议中的标签集，此处标签的名称将会是location **/@Column(tag = true)String location;/** 相当于InfluxDB行协议中的字段集，此处字段的名称将会是value **/@ColumnDouble value;/** 相当于InfluxDB行协议中的时间戳 **/@Column(timestamp = true)Instant timestamp;/** 全参构造器，方便调用者创建对象 **/public DemoPOJO(String location, Double value, Instant timestamp) {this.location = location;this.value = value;this.timestamp = timestamp;}
}

3、同步写入

import com.influxdb.client.InfluxDBClient;
import com.influxdb.client.InfluxDBClientFactory;
import com.influxdb.client.WriteApiBlocking;
import com.influxdb.client.domain.WritePrecision;
import com.influxdb.client.internal.AbstractWriteClient;
import com.influxdb.client.internal.MeasurementMapper;
import com.influxdb.client.write.Point;import java.time.Instant;/*** @author: tony* @description: 这里是使用同步方式向InfluxDB写入数据的示例代码**/
public class Write1 {/** token 操作时需要换成自己的 **/private static char[] token = "token....".toCharArray();/** 组织名称 **/private static String org = "cxf";/** InfluxDB服务提供的url **/private static String url = "http://localhost:8086/";/** 存储桶名称 **/private static String bucket = "example_java";public static void main(String[] args) {InfluxDBClient influxDBClient = InfluxDBClientFactory.create(url, token, org, bucket);WriteApiBlocking writeApiBlocking = influxDBClient.getWriteApiBlocking();// 0. 使用InflxuDB行协议写入
//        writeApiBlocking.writeRecord(WritePrecision.MS,"temperature,location=north value=50");// 1. 使用Point写入
//        Point point = Point.measurement("temperature")
//                .addTag("location", "west")
//                .addField("value", 38.0)
//                .time(Instant.now(),WritePrecision.NS)
//                ;
//        writeApiBlocking.writePoint(point);// 2. 使用POJO类写入DemoPOJO demoPOJO = new DemoPOJO("east", 22.2, Instant.now());writeApiBlocking.writeMeasurement(WritePrecision.MS,demoPOJO);// 3. 调用close方法会关闭并释放一些比如守护线程之类的对象。influxDBClient.close();}
}

4、异步写入

import com.influxdb.client.InfluxDBClient;
import com.influxdb.client.InfluxDBClientFactory;
import com.influxdb.client.WriteApi;
import com.influxdb.client.WriteOptions;
import com.influxdb.client.domain.WritePrecision;/*** @description: 通过异步的方式向InfluxDB写入数据*/
public class AsyncWrite {/** token 操作时需要换成自己的 **/private static char[] token = "token....".toCharArray();/** 组织名称 **/private static String org = "cxf";/** InfluxDB服务提供的url **/private static String url = "http://localhost:8086/";/** 存储桶名称 **/private static String bucket = "example_java";public static void main(String[] args) {// 0.创建InfluxDB的客户端InfluxDBClient influxDBClient = InfluxDBClientFactory.create(url, token, org, bucket);// 1.异步写入会创建一个守护线程，所以在makWriteApi时可以传递一些配置项，也就是WriteOptions对象WriteOptions options = WriteOptions.builder().batchSize(999).flushInterval(10000).build();// 2.使用makeWriteApi创建的WriteApi writeApi = influxDBClient.makeWriteApi(options);for (int i = 0; i < 999; i++) {writeApi.writeRecord(WritePrecision.MS,"temperature,location=south value=77");}// 3.关闭连接，此方法会触发一次刷写，将缓冲区中剩下的数据向InfluxDB写入一次。influxDBClient.close();}
}

5、查询

import com.influxdb.client.BucketsApi;
import com.influxdb.client.InfluxDBClient;
import com.influxdb.client.InfluxDBClientFactory;
import com.influxdb.client.QueryApi;
import com.influxdb.client.domain.File;
import com.influxdb.query.FluxColumn;
import com.influxdb.query.FluxRecord;
import com.influxdb.query.FluxTable;import java.util.List;
import java.util.Map;/*** @description: 这是关于从InfluxDB查询数据的代码*/
public class Query {/** token 操作时需要换成自己的 **/private static char[] token = "token....".toCharArray();/** 组织名称 **/private static String org = "cxf";/** InfluxDB服务提供的url **/private static String url = "http://localhost:8086/";public static void main(String[] args) {// 0.创建InfluxDB客户端对象InfluxDBClient influxDBClient = InfluxDBClientFactory.create(url, token, org);// 1.获取查询API对象QueryApi queryApi = influxDBClient.getQueryApi();// 2.这个flux脚本会查询test_init存储桶中的go_goroutines测量，这个测量下只有一个序列String flux = "from(bucket: \"test_init\")\n" +"  |> range(start: -1h)\n" +"  |> filter(fn: (r) => r[\"_measurement\"] == \"go_goroutines\")\n" +"  |> aggregateWindow(every: 10s, fn: mean, createEmpty: false)\n" +"  |> yield(name: \"mean\")";// 3.这个flux脚本会查询example02存储桶中的cpu测量，指定字段名称为usage_user后，String flux2 = "from(bucket: \"example02\")\n" +"  |> range(start: -1h)\n" +"  |> filter(fn: (r) => r[\"_measurement\"] == \"cpu\")\n" +"  |> filter(fn: (r) => r[\"_field\"] == \"usage_user\")\n" +"  |> aggregateWindow(every: 10s, fn: mean, createEmpty: false)\n" +"  |> yield(name: \"mean\")";// 4.使用query方法将会得到一个List<FluxTable>对象，其中每一个FluxTable都对应着一个序列List<FluxTable> query = queryApi.query(flux);// 5.下面这个for循环会把遍历每个序列，并将这个序列中对应的每一行数据打印出来。for (FluxTable fluxTable : query) {List<FluxRecord> records = fluxTable.getRecords();for (FluxRecord record : records) {Map<String, Object> one = record.getValues();System.out.println(one);}}// 6.下面的queryRaw方法将会得到一个字符串，字符串中是FLUX拓展的CSV格式的数据String data = queryApi.queryRaw(flux2);System.out.println(data);}
}

时序数据库：Influxdb详解

文章目录一、简介1、简介2、官网二、部署1、安装2、配置（1）用户初始化三、入门（Web UI）1、加载数据（1）上传数据文件（2）代码接入模板 2、管理存储桶（1）创建…...

编程日记 2025/7/6 16:18:27

内存泄漏及检测办法

什么情况下会产生内存泄漏？ 内存泄漏如何检测？ 使用 valgrind 对象计数基本思路： 在对象的构造函数中增加计数：每次创建一个对象时，增加一个计数。在对象的析构函数中减少计数：每次销毁一个对象时&…...

编程日记 2025/7/4 12:39:54

BiGRU双向门控循环单元多变量多步预测，光伏功率预测（Matlab完整源码和数据)

代码地址：BiGRU双向门控循环单元多变量多步预测，光伏功率预测（Matlab完整源码和数据) BiGRU双向门控循环单元多变量多步预测，光伏功率预测一、引言 1.1、研究背景和意义随着全球对可再生能源需求的不断增长，光伏…...

编程日记 2025/7/5 22:22:45

Leetcode 3448. Count Substrings Divisible By Last Digit

Leetcode 3448. Count Substrings Divisible By Last Digit 1. 解题思路2. 代码实现题目链接：3448. Count Substrings Divisible By Last Digit 1. 解题思路这一题的话我们走的是一个累积数组的思路。首先，我们使用一个cache数组记录下任意段数字…...

编程日记 2025/7/7 9:08:43

青少年编程与数学 02-009 Django 5 Web 编程 03课题、项目结构

青少年编程与数学 02-009 Django 5 Web 编程 03课题、项目结构一、项目结构项目根目录应用目录其他目录二、项目设置Django 插件设置项目配置环境变量设置项目目录标记版本控制三、Django 插件安装 Django 插件配置 Django 插件使用 Django 插件功能四、扩展插件开发效率插…...

编程日记 2025/7/7 6:29:08

【玩转 Postman 接口测试与开发2_018】第14章：利用 Postman 初探 API 安全测试

《API Testing and Development with Postman》最新第二版封面文章目录第十四章 API 安全测试1 OWASP API 安全清单1.1 相关背景1.2 OWASP API 安全清单1.3 认证与授权1.4 破防的对象级授权（Broken object-level authorization）1.5 破防的属性级授权&a…...

编程日记 2025/7/7 11:12:11

UA-Track：不确定性感知端到端3D多目标跟踪

论文地址：https://arxiv.org/pdf/2406.02147 主页：https://liautoad.github.io/ua-track-website/ 3D多目标跟踪（MOT）在自动驾驶感知中起着至关重要的作用。最近基于端到端查询的跟踪器可以同时检测和跟踪对象，这在3D …...

编程日记 2025/7/1 16:10:18

Windows下AMD显卡在本地运行大语言模型(deepseek-r1)

Windows下AMD显卡在本地运行大语言模型本人电脑配置第一步先在官网确认自己的 AMD 显卡是否支持 ROCm下载Ollama安装程序模型下载位置更改下载 ROCmLibs先确认自己显卡的gfx型号下载解压替换替换rocblas.dll替换library文件夹下的所有重启Ollama下载模型运行效果本人电脑配…...

编程日记 2025/7/6 5:06:35

萌新学 Python 之字符串及字符串相关函数

字符串：单引号、双引号、三个单引号、三个双引号字符串属于不可变的数据类型，一旦被定义，内存地址不变 name 张三 # 字符串赋值给name后，内存地址存储张三，地址不变 username 张三 # 张三去内存中找…...

编程日记 2025/7/7 4:04:32

【鸿蒙开发】第二十四章 AI - Core Speech Kit（基础语音服务）

目录 1 简介 1.1 场景介绍 1.2 约束与限制 2 文本转语音 2.1 场景介绍 2.2 约束与限制 2.3 开发步骤 2.4 设置播报策略 2.4.1 设置单词播报方式 2.4.2 设置数字播报策略 2.4.3 插入静音停顿 2.4.4 指定汉字发音 2.5 开发实例 3 语音识别 3.1 场景介绍 3.2 约束…...

编程日记 2025/7/6 11:12:43

Java | RESTful 接口规范

关注：CodingTechWork 引言作为一名程序员，制定清晰、一致且高效的 RESTful 接口规范对于团队的开发效率和项目的长期维护至关重要。本文将详细介绍 RESTful 接口的设计理念、请求方法分类、核心规范，以及正确和错误的示例，帮助团…...

编程日记 2025/7/6 20:01:20

shell脚本控制——处理信号

Linux利用信号与系统中的进程进行通信。你可以通过对脚本进行编程，使其在收到特定信号时执行某些命令，从而控制shell脚本的操作。 1.重温Linux信号 Linux系统和应用程序可以产生超过30个信号。下表列出了在shell脚本编程时会遇到的最常见的Linux系统信…...

编程日记 2025/7/6 17:52:17

OpenGL学习笔记（十二）：初级光照：投光物/多光源（平行光、点光源、聚光）

文章目录平行光点光源聚光多光源现实世界中，我们有很多种类的光照，每种的表现都不同。将光投射(Cast)到物体的光源叫做投光物(Light Caster)。平行光/定向光(Directional Light)点光源(Point Light)聚光(Spotlight) 平行光当一个光源处于很远的地…...

编程日记 2025/7/5 20:45:50

redis底层数据结构——整数集合

文章目录定义内部实现升级升级的好处提升灵活性节约内存降级总结定义整数集合（intset）是集合键的底层实现之一，当一个集合只包含整数值元素，并且这个集合的元素数量不多时，Redis就会使用整数集合作为集合键的底层…...

编程日记 2025/7/6 4:11:00

w198基于Springboot的智能家居系统

🙊作者简介：多年一线开发工作经验，原创团队，分享技术代码帮助学生学习，独立完成自己的网站项目。代码可以查看文章末尾⬇️联系方式获取，记得注明来意哦~🌹赠送计算机毕业设计600个选题excel文…...

编程日记 2025/7/6 13:31:57

【JavaScript】《JavaScript高级程序设计 (第4版) 》笔记-Chapter2-HTML 中的 JavaScript

二、HTML 中的 JavaScript 将 JavaScript 插入 HTML 的主要方法是使用<script>元素。 <script>元素有下列 8 个属性。 async：可选。表示应该立即开始下载脚本，但不能阻止其他页面动作，比如下载资源或等待其他脚本加载。只对外部…...

编程日记 2025/7/6 18:33:20

【5】阿里面试题整理

[1]. 介绍一下ZooKeeper ZooKeeper是一个开源的分布式协调服务，核心功能是通过树形数据模型（ZNode）和Watch机制，解决分布式系统的一致性问题。它使用ZAB协议保障数据一致性，典型场景包括分布式锁、配置管理和服务注…...

编程日记 2025/7/6 19:08:11

系统思考—自我超越

“人们往往认为是个人的能力限制了他们，但事实上，是组织的结构和惯性思维限制了他们的潜力。”—彼得圣吉最近和一家行业隐形冠军交流，他们已经是领域第一，老板却依然要求：核心团队都要自我超越，攻坚克难…...

编程日记 2025/7/6 12:11:54

大模型-ALIGN 详细介绍

ALIGN模型（A Large-scale ImaGe and Noisy-text embedding）是一种大规模图像和噪声文本嵌入模型，它通过对比学习的方式将图像和文本嵌入到同一个向量空间中，使得匹配的图像-文本对的嵌入向量接近，不匹配的则远离。这种…...

编程日记 2025/7/6 18:48:37

【C++高并发服务器WebServer】-15：poll、epoll详解及实现

本文目录一、poll二、epoll2.1 相对poll和select的优点2.2 epoll的api2.3 epoll的demo实现2.5 epoll的工作模式一、poll poll是对select的一个改进，我们先来看看select的缺点。我们来看看poll的实现。 struct pollfd {int fd; /* 委托内核检测的文件描述符 */s…...

编程日记 2025/7/6 18:10:46

【算法】动态规划专题⑩ —— 混合背包问题 python

目录前置知识进入正题总结前置知识【算法】动态规划专题⑤ —— 0-1背包问题滚动数组优化【算法】动态规划专题⑥ —— 完全背包问题 python 【算法】动态规划专题⑦ —— 多重背包问题二进制分解优化 python 混合背包结合了三种不同类型的背包问题：0/1背包…...

编程日记 2025/7/7 11:03:02

Java高频面试之SE-20

hello啊，各位观众姥爷们！！！本baby今天又来了！哈哈哈哈哈嗝🐶 Java的泛型是什么？ Java 泛型（Generics） 是 Java 5 引入的一项重要特性，用于增强代码的类型安…...

编程日记 2025/7/6 18:18:21

springboot 事务管理

在Spring Boot中，事务管理是通过Spring框架的事务管理模块来实现的。Spring提供了声明式事务管理和编程式事务管理两种方式。通常，我们使用声明式事务管理，因为它更简洁且易于维护。 1. 声明式事务管理声明式事务管理是通过注解来实现的。…...

编程日记 2025/7/7 9:18:38

opentelemetry-collector 配置elasticsearch

一、修改otelcol-config.yaml receivers:otlp:protocols:grpc:endpoint: 0.0.0.0:4317http:endpoint: 0.0.0.0:4318 exporters:debug:verbosity: detailedotlp/jaeger: # Jaeger supports OTLP directlyendpoint: 192.168.31.161:4317tls:insecure: trueotlphttp/prometheus: …...

编程日记 2025/7/6 20:33:59

文章目录

一、简介

1、简介

2、官网

二、部署

1、安装

2、配置

（1）用户初始化

三、入门（Web UI）

1、加载数据

（1）上传数据文件

（2）代码接入模板

2、管理存储桶

（1）创建桶

（2）修改桶

3、演示：测试录入数据

4、Telegraf集成

5、管理抓取任务

6、管理 API Token

7、使用Data Explorer

（1）查询构造器

（2）FLUX 脚本编辑器

（3）数据预览区

（4）数据导出为CSV

8、使用Notebook

四、Flux语法

五、HTTP API

六、Java操作Influxdb

1、导包

2、POJO

3、同步写入

4、异步写入

5、查询

相关文章：