腾海燕
ASP.NET Core2读写InfluxDB时序数据库
来源:唐明亮     发布时间: 2019-04-22      浏览次数:249

字号:

在我们很多应用中会遇到有一种基于一系列时间的数据需要处理,通过时间的顺序可以将这些数据点连成线,再通过数据统计后可以做成多纬度的报表,也可通过机器学习来实现数据的预测告警。而时序数据库就是用于存放管理这种有着时间顺序数据的,时序数据库一般都支持时序数据的快速写入、持久化、多纬度的聚合查询等基本功能。

 

InfluxDB简介

InfluxDB是一个基于时间序列数据而开发的高性能数据存储平台,它可以对时序数据进行高吞吐量的摄取、压缩和实时查询。InfluxDB是用Go语言编写的,它会编译成一个没有外部依赖的二进制文件来运行,支持Java、JavaScript、c#等语言。InfluxDB支持类似SQL的查询语言,同时还支持正则表达式、算术表达式和时间序列特定函数以加速数据的处理效率。如下是跟InfluxDB相关的网址:

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

InfluxDB官方文档:https://docs.influxdata.com/influxdb/

InfluxDB官方下载:https://portal.influxdata.com/downloads

InfluxDB客户端工具下载:https://docs.influxdata.com/influxdb/v1.6/tools/api_client_libraries/

 

InfluxDB操作

这里将会简单的介绍下如何操作InfluxDB,通过这些操作基本也能满足工作上的需要了。操作InfluxDB可以通过命令行工具,也可借助开源的客户端工具,我这里使用的是一款名叫“InfluxDBStudio”基于C#编写的开源工具。常用操作的代码如下:

1 #显示用户 2 show users 3 4 #创建用户 5 create user "username" with password "password" 6 7 #创建管理员权限用户 8 create user "username" with password "password" with all privileges 9 10 #删除用户 11 drop user "username" 12 13 #创建数据库 14 create database "db_name" 15 16 #显示所有的数据库 17 show databases 18 19 #删除数据库 20 drop database "db_name" 21 22 #使用数据库 23 use db_name 24 25 #显示该数据库中所有的表 26 show measurements 27 28 #创建表,直接在插入数据的时候指定表名,其中test为表名 29 insert test,host=127.0.0.1,monitor_name=test count=1 30 31 #删除表 32 drop measurement "measurement_name" 33 34 #查询数据 35 select * from test order by time desc 36 37 #查看当前数据库的数据保存策略(Retention Policies) 38 show retention policies on "db_name" 39 40 #创建新的数据保存策略 41 #rp_name:策略名 42 #db_name:具体的数据库名; 43 #3w:保存3周,3周之前的数据将被删除,influxdb具有各种事件参数,比如:h(小时),d(天),w(星期) 44 #replication 1:副本个数,一般为1就可以了 45 #default:设置为默认策略 46 create retention policy "rp_name" on "db_name" duration 3w replication 1 default 47 48 #修改数据保存策略 49 alter retention policy "rp_name" on "db_name" duration 30d default 50 51 #删除数据保存策略 52 drop retention policy "rp_name" 53 54 #查看数据库的连续查询(Continous Queries) 55 show continuous queries 56 57 #创建新的连续查询(Continous Queries) 58 #cq_name:连续查询名字 59 #db_name:数据库名字 60 #sum(count):计算总和 61 #table_name:当前表名 62 #new_table_name:存新的数据的表名 63 #30m:时间间隔为30分钟 64 create continous query cq_name on db_name begin select sum(count) into new_table_name from table_name group by time(30m) end 65 66 #删除连续查询 67 drop continous query cp_name on db_name 68

 

实现

通过上述的介绍与操作我们已基本熟悉了InfluxDB数据库,那么接下来咱们就一起来看看在ASP.NET Core2程序中如何来读写操作InfluxDB数据库吧。而这里我们借助一个名为“InfluxData.Net”的第三方库来与InfluxDB交互通讯,基于“InfluxData.Net”库可以使得我们很简单的完成数据库的读写操作。在ASP.NET Core2项目中通过Nuget管理器引用“InfluxData.Net”类库后,敲入实现代码如下:

1 using System; 2 using System.Collections.Generic; 3 using System.Linq; 4 using System.Threading.Tasks; 5 using InfluxData.Net.Common.Enums; 6 using InfluxData.Net.InfluxDb; 7 using InfluxData.Net.InfluxDb.Models; 8 using Microsoft.AspNetCore.Mvc; 9 10 namespace WebApplication1.Controllers 11 { 12 public class InfoController : Controller 13 { 14 //声明InfluxDbClient 15 private InfluxDbClient clientDb; 16 17 public InfoController() 18 { 19 //连接InfluxDb的API地址、账号、密码 20 var infuxUrl = "http://localhost:8086/"; 21 var infuxUser = "admin"; 22 var infuxPwd = "admin"; 23 24 //创建InfluxDbClient实例 25 clientDb = new InfluxDbClient(infuxUrl, infuxUser, infuxPwd, InfluxDbVersion.Latest); 26 } 27 28 29 /// <summary> 30 /// 从InfluxDB中读取数据 31 /// </summary> 32 public async void GetData() 33 { 34 //传入查询命令,支持多条 35 var queries = new[] 36 { 37 " SELECT * FROM Reading WHERE time> now() - 24h " 38 }; 39 var dbName = "code-hub"; 40 41 //从指定库中查询数据 42 var response = await clientDb.Client.QueryAsync(queries, dbName); 43 //得到Serie集合对象(返回执行多个查询的结果) 44 var series = response.ToList(); 45 //取出第一条命令的查询结果,是一个集合 46 var list = series[0].Values; 47 //从集合中取出第一条数据 48 var info_model = list.FirstOrDefault(); 49 } 50 51 52 53 /// <summary> 54 /// 往InfluxDB中写入数据 55 /// </summary> 56 public async void AddData() 57 { 58 //基于InfluxData.Net.InfluxDb.Models.Point实体准备数据 59 var point_model = new Point() 60 { 61 Name = "Reading",//表名 62 Tags = new Dictionary<string, object>() 63 { 64 { "Id", 158} 65 }, 66 Fields = new Dictionary<string, object>() 67 { 68 { "Val", "webInfo" } 69 }, 70 Timestamp = DateTime.UtcNow 71 }; 72 var dbName = "code-hub"; 73 74 //从指定库中写入数据,支持传入多个对象的集合 75 var response = await clientDb.Client.WriteAsync(point_model, dbName); 76 } 77 } 78 }

 

总结

1、InfluxDB是个专业的时序数据库,通过时序库可帮助我们更高效的处理应用中的时序数据。

2、使用InfluxDB库时需先了解该库的一些特色功能,如数据保存策略、连续查询等。

3、通过“InfluxData.Net”类库可快速简便的帮助我们在ASP.NET Core2程序中实现对InfluxDB的读写操作。

 

声明

本文为作者原创,转载请备注出处与保留原文地址,谢谢。如文章能给您带来帮助,请点下推荐或关注,感谢您的支持!

 

  • 相关内容: