Python简单使用InfluxDB
发布时间：2019-09-26 10:00:45编辑：auto阅读（2595）
- database: 数据库名，在 InfluxDB 中可以创建多个数据库，不同数据库中的数据文件是隔离存放的，存放在磁盘上的不同目录。
- retention policy: 存储策略，用于设置数据保留的时间，每个数据库刚开始会自动创建一个默认的存储策略
autogen，数据保留时间为永久，之后用户可以自己设置，例如保留最近2小时的数据。插入和查询数据时如果不指定存储策略，则使用默认存储策略，且默认存储策略可以修改。InfluxDB
会定期清除过期的数据。 - measurement: 测量指标名，例如 cpu_usage 表示 cpu 的使用率。
- tag sets: tags 在 InfluxDB 中会按照字典序排序，不管是 tagk 还是 tagv，只要不一致就分别属于两个
key，例如 host=server01,region=us-west 和 host=server02,region=us-west
就是两个不同的 tag set。 - field name: 例如上面数据中的 value 就是 fieldName，InfluxDB 中支持一条数据中插入多个
fieldName，这其实是一个语法上的优化，在实际的底层存储中，是当作多条数据来存储。 timestamp:
每一条数据都需要指定一个时间戳，在 TSM 存储引擎中会特殊对待，以为了优化后续的查询操作。
前言
之前已经在自己的MQTT服务器上安装好了InfluxDB时序数据库,接下来写个Python程序测试下.
安装
API详情参阅这里
打开powershell,执行pip install influxdb安装模块
程序
程序API详细参考这里
# coding=utf-8
import time
from influxdb import InfluxDBClient
def read_info():
data_list = [{'measurement': 'win',
'tags': {'cpu': 'i7-7700HQ'},
'fields': {'cpu_info_user': cpu_time_info[0],
'cpu_info_system': cpu_time_info[1],
'cpu_info_idle': cpu_time_info[2],
'cpu_info_interrupt': cpu_time_info[3],
'cpu_info_dpc': cpu_time_info[4]}}]
return data_list
if __name__ == '__main__':
client = InfluxDBClient(host, port, user, password, database) # 初始化
counts = 0 #计数,也就是数据上传20次
while counts <= 20:#
counts += 1
client.write_points(read_info())
time.sleep(5)
程序功能很简单,每5秒上传一次CPU使用状况,连续上传20次.
其中核心知识是数据格式,这里会自动打包字典到JSON,一开始在这打包成JSON上传报错.而且需要把这个字典放在列表中,因为一次可以添加多个字典格式上传.其中必须有'measurement','tags','fields'三个Key.
数据格式 Line Protocol
在 InfluxDB 中，我们可以粗略的将要存入的一条数据看作一个虚拟的 key 和其对应的 value(field value)，格式如下：
cpu_usage,host=server01,region=us-west value=0.64 1434055562000000000
虚拟的 key 包括以下几个部分： database, retention policy, measurement, tag sets, field name, timestamp。 database 和 retention policy 在上面的数据中并没有体现，通常在插入数据时在 http 请求的相应字段中指定。
上一篇： Windows系统下Eclipse上搭建
下一篇： 本地安装python包的方法
- openvpn linux客户端使用
49468
- H3C基本命令大全
48677
- openvpn windows客户端使用
39372
- H3C IRF原理及 配置
36441
- Python exit()函数
30842
- openvpn mac客户端使用
27666
- python全系列官方中文文档
26647
- 1.常用turtle功能函数
21469
- python 获取网卡实时流量
21339
- python 获取Linux和Windows硬件信息
19684
- LLaMA Factory-Lora微调实现声控语音多轮问答对话-1
357°
- LLaMA Factory微调后的模型合并导出和部署-4
698°
- LLaMA Factory微调模型的各种参数怎么设置-3
613°
- LLaMA Factory构建高质量数据集-2
682°
- MinerU-linux环境本地部署
1455°
- LLaMA Factory安装和基本使用-1
767°
- 使用ms-swift基于Qwen3-8B微调小说模型
1447°
- pythonp爬虫-fanqienovel字体反爬实战
1677°
- 大模型基础架构
1324°
- AI多模态- Janus-Pro-7B模型推理微调,融合实战2
1306°
- 姓名：Run
- 职业：谜
- 邮箱：383697894@qq.com
- 定位：上海 · 松江
