在我們很多應用中會遇到有一種基于一系列時間的數據需要處理，通過時間的順序可以將這些數據點連成線，再通過數據統計后可以做成多緯度的報表，也可通過機器學習來實現數據的預測告警。而時序數據庫就是用于存放管理這種有著時間順序數據的，時序數據庫一般都支持時序數據的快速寫入、持久化、多緯度的聚合查詢等基本功能。

?

InfluxDB簡介

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

InfluxDB官網：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操作

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

#顯示用戶

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

實現

通過上述的介紹與操作我們已基本熟悉了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", "5810953" }

? ? ? ? ? ? ? ? },

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

? ? ? ? ? ? ? ? {

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

? ? ? ? ? ? ? ? },

? ? ? ? ? ? ? ? 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的讀寫操作。

相關文章：

• AspNet Core下利用 app-metrics+Grafana + InfluxDB實現高大上的性能監控界面

• .NET Core微服務之基于App.Metrics+InfluxDB+Grafana實現統一性能監控

• Metrics.net + influxdb + grafana 構建WebAPI的自動化監控和預警

• .Net Core 2.0+ InfluxDB+Grafana+App Metrics 實現跨平臺的實時性能監控
  

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

---

.NET社區新聞，深度好文，歡迎訪問公眾號文章匯總 http://www.csharpkit.com

創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。