ASP.NET Core2读写InfluxDB时序数据库的方法教程

实现

通过上述的介绍与操作我们已基本熟悉了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的读写操作。

好了，以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对易采站长站的支持。