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 data  \"db_name\"

#显示所有的数据库
show data s

#删除数据库
drop data  \"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,  >()
  {
   { \"Id\", 158}
  },
  Fields = new Dictionary<string,  >()
  {
   { \"Val\", \"webInfo\" }
  },
  Timestamp = DateTime.UtcNow
  };
  var dbName = \"code-hub\";

  //从指定库中写入数据，支持传入多个对象的集合
  var response = await clientDb.Client.WriteAsync(point_model, dbName);
 }
 }
}