王俊凯的qq号,完美搭档下载,有什么好玩的网络游戏吗
在我们很多应用中会遇到有一种基于一系列时间的数据需要处理，通过时间的顺序可以将这些数据点连成线，再通过数据统计后可以做成多纬度的报表，也可通过机器学习来实现数据的预测告警。而时序数据库就是用于存放管理这种有着时间顺序数据的，时序数据库一般都支持时序数据的快速写入、持久化、多纬度的聚合查询等基本功能。
influxdb简介
influxdb是一个基于时间序列数据而开发的高性能数据存储平台，它可以对时序数据进行高吞吐量的摄取、压缩和实时查询。influxdb是用go语言编写的，它会编译成一个没有外部依赖的二进制文件来运行，支持java、javascript、c#等语言。influxdb支持类似sql的查询语言，同时还支持正则表达式、算术表达式和时间序列特定函数以加速数据的处理效率。如下是跟influxdb相关的网址：
influxdb官网：
influxdb官方文档：
influxdb官方下载：
influxdb客户端工具下载：
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的读写操作。
声明
本文为作者原创，转载请备注出处与保留原文地址，谢谢。如文章能给您带来帮助，请点下推荐或关注，感谢您的支持！
如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复
Blazor server side 自家的一些开源的, 实用型项目的进度之 CEF客户端
.NET IoC模式依赖反转(DIP)、控制反转(Ioc)、依赖注入(DI)
vue+.netcore可支持业务代码扩展的开发框架 VOL.Vue 2.0版本发布
网友评论