bucket的概念类似数据库的“库”，同时每个库中的数据都因为存在“时间戳”，每个数据都会有一个对应的时间点

influxdb-client-python官方github页面：https://github.com/influxdata/influxdb-client-python

管理bucket的官方示例：https://github.com/influxdata/influxdb-client-python/blob/master/examples/buckets_management.py

文章目录

基本用法
- 创建bucket
- 查询bucket
- 修改bucket
- 删除bucket
完整示例

基本用法

首先使用influxdb-client管理InfluxDB数据库都需要使用：

from influxdb_client import InfluxDBClientinfluxdb_token = "SkeHprHCgmvtX3LXluMUlgyl5nzwM4zdMtsCuT7BQXsaJlhFPMJizKj0nX3ugr9vRfY7Ak4rIhu-wx-aIqNFig==" # TODO 改为自己的token
influxdb_org = "manager" # TODO 填写自己的组织名称
client = InfluxDBClient(url="http://localhost:8086", token=influxdb_token, org=influxdb_org) # 创建客户端buckets_api = client.buckets_api() # 创建链接bucket的客户端

创建bucket

一行代码即可创建成功：

created_bucket = buckets_api.create_bucket(bucket_name="new_create_bucket", org=influxdb_org)

如果需要设置数据的保留时间

from influxdb_client import BucketRetentionRulesretention_rules = BucketRetentionRules(type="expire", every_seconds=36000)  # 保留近10天数据的bucket
created_bucket = buckets_api.create_bucket(bucket_name="new_create_bucket",retention_rules=retention_rules,org=influxdb_org)

查询bucket

查询全部的bucket使用：

all_buckets = buckets_api.find_buckets(org=influxdb_org).buckets  # 查找全部的bucket
for _record_bucket in all_buckets:bucket_info = {"id": _record_bucket.id,"name": _record_bucket.name,"retention": _record_bucket.retention_rules,}print(bucket_info)

多数情况下，我们会已知一个bucket的名称，然后获得这个bucket的对象，使用如下代码实现：

my_bucket = buckets_api.find_bucket_by_name("new_create_bucket")

修改bucket

在查询的时候每一个属性都可以使用如下代码修改：

my_bucket.description = "修改后的describe"  # 先修改
my_bucket = buckets_api.update_bucket(bucket=my_bucket)  # 再保存
print(my_bucket.description)

得到的结果是：

修改后的describe

删除bucket

一行代码即可删除：

buckets_api.delete_bucket(my_bucket)

完整示例

from influxdb_client import InfluxDBClientinfluxdb_token = "SkeHprHCgmvtX3LXluMUlgyl5nzwM4zdMtsCuT7BQXsaJlhFPMJizKj0nX3ugr9vRfY7Ak4rIhu-wx-aIqNFig=="
influxdb_org = "manager"
client = InfluxDBClient(url="http://localhost:8086", token=influxdb_token, org=influxdb_org)
buckets_api = client.buckets_api()# 增
print("===================== 创建bucket =====================")
created_bucket = buckets_api.create_bucket(bucket_name="new_create_bucket", org=influxdb_org)# 查
print("===================== 查询全部的bucket =====================")
all_buckets = buckets_api.find_buckets(org=influxdb_org).buckets
for _record_bucket in all_buckets:bucket_info = {"id": _record_bucket.id,"name": _record_bucket.name,"retention": _record_bucket.retention_rules,}print(bucket_info)print("===================== 查询某个已知name的bucket =====================")
my_bucket = buckets_api.find_bucket_by_name("new_create_bucket")# 修改
print("===================== 修改bucket =====================")
my_bucket.description = "修改后的describe"  # 先修改
my_bucket = buckets_api.update_bucket(bucket=my_bucket)  # 再保存
print(my_bucket.description)# 删除
print("===================== 删除bucket =====================")
buckets_api.delete_bucket(my_bucket)

python使用influxdb-client管理InfluxDB的bucket相关推荐

InfluxDB简介，InfluxDB的基本操作
一.InfluxDB 简介 InfluxDB 是用Go语言编写的一个开源分布式时序.事件和指标数据库,无需外部依赖. 类似的数据库有Elasticsearch.Graphite等. 其主要特色功能 1 ...
什么是 Python 的「内存管理机制」？
什么是内存管理器(what) Python作为一个高层次的结合了解释性.编译性.互动性和面向对象的脚本语言,与大多数编程语言不同,Python中的变量无需事先申明,变量无需指定类型,程序员无需关心内存 ...
python操作三大主流数据库(6)python操作mysql⑥新闻管理后台功能的完善(增、ajax异步删除新闻、改、查)...
python操作mysql⑥新闻管理后台功能的完善(增.删.改.查) 安装表单验证 D:\python\python_mysql_redis_mongodb\version02>pip inst ...
Python简单主机批量管理工具
Python简单主机批量管理工具一.程序介绍需求: 简单主机批量管理工具需求:1.主机分组2.主机信息使用配置文件3.可批量执行命令.发送文件,结果实时返回4.主机用户名密码.端口可以不同5.执行 ...
pip Python 包安装和管理工具
pip 是一个 Python 包安装与管理工具. 从PyPI安装软件包: $ pip install SomePackage [...] Successfully installed SomePack ...
Python如何进行内存管理？
Python中主要通过引用计数和内存池机制进行内存管理. 一.引用计数机制 Python内部使用引用计数(记录对象有多少个引用)来保持追踪内存中的对象,当对象被创建时,该对象的引用计数加1;当对象被销 ...
4_InfluxDB学习之InfluxDB的基本概念、InfluxDB中独有的概念(Point,series),InfluxDB学习之InfluxDB的基本操作,InfluxDB操作方式,crud
4.InfluxDB学习之InfluxDB的基本概念 4.1.与传统数据库中的名词做比较 4.2.InfluxDB中独有的概念 4.2.1.Point 4.2.2.series 4.3.InfluxD ...
python写网页脚本_东拼西凑用python脚本登录web管理页面做巡检（实现）
东拼西凑用python脚本登录web管理页面做巡检(实现) 发布时间:2020-06-06 12:26:40 来源:51CTO 阅读:489 参考博文https://www.cnblogs.com/s ...
python开发软件的实例-由Python编写的MySQL管理工具代码实例
本文实例为大家分享了由Python编写的MySQL管理工具的具体代码,供大家参考,具体内容如下 import pymysql import pandas as pd from tkinter impo ...

python使用influxdb-client管理InfluxDB的bucket