ASP.NET Core2读写InfluxDB时序数据库的方法教程
前言
在我们很多应用中会遇到有一种基于一系列时间的数据需要处理,通过时间的顺序可以将这些数据点连成线,再通过数据统计后可以做成多纬度的报表,也可通过机器学习来实现数据的预测告警。而时序数据库就是用于存放管理这种有着时间顺序数据的,时序数据库一般都支持时序数据的快速写入、持久化、多纬度的聚合查询等基本功能。
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/
特点:
- 无结构(无模式):可以是任意数量的列
- 可以设置metric的保存时间
- 支持与时间有关的相关函数(如min、max、sum、count、mean、median等),方便统计
- 支持存储策略:可以用于数据的删改。(influxdb没有提供数据的删除与修改方法)
- 支持连续查询:是数据库中自动定时启动的一组语句,和存储策略搭配可以降低influxdb的系统占用量。
- 原生的http支持,内置http api
- 支持类似sql语法
- 支持设置数据在集群中的副本数
- 支持定期采样数据,写入另外的measurement,方便分粒度存储数据。
- 自带web管理界面,方便使用(登入方式:http://:8083)
influxdb操作
这里将会简单的介绍下如何操作influxdb,通过这些操作基本也能满足工作上的需要了。操作influxdb可以通过命令行工具,也可借助开源的客户端工具,我这里使用的是一款名叫“influxdbstudio”基于c#编写的开源工具。常用操作的代码如下:
#显示用户 show users #创建用户 create user "username" with password 'password' #创建管理员权限用户 create user "username" with password 'password' with all privileges #删除用户 drop user "username" #创建数据库 create database "db_name" #显示所有的数据库 show databases #删除数据库 drop database "db_name" #使用数据库 use db_name #显示该数据库中所有的表 show measurements #创建表,直接在插入数据的时候指定表名,其中test为表名 insert test,host=127.0.0.1,monitor_name=test count=1 #删除表 drop measurement "measurement_name" #查询数据 select * from test order by time desc #查看当前数据库的数据保存策略(retention policies) show retention policies on "db_name" #创建新的数据保存策略 #rp_name:策略名 #db_name:具体的数据库名; #3w:保存3周,3周之前的数据将被删除,influxdb具有各种事件参数,比如:h(小时),d(天),w(星期) #replication 1:副本个数,一般为1就可以了 #default:设置为默认策略 create retention policy "rp_name" on "db_name" duration 3w replication 1 default #修改数据保存策略 alter retention policy "rp_name" on "db_name" duration 30d default #删除数据保存策略 drop retention policy "rp_name" #查看数据库的连续查询(continous queries) show continuous queries #创建新的连续查询(continous queries) #cq_name:连续查询名字 #db_name:数据库名字 #sum(count):计算总和 #table_name:当前表名 #new_table_name:存新的数据的表名 #30m:时间间隔为30分钟 create continous query cq_name on db_name begin select sum(count) into new_table_name from table_name group by time(30m) end #删除连续查询 drop continous query cp_name on db_name
实现
通过上述的介绍与操作我们已基本熟悉了influxdb数据库,那么接下来咱们就一起来看看在asp.net core2程序中如何来读写操作influxdb数据库吧。而这里我们借助一个名为“influxdata.net”的第三方库来与influxdb交互通讯,基于“influxdata.net”库可以使得我们很简单的完成数据库的读写操作。在asp.net core2项目中通过nuget管理器引用“influxdata.net”类库后,敲入实现代码如下:
using system; using system.collections.generic; using system.linq; using system.threading.tasks; using influxdata.net.common.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的读写操作。
好了,以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对的支持。
上一篇: 不要用强制方法杀掉python线程