influxdb

voidFan · · 1105 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

influxdb简介

  • InfluxDB是基于Golang编写的一个用于存储和分析时间序列数据的开源数据库。
  • 安装简单,无外部依赖,底层采用TSM存储并且读写数据很高效;
  • 内置HTTP接口,使用方便
  • 数据可以打标记,查让查询可以很灵活
  • 类SQL的查询语句
  • 能够实时查询,数据在写入时被索引后就能够被立即查出

基本概念介绍

  • timestamp:每一条数据都需要指定一个时间戳,这个时间戳以RFC3339格式展示了与特定数据相关联的UTC日期和时间(当然也是可以修改的)。在 TSM 存储引擎中会特殊对待,以为了优化后续的查询操作。
  • database: 数据库名,在InfluxDB 中可以创建多个数据库,不同数据库中的数据文件是隔离存放的,存放在磁盘上的不同目录。
  • retention Policy:存储策略
    1. 用于设置数据保留的时间,每个数据库刚开始会自动创建一个默认的存储策略 autogen,数据保留时间为永久,
    2. autogen中的数据永不删除且备份数replication为1(只有一份数据,在集群中起作用)。
    3. 可以自己设置存储策略,例如保留最近2小时的数据。
    4. 插入和查询数据时如果不指定存储策略,则使用默认存储策略,且默认存储策略可以修改。InfluxDB会定期清除过期的数据。
  • measurement:是一个容器,包含了列(timestamp,filed,tag set)。类似传统数据库的表,例如cpu_usage_table 表示 cpu 的使用率。
  • tag set:不同的每组tag key和tag value的集合,如图location = 1, scientist = langstroth.
    1. tags 在 InfluxDB 中会被建立索引,且放在内存中。
    2. 如果某种数据经常用来被作为查询条件,可以考虑设为Tag。(为了解决海量数据查询,建索引)
  • series: series是共同retention, policy,measurement和tag set的集合。
  • field: 记录值,是查询的主要对象,例如value值等
  • point: 代表一条记录,point是具有相同timestamp、相同series(measurement,rp,tag set相同)的field。这个点在此时刻是唯一存在的。
  • line protocol:写入InfluxDB时的数据点的文本格式。如:cpu,host=serverA,region=us_west
  • continuous query(CQ):
  • 官方说明

InfluxDB SQL语法

  • database和measurements相关SQL

1. show databases;
2. use <db_name>;
3. show measurements;
4. select * from measurement_name limit 10;  //查询10条数据
5. show tag keys;      //查看一个measurement中所有的tag key
6. show field keys;    //查看一个measurement中所有的field key
7. show retention policies;    //查看一个measurement中所有的保存策略(可以有多个,一个标识为default)
  • 常用函数

  1. count()函数返回一个(field)字段中的非空值的数量。SELECT COUNT(field) FROM measurements
  2. DISTINCT()函数返回一个字段(field)的唯一值。
  3. MEAN() 函数返回一个字段(field)中的值的算术平均值(平均值)。字段类型必须是长整型或float64。
  4. MEDIAN()函数从单个字段(field)中的排序值返回中间值(中位数)。字段值的类型必须是长整型或float64格式。
  5. SPREAD()函数返回字段的最小值和最大值之间的差值。数据的类型必须是长整型或float64。
  6. SUM()函数返回一个字段中的所有值的和。字段的类型必须是长整型或float64。
  7. BOTTOM()函数作用:返回一个字段中最小的N个值。字段类型必须是长整型或float64类型。
  8. FIRST()函数作用:返回一个字段中最老的取值。
  9. LAST()函数作用:返回一个字段中最新的取值。
  10. MAX()函数作用:返回一个字段中的最大值。该字段类型必须是长整型,float64,或布尔类型。
  11. MIN()函数作用:返回一个字段中的最小值。该字段类型必须是长整型,float64,或布尔类型。
  12. PERCENTILE()函数作用:返回排序值排位为N的百分值。字段的类型必须是长整型或float64。百分值是介于100到0之间的整数或浮点数,包括100。
  13. DERIVATIVE()函数作用:返回一个字段在一个series中的变化率。InfluxDB会计算按照时间进行排序的字段值之间的差异,并将这些结果转化为单位变化率。其中,单位可以指定,默认为1s。
  14. DIFFERENCE()函数作用:返回一个字段中连续的时间值之间的差异。字段类型必须是长整型或float64。
  15. ELAPSED()函数作用:返回一个字段在连续的时间间隔间的差异,间隔单位可选,默认为1纳秒。
  16. MOVING_AVERAGE()函数作用:返回一个连续字段值的移动平均值,字段类型必须是长整形或者float64类型。
  17. NON_NEGATIVE_DERIVATIVE()函数作用:返回在一个series中的一个字段中值的变化的非负速率。
  18. STDDEV()函数作用:返回一个字段中的值的标准偏差。值的类型必须是长整型或float64类型。

有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:voidFan

查看原文:influxdb

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1105 次点击  
加入收藏 微博
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传