Python写入InfluxDB

InfluxDB是一个开源的时序数据库，使用GO语言开发，特别适合用于处理和分析资源监控数据这种时序相关数据。而InfluxDB自带的各种特殊函数如求标准差，随机取样数据，统计数据变化比等，使数据统计和实时分析变得十分方便。

安装

• 数据库安装
  根据不同的系统安装方式不太一样, 具体参考官网, 这个官网提供的挺详细的。

如果有指定版本的requests, 注意一下requests版本, influxdb不支持旧版的requests库, 版本不支持安装时会有提示。

• Python安装操作库

  python3 -m pip install influxdb
  
  pip install --upgrade influxdb             # 升级
  pip uninstall influxdb       # 卸载

使用准备

• 操作准备
  需要先创建数据库，可以使用命令行进行创建

  create database database_name;

也可以使用python命令直接创建

from influxdb import InfluxDBClient
# 首先连接influxdb
client = InfluxDBClient(host='服务器IP', port=8086, username='myuser', password='mypass' ssl=True, verify_ssl=True)
# 创建数据库
client.create_database('database_name')   
# 查询数据库
client.get_list_database()

操作

• 连接数据库

  from influxdb import InfluxDBClient
  client = InfluxDBClient('服务器IP', '8086', 'myuser', 'mypass', 'database_name')

• 写入数据
  InfluxDB的每条数据可以看成一个json数据（其实写入的时候就是个json数据），每条数据中包含了'measurement'，'time'，'tags'，'fields'

w_json = [{
    "measurement": 'table_name',
    "time": now_time,
    "tags": {
        'name': '名字',
        'categories': '类型'
        },
    "fields": {
        'price': "价格",
        'unit': "单位",
        }
    }]
写入数据库
client.write_points(w_json)

参考链接：时光不写博客-Python写入InfluxDB