查询 InfluxDB
要使用 Flux 从 InfluxDB 查询数据，请使用 from() 和 range。 为每个函数提供以下参数
- from():
- bucket 或 bucketID: 要查询的 InfluxDB bucket 名称 或 bucket ID。
- range():
- start: 返回结果的最早时间。
InfluxDB 要求查询必须有时间范围限制，因此 from() 之后必须始终跟随 range()。
from(bucket: "example-bucket")
|> range(start: -1h)
远程查询 InfluxDB Cloud 或 2.x
要远程查询 InfluxDB Cloud 或 2.x，除了 bucket 或 bucketID 之外，还需要提供以下参数。
- host: InfluxDB Cloud 区域 URL 或 InfluxDB URL
- org 或 orgID: InfluxDB 组织名称或 ID
- token: InfluxDB API 令牌
from(
bucket: "example-bucket",
host: "http://localhost:8086",
org: "example-org",
token: "mYSup3r5Ecr3T70keN",
)
查询 InfluxDB 1.x
要查询 InfluxDB 1.x，请对您的 bucket 名称使用 database-name/retention-policy-name 命名约定。 例如，要查询 telegraf 数据库中 autogen 保留策略中的数据
from(bucket: "telegraf/autogen")
|> range(start: -30m)
要查询数据库中默认保留策略，请使用相同的 bucket 命名约定，但不要提供保留策略
from(bucket: "telegraf/")
|> range(start: -30m)
结果结构
from() 和 range() 返回一个按 序列（measurement、标签集和字段）分组的 表流。 每个表包含以下列
- _start: 查询范围开始时间（由
range()定义） - _stop: 查询范围停止时间（由
range()定义） - _time: 数据时间戳
- _measurement: Measurement 名称
- _field: 字段键
- _value: 字段值
- 标签列: 每列标签一列，其中列标签是标签键，列值是标签值
带有下划线前缀的列
带有下划线 (_) 前缀的列被视为“系统”列。 一些 Flux 函数需要这些列。
InfluxDB 查询结果示例
悬停在突出显示的文本上以查看描述。
| _start | _stop | _time | _measurement | host | _field | _value |
|---|---|---|---|---|---|---|
| 2021-01-01T00:00:00Z | 2021-01-02T00:00:00Z | 2021-01-01T00:00:00Z | foo | host1 | bar | 1.2 |
| 2021-01-01T00:00:00Z | 2021-01-02T00:00:00Z | 2021-01-01T01:00:00Z | foo | host1 | bar | 1.6 |
| 2021-01-01T00:00:00Z | 2021-01-02T00:00:00Z | 2021-01-01T02:00:00Z | foo | host1 | bar | 2.1 |
| _start | _stop | _time | _measurement | host | _field | _value |
|---|---|---|---|---|---|---|
| 2021-01-01T00:00:00Z | 2021-01-02T00:00:00Z | 2021-01-01T00:00:00Z | foo | host2 | bar | 1.2 |
| 2021-01-01T00:00:00Z | 2021-01-02T00:00:00Z | 2021-01-01T01:00:00Z | foo | host2 | bar | 1.7 |
| 2021-01-01T00:00:00Z | 2021-01-02T00:00:00Z | 2021-01-01T02:00:00Z | foo | host2 | bar | 2.1 |
结构化结果，类似于 InfluxQL
InfluxQL 将每个字段作为一列返回，其中列标签是字段键，列值是字段值。 要使用 Flux 类似地构建结果，请使用 pivot() 或 schema.fieldsAsCols() 将字段透视为列。
此页内容是否对您有帮助？
感谢您的反馈！