influxdb创建数据库实例的保留策略和连续查询

素颜马尾好姑娘i 2022-03-16 09:52 448阅读 0赞

**目录**

保留策略

创建存储策略

查看数据库实例保留策略

连续查询

介绍：

基本语法：

案例需求

--------------------

## 保留策略 ##

### **创建存储策略** ###

>       duration：保留策略的属性决定数据库中的数据保留期间。大于这个期间的数据将会被删除。
> 
>      保留策略创建语法：
> 
>       CREATE RETENTION POLICY <retention\_policy\_name> ON <database\_name> DURATION <duration> REPLICATION <n> \[SHARD DURATION <duration>\] \[DEFAULT\]

CREATE RETENTION POLICY "k2h_raw" ON "dat_metrics" DURATION 2h0m0s REPLICATION 1 DEFAULT;
    CREATE RETENTION POLICY "k7d_s5m" ON "dat_metrics" DURATION 168h0m0s REPLICATION 1;
    CREATE RETENTION POLICY "k90d_s30m" ON "dat_metrics" DURATION 2160h0m0s REPLICATION 1;

创建连续查询
    CREATE CONTINUOUS QUERY bc_query_stat_sample_by_30m ON dat_metrics BEGIN SELECT last(*), mean(*), max(*), min(*) INTO dat_metrics.k90d_s30m.bc_query_stat FROM dat_metrics.k2h_raw.bc_query_stat GROUP BY time(30m), cloud_app_id, cloud_node_id, service END;
    
    修改保留策略语法
    ALTER RETENTION POLICY <retention_policy_name> ON <database_name> DURATION <duration> REPLICATION <n> SHARD DURATION <duration> DEFAUL
    
    alter retention policy "k2h_raw" on "dat_metrics" DEFAULT

### 查看数据库实例保留策略 ###

SHOW RETENTION POLICIES ON "dat\_metrics";

![2019022714560848.png][]

## **连续查询** ##

### 介绍： ###

连续查询(Continuous Queries下文统一简称CQ)是InfluxQL对实时数据自动周期运行的查询，然后把查询结果写入到指定的measurement中。

### 基本语法： ###

CREATE CONTINUOUS QUERY <cq_name> ON <database_name>
    BEGIN
      <cq_query>
    END

语法描述：

cq\_query

`cq_query`需要一个函数，一个`INTO`子句和一个`GROUP BY time()`子句：

SELECT <function[s]> INTO <destination_measurement> FROM <measurement> [WHERE <stuff>] GROUP BY time(<interval>)[,<tag_key[s]>]

运行时间点以及覆盖的时间范围

CQ对实时数据进行操作。他们使用本地服务器的时间戳，`GROUP BY time()`间隔和InfluxDB的预设时间边界来确定何时执行以及查询中涵盖的时间范围。

CQs以与`cq_query`的`GROUP BY time()`间隔相同的间隔执行，并且它们在InfluxDB的预设时间边界开始时运行。如果`GROUP BY time()`间隔为1小时，则CQ每小时开始执行一次。

当CQ执行时，它对于`now()`和`now()`减去`GROUP BY time()`间隔的时间范围运行单个查询。 如果`GROUP BY time()`间隔为1小时，当前时间为17:00，查询的时间范围为16:00至16:59999999999。

## 案例需求 ##

原始数据保留7天，5分钟采样数据保留一个月，30分钟采样数据保留一年。

以host\_metrics数据库为例：

第一步 修改保留策略为数据保留7天

alter retention policy "k2h\_raw" on "host\_metrics" DEFAULT

第二步 创建连续查询  
对host\_metrics数据中的cpu measurement进行创建连续查询

CREATE CONTINUOUS QUERY cpu_sample_by_5m ON host_metrics 
    BEGIN 
      SELECT last(*), mean(*), max(*), min(*) INTO host_metrics.k7d_s5m.cpu FROM host_metrics.k2h_raw.cpu GROUP BY time(5m), host, core_id 
    END
                  
    CREATE CONTINUOUS QUERY cpu_sample_by_30m ON host_metrics
    BEGIN
     SELECT last(*), mean(*), max(*), min(*) INTO host_metrics.k90d_s30m.cpu FROM host_metrics.k2h_raw.cpu GROUP BY time(30m), host, core_id 
    END

![20190402135343620.png][]

列出influxdb实例上的CQ,展示是以实例进行分组

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzI2NDQ5_size_16_color_FFFFFF_t_70][]

# #

参考1：[https://jasper-zhang1.gitbooks.io/influxdb/content/Query\_language/continuous\_queries.html][https_jasper-zhang1.gitbooks.io_influxdb_content_Query_language_continuous_queries.html]

参考2：[https://docs.influxdata.com/influxdb/v1.3/query\_language/data\_download/][https_docs.influxdata.com_influxdb_v1.3_query_language_data_download]

[2019022714560848.png]: /images/20220316/5aeac75da9604459b141b03c4958f0ef.png
[20190402135343620.png]: /images/20220316/49de40c2b3bd44608732c977c3f91def.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzI2NDQ5_size_16_color_FFFFFF_t_70]: /images/20220316/142748a87d534dd1a78ae7626c8d2f44.png
[https_jasper-zhang1.gitbooks.io_influxdb_content_Query_language_continuous_queries.html]: https://jasper-zhang1.gitbooks.io/influxdb/content/Query_language/continuous_queries.html
[https_docs.influxdata.com_influxdb_v1.3_query_language_data_download]: https://docs.influxdata.com/influxdb/v1.3/query_language/data_download/