ASP.NET Core2读写InfluxDB时序数据库的方法教程_实用技巧

#显示用户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

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); } }}