ASP.NET Core2中如何讀寫InfluxDB時(shí)序數(shù)據(jù)庫

本篇文章給大家分享的是有關(guān)ASP.NET Core2中如何讀寫InfluxDB時(shí)序數(shù)據(jù)庫，小編覺得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。

InfluxDB簡(jiǎn)介

InfluxDB是一個(gè)基于時(shí)間序列數(shù)據(jù)而開發(fā)的高性能數(shù)據(jù)存儲(chǔ)平臺(tái)，它可以對(duì)時(shí)序數(shù)據(jù)進(jìn)行高吞吐量的攝取、壓縮和實(shí)時(shí)查詢。InfluxDB是用Go語言編寫的，它會(huì)編譯成一個(gè)沒有外部依賴的二進(jìn)制文件來運(yùn)行，支持Java、JavaScript、c#等語言。InfluxDB支持類似SQL的查詢語言，同時(shí)還支持正則表達(dá)式、算術(shù)表達(dá)式和時(shí)間序列特定函數(shù)以加速數(shù)據(jù)的處理效率。如下是跟InfluxDB相關(guān)的網(wǎng)址：

InfluxDB官網(wǎng)：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/

特點(diǎn)：

• 無結(jié)構(gòu)(無模式)：可以是任意數(shù)量的列

• 可以設(shè)置metric的保存時(shí)間

• 支持與時(shí)間有關(guān)的相關(guān)函數(shù)(如min、max、sum、count、mean、median等)，方便統(tǒng)計(jì)

• 支持存儲(chǔ)策略:可以用于數(shù)據(jù)的刪改。(influxDB沒有提供數(shù)據(jù)的刪除與修改方法)

• 支持連續(xù)查詢:是數(shù)據(jù)庫中自動(dòng)定時(shí)啟動(dòng)的一組語句，和存儲(chǔ)策略搭配可以降低InfluxDB的系統(tǒng)占用量。

• 原生的HTTP支持，內(nèi)置HTTP API

• 支持類似sql語法

• 支持設(shè)置數(shù)據(jù)在集群中的副本數(shù)

• 支持定期采樣數(shù)據(jù)，寫入另外的measurement，方便分粒度存儲(chǔ)數(shù)據(jù)。

• 自帶web管理界面，方便使用(登入方式：http://:8083)

InfluxDB操作

這里將會(huì)簡(jiǎn)單的介紹下如何操作InfluxDB，通過這些操作基本也能滿足工作上的需要了。操作InfluxDB可以通過命令行工具，也可借助開源的客戶端工具，我這里使用的是一款名叫“InfluxDBStudio”基于C#編寫的開源工具。常用操作的代碼如下：

#顯示用戶
show users

#創(chuàng)建用戶
create user "username" with password 'password'

#創(chuàng)建管理員權(quán)限用戶
create user "username" with password 'password' with all privileges

#刪除用戶
drop user "username"

#創(chuàng)建數(shù)據(jù)庫
create database "db_name"

#顯示所有的數(shù)據(jù)庫
show databases

#刪除數(shù)據(jù)庫
drop database "db_name"

#使用數(shù)據(jù)庫
use db_name

#顯示該數(shù)據(jù)庫中所有的表
show measurements

#創(chuàng)建表，直接在插入數(shù)據(jù)的時(shí)候指定表名，其中test為表名
insert test,host=127.0.0.1,monitor_name=test count=1

#刪除表
drop measurement "measurement_name"

#查詢數(shù)據(jù)
select * from test order by time desc

#查看當(dāng)前數(shù)據(jù)庫的數(shù)據(jù)保存策略（Retention Policies）
show retention policies on "db_name"

#創(chuàng)建新的數(shù)據(jù)保存策略
#rp_name：策略名
#db_name：具體的數(shù)據(jù)庫名；
#3w：保存3周，3周之前的數(shù)據(jù)將被刪除，influxdb具有各種事件參數(shù)，比如：h（小時(shí)），d（天），w（星期）
#replication 1：副本個(gè)數(shù)，一般為1就可以了
#default：設(shè)置為默認(rèn)策略
create retention policy "rp_name" on "db_name" duration 3w replication 1 default

#修改數(shù)據(jù)保存策略
alter retention policy "rp_name" on "db_name" duration 30d default

#刪除數(shù)據(jù)保存策略
drop retention policy "rp_name"

#查看數(shù)據(jù)庫的連續(xù)查詢（Continous Queries）
show continuous queries

#創(chuàng)建新的連續(xù)查詢（Continous Queries）
#cq_name：連續(xù)查詢名字
#db_name：數(shù)據(jù)庫名字
#sum(count)：計(jì)算總和
#table_name：當(dāng)前表名
#new_table_name：存新的數(shù)據(jù)的表名
#30m：時(shí)間間隔為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

#刪除連續(xù)查詢
drop continous query cp_name on db_name

實(shí)現(xiàn)

通過上述的介紹與操作我們已基本熟悉了InfluxDB數(shù)據(jù)庫，那么接下來咱們就一起來看看在ASP.NET Core2程序中如何來讀寫操作InfluxDB數(shù)據(jù)庫吧。而這里我們借助一個(gè)名為“InfluxData.Net”的第三方庫來與InfluxDB交互通訊，基于“InfluxData.Net”庫可以使得我們很簡(jiǎn)單的完成數(shù)據(jù)庫的讀寫操作。在ASP.NET Core2項(xiàng)目中通過Nuget管理器引用“InfluxData.Net”類庫后，敲入實(shí)現(xiàn)代碼如下：

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地址、賬號(hào)、密碼
  var infuxUrl = "http://localhost:8086/";
  var infuxUser = "admin";
  var infuxPwd = "admin";

  //創(chuàng)建InfluxDbClient實(shí)例
  clientDb = new InfluxDbClient(infuxUrl, infuxUser, infuxPwd, InfluxDbVersion.Latest);
 }


 /// <summary>
 /// 從InfluxDB中讀取數(shù)據(jù)
 /// </summary>
 public async void GetData()
 {
  //傳入查詢命令，支持多條
  var queries = new[]
  {
  " SELECT * FROM Reading WHERE time> now() - 24h "
  };
  var dbName = "code-hub";

  //從指定庫中查詢數(shù)據(jù)
  var response = await clientDb.Client.QueryAsync(queries, dbName);
  //得到Serie集合對(duì)象（返回執(zhí)行多個(gè)查詢的結(jié)果）
  var series = response.ToList();
  //取出第一條命令的查詢結(jié)果，是一個(gè)集合
  var list = series[0].Values;
  //從集合中取出第一條數(shù)據(jù)
  var info_model = list.FirstOrDefault();
 }



 /// <summary>
 /// 往InfluxDB中寫入數(shù)據(jù)
 /// </summary>
 public async void AddData()
 {
  //基于InfluxData.Net.InfluxDb.Models.Point實(shí)體準(zhǔn)備數(shù)據(jù)
  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";

  //從指定庫中寫入數(shù)據(jù)，支持傳入多個(gè)對(duì)象的集合
  var response = await clientDb.Client.WriteAsync(point_model, dbName);
 }
 }
}

以上就是ASP.NET Core2中如何讀寫InfluxDB時(shí)序數(shù)據(jù)庫，小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘９ぷ鲿?huì)見到或用到的。希望你能通過這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注億速云行業(yè)資訊頻道。