前言
在我们很多应用中会遇到有一种基于一系列时间的数据需要处理,通过时间的顺序可以将这些数据点连成线,再通过数据统计后可以做成多纬度的报表,也可通过机器学习来实现数据的预测告警。而时序数据库就是用于存放管理这种有着时间顺序数据的,时序数据库一般都支持时序数据的快速写入、持久化、多纬度的聚合查询等基本功能。
InfluxDB简介
InfluxDB是一个基于时间序列数据而开发的高性能数据存储平台,它可以对时序数据进行高吞吐量的摄取、压缩和实时查询。InfluxDB是用Go语言编写的,它会编译成一个没有外部依赖的二进制文件来运行,支持Java、JavaScript、c#等语言。InfluxDB支持类似SQL的查询语言,同时还支持正则表达式、算术表达式和时间序列特定函数以加速数据的处理效率。如下是跟InfluxDB相关的网址:
InfluxDB官网:https://mon.Enums;using InfluxData.Net.InfluxDb;using InfluxData.Net.InfluxDb.Models;using Microsoft.AspNetCore.Mvc;namespace WebApplication1.Controllers{ public class InfoController : Controller { //声明InfluxDbClient private InfluxDbClient clientDb; public InfoController() { //连接InfluxDb的API地址、账号、密码 var infuxUrl = "http://localhost:8086/"; var infuxUser = "admin"; var infuxPwd = "admin"; //创建InfluxDbClient实例 clientDb = new InfluxDbClient(infuxUrl, infuxUser, infuxPwd, InfluxDbVersion.Latest); } /// <summary> /// 从InfluxDB中读取数据 /// </summary> public async void GetData() { //传入查询命令,支持多条 var queries = new[] { " SELECT * FROM Reading WHERE time> now() - 24h " }; var dbName = "code-hub"; //从指定库中查询数据 var response = await clientDb.Client.QueryAsync(queries, dbName); //得到Serie集合对象(返回执行多个查询的结果) var series = response.ToList(); //取出第一条命令的查询结果,是一个集合 var list = series[0].Values; //从集合中取出第一条数据 var info_model = list.FirstOrDefault(); } /// <summary> /// 往InfluxDB中写入数据 /// </summary> public async void AddData() { //基于InfluxData.Net.InfluxDb.Models.Point实体准备数据 var point_model = new Point() { Name = "Reading",//表名 Tags = new Dictionary<string, object>() { { "Id", 158} }, Fields = new Dictionary<string, object>() { { "Val", "webInfo" } }, Timestamp = DateTime.UtcNow }; var dbName = "code-hub"; //从指定库中写入数据,支持传入多个对象的集合 var response = await clientDb.Client.WriteAsync(point_model, dbName); } }}
总结
1、InfluxDB是个专业的时序数据库,通过时序库可帮助我们更高效的处理应用中的时序数据。
2、使用InfluxDB库时需先了解该库的一些特色功能,如数据保存策略、连续查询等。
3、通过“InfluxData.Net”类库可快速简便的帮助我们在ASP.NET Core2程序中实现对InfluxDB的读写操作。
好了,以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对的支持。