Python 和 InfluxDB

强大的性能和轻松的集成,由 InfluxData 构建的开源数据连接器 Telegraf 提供支持。

50 亿+

Telegraf 下载量

#1

时序数据库
来源:DB-Engines

10 亿+

InfluxDB 下载量

2,800+

贡献者

目录

强大的性能,无限的扩展能力

收集、组织和处理海量高速数据。当您将任何数据视为时序数据时,它都会更有价值。借助 InfluxDB,这是排名第一的时序平台,旨在与 Telegraf 一起扩展。

查看入门方法

使用 Python 客户端库和 InfluxDB 构建物联网、分析和云应用程序。

为什么使用 InfluxDB Python 客户端库?

InfluxDB 是一个 API 优先的时序数据库,适用于您的 Python 应用程序。使用 InfluxDB 开源 Python API 客户端,将数据写入和查询到您的应用程序中,甚至可以从您的应用程序中管理您的 InfluxDB 实例。

主要特点

  • 提供对所有 InfluxDB 写入和读取功能、设置和高级功能的 API 访问
  • 以 InfluxDB 行协议、点数据结构或 pandas 数据帧格式写入数据
  • 轻松配置超时、延迟和请求重试
  • 批量处理数据到 InfluxDB 以获得更高的效率
  • 以 Flux 表结构、字符串、csv、流或数据帧格式返回 InfluxDB 数据
  • Panda 数据帧集成

开始使用



使用 InfluxDB 的 Python 客户端库批量处理数据


使用 InfluxDB 的 Python 客户端库查询数据


使用 InfluxDB Python 客户端库管理 API

读取

写入


from influxdb_client import InfluxDBClient

url = 'https://us-west-2-1.aws.cloud2.influxdata.com'
token = 'my-token'
org = 'my-org'
bucket = 'my-bucket'

with InfluxDBClient(url=url, token=token, org=org) as client:
    query_api = client.query_api()

    tables = query_api.query('from(bucket: "my-bucket") |> range(start: -1d)')

    for table in tables:
        for record in table.records:
            print(str(record["_time"]) + " - " + record.get_measurement()
                  + " " + record.get_field() + "=" + str(record.get_value()))

有关更多信息,请查看文档。

项目 URL   文档   Python 客户端库入门

强大的性能,无限的扩展能力

收集、组织和处理海量高速数据。当您将任何数据视为时序数据时,它都会更有价值。借助 InfluxDB,这是排名第一的时序平台,旨在与 Telegraf 一起扩展。

查看入门方法

相关集成