InfluxDB概念和基本操做

InfluxDB基本概念

數據格式

在 InfluxDB 中，咱們能夠粗略的將要存入的一條數據看做一個虛擬的 key 和其對應的 value(field value)。格式以下：

cpu_usage,host=server01,region=hn-zhengzhou value=0.64 1434055562000000000

虛擬的 key 包括如下幾個部分： database, retention policy, measurement, tag sets, field name, timestamp。

• database:數據庫名，在InfluxDB中，能夠建立多個database，不一樣數據庫中的數據文件是隔離的，存放在不一樣磁盤目錄中。
• retention policy:存儲策略，用於設置數據保留的時間每一個數據庫剛開始會自動建立一個默認的存儲策略 autogen，數據保留時間爲永久，以後用戶能夠本身設置，例如保留最近2小時的數據。插入和查詢數據時若是不指定存儲策略，則使用默認存儲策略，且默認存儲策略能夠修改。InfluxDB 會按期清除過時的數據
• measurement:對應關係數據庫中的表，測量指標名，例如 cpu_usage 表示 cpu 的使用率。
• tag sets: tags 在 InfluxDB 中會按照字典序排序，不論是 tagk 仍是 tagv，只要不一致就分別屬於兩個 key，例如 host=server01,region=hn-zhengzhou 和 host=server02,region=hn-zhengzhou 就是兩個不一樣的 tag set。
• tag--標籤，在InfluxDB中，tag是一個很是重要的部分，表名+tag一塊兒做爲數據庫的索引，是「key-value」的形式。
• field name: 例如上面數據中的 value 就是 fieldName，InfluxDB 中支持一條數據中插入多個 fieldName，這實際上是一個語法上的優化，在實際的底層存儲中，是看成多條數據來存儲
• timestamp: 每一條數據都須要指定一個時間戳，在 TSM 存儲引擎中會特殊對待，覺得了優化後續的查詢操做。

Point

points至關於關係數據庫中的行，Point由時間戳（time）、數據（field）、標籤（tags）組成。

Series

Series 至關因而 InfluxDB 中一些數據的集合，在同一個 database 中，retention policy、measurement、tag sets 徹底相同的數據同屬於一個 series，同一個 series 的數據在物理上會按照時間順序排列存儲在一塊兒。

Shard

Shard 在 InfluxDB 中是一個比較重要的概念，它和 retention policy 相關聯。每個存儲策略下會存在許多 shard，每個 shard 存儲一個指定時間段內的數據，而且不重複，例如 7點-8點 的數據落入 shard0 中，8點-9點的數據則落入 shard1 中。每個 shard 都對應一個底層的 tsm 存儲引擎，有獨立的 cache、wal、tsm file。

目錄與文件結構

InfluxDB 的數據存儲主要有三個目錄。默認狀況下是 meta, wal 以及 data 三個目錄。meta 用於存儲數據庫的一些元數據，meta 目錄下有一個 meta.db 文件。wal 目錄存放預寫日誌文件，以 .wal 結尾。data 目錄存放實際存儲的數據文件，以 .tsm 結尾。

InfluxDB基本操做

InfluxDB提供多種操做方式：

• 客戶端命令行方式
• HTTP API接口
• 各語言API庫
• 基於WEB管理頁面操做

客戶端命令行方式操做

進入命令行

influx
Connected to http://localhost:8086 version 1.2.4
InfluxDB shell version: 1.2.4

顯示數據庫

show databases;

新建數據庫

create database cpu_info;

使用制定數據庫

use cpu_info;

刪除數據庫

drop database cpu_info;

在InfluxDB當中，並無表（table）這個概念，取而代之的是MEASUREMENTS，MEASUREMENTS的功能與傳統數據庫中的表一致，所以咱們也能夠將MEASUREMENTS稱爲InfluxDB中的表

顯示全部表

show measurements

新建表

InfluxDB中沒有顯式的新建表的語句，只能經過insert數據的方式來創建新表。

insert disk_free,hostname=server01 value=442221834240i

其中 disk_free 就是表名，hostname是索引（tag），value=xx是記錄值（field），記錄值能夠有多個，系統自帶追加時間戳。或者添加數據時，本身寫入時間戳

insert disk_free,hostname=server01 value=442221834240i 1435362189575692182

刪除表

drop measurement disk_free

數據保存策略（Retention Policies)

influxDB是沒有提供直接刪除數據記錄的方法，可是提供數據保存策略，主要用於指定數據保留時間，超過指定時間，就刪除這部分數據。

查看當前數據庫Retention Policies

show retention policies on cpu_info;
name    duration shardGroupDuration replicaN default
----    -------- ------------------ -------- -------
autogen 0s       168h0m0s           1        true

建立新的Retention Policies

create retention policy "rp_name" on "db_name" duration 3w replication 1 default

• rp_name：策略名；
• db_name：具體的數據庫名；
• 3w：保存3周，3周以前的數據將被刪除，influxdb具備各類事件參數，好比：h（小時），d（天），w（星期）；
• replication 1：副本個數，通常爲1就能夠了；
• default：設置爲默認策略

修改Retention Policies

alter retention policy "rp_name" on "db_name" duration 30d default

刪除Retention Policies

drop retention policy "rp_name" on "db_name"

連續查詢（Continuous Queries）

InfluxDB的連續查詢是在數據庫中自動定時啓動的一組語句，語句中必須包含 SELECT 關鍵詞和 GROUP BY time() 關鍵詞。InfluxDB會將查詢結果放在指定的數據表中。

使用連續查詢是最優的下降採樣率的方式，連續查詢和存儲策略搭配使用將會大大下降InfluxDB的系統佔用量。並且使用連續查詢後，數據會存放到指定的數據表中，這樣就爲之後統計不一樣精度的數據提供了方便。

新建連續查詢語法以下：

CREATE CONTINUOUS QUERY <cq_name> ON <database_name>
[RESAMPLE [EVERY <interval>] [FOR <interval>]]
BEGIN SELECT <function>(<stuff>)[,<function>(<stuff>)] INTO <different_measurement>
FROM <current_measurement> [WHERE <stuff>] GROUP BY time(<interval>)[,<stuff>]
END

樣例：

CREATE CONTINUOUS QUERY wj_30m ON shhnwangjian BEGIN SELECT mean(connected_clients), MEDIAN(connected_clients), MAX(connected_clients), MIN(connected_clients) INTO redis_clients_30m FROM redis_clients GROUP BY ip,port,time(30m) END

在shhnwangjian庫中新建了一個名爲 wj_30m 的連續查詢，每三十分鐘取一個connected_clients字段的平均值、中位值、最大值、最小值 redis_clients_30m 表中。使用的數據保留策略都是 default。

顯示全部已存在的連續查詢

SHOW CONTINUOUS QUERIES

刪除Continuous Queries

DROP CONTINUOUS QUERY <cq_name> ON <database_name>