在我們很多應(yīng)用中會(huì)遇到有一種基于一系列時(shí)間的數(shù)據(jù)需要處理，通過時(shí)間的順序可以將這些數(shù)據(jù)點(diǎn)連成線，再通過數(shù)據(jù)統(tǒng)計(jì)后可以做成多緯度的報(bào)表，也可通過機(jī)器學(xué)習(xí)來實(shí)現(xiàn)數(shù)據(jù)的預(yù)測(cè)告警。而時(shí)序數(shù)據(jù)庫就是用于存放管理這種有著時(shí)間順序數(shù)據(jù)的，時(shí)序數(shù)據(jù)庫一般都支持時(shí)序數(shù)據(jù)的快速寫入、持久化、多緯度的聚合查詢等基本功能。

?

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/

?

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", "5810953" }

? ? ? ? ? ? ? ? },

? ? ? ? ? ? ? ? Fields = new Dictionary<string, object>()

? ? ? ? ? ? ? ? {

? ? ? ? ? ? ? ? ? ? { "Val",102 }

? ? ? ? ? ? ? ? },

? ? ? ? ? ? ? ? Timestamp = DateTime.UtcNow

? ? ? ? ? ? };

? ? ? ? ? ? var dbName = "code-hub";

? ? ? ? ? ? //從指定庫中寫入數(shù)據(jù)，支持傳入多個(gè)對(duì)象的集合

? ? ? ? ? ? var response = await clientDb.Client.WriteAsync(point_model, dbName);

? ? ? ? }

? ? }

}

總結(jié)

1、InfluxDB是個(gè)專業(yè)的時(shí)序數(shù)據(jù)庫，通過時(shí)序庫可幫助我們更高效的處理應(yīng)用中的時(shí)序數(shù)據(jù)。

2、使用InfluxDB庫時(shí)需先了解該庫的一些特色功能，如數(shù)據(jù)保存策略、連續(xù)查詢等。

3、通過“InfluxData.Net”類庫可快速簡(jiǎn)便的幫助我們?cè)贏SP.NET Core2程序中實(shí)現(xiàn)對(duì)InfluxDB的讀寫操作。

相關(guān)文章：

• AspNet Core下利用 app-metrics+Grafana + InfluxDB實(shí)現(xiàn)高大上的性能監(jiān)控界面

• .NET Core微服務(wù)之基于App.Metrics+InfluxDB+Grafana實(shí)現(xiàn)統(tǒng)一性能監(jiān)控

• Metrics.net + influxdb + grafana 構(gòu)建WebAPI的自動(dòng)化監(jiān)控和預(yù)警

• .Net Core 2.0+ InfluxDB+Grafana+App Metrics 實(shí)現(xiàn)跨平臺(tái)的實(shí)時(shí)性能監(jiān)控
  

原文地址:?https://www.cnblogs.com/Andre/p/9884051.html

---

.NET社區(qū)新聞，深度好文，歡迎訪問公眾號(hào)文章匯總 http://www.csharpkit.com

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的ASP.NET Core2读写InfluxDB时序数据库的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。