InfluxDB 2如何获取指定bucket的schema结构信息？

完全可以通过官方原生能力实现，不需要额外依赖组件，优先推荐Flux查询配合官方JS客户端的方案，兼容性和稳定性最好。

方案1：基于influxdb-client-js + Flux查询实现（推荐） #

InfluxDB 2.x内置的influxdata/influxdb/schema Flux包专门用于查询元数据，2.2.0版本对该包的支持已经稳定，不需要开启任何实验特性即可使用。

前置依赖 #

先安装官方JS客户端：
npm install @influxdata/influxdb-client

核心Flux查询语句 #

三类schema信息对应的查询逻辑如下：

• 获取指定Bucket下所有measurement列表

import "influxdata/influxdb/schema"
// 若要查询建桶以来所有历史存在的measurement，追加参数 start: time(v: 0)
// 不加start参数默认查询过去30天有写入的measurement
schema.measurements(bucket: "你的目标Bucket名称")

• 获取指定measurement下所有tag key

import "influxdata/influxdb/schema"
schema.tagKeys(
  bucket: "你的目标Bucket名称",
  predicate: (r) => r._measurement == "目标measurement名称",
  start: time(v: 0) // 按需配置时间范围
)

如果要查询某个tag对应的所有枚举值，替换函数为schema.tagValues，新增tag参数指定目标tag名即可。

• 获取指定measurement下所有field key及对应类型

import "influxdata/influxdb/schema"
schema.fieldKeys(
  bucket: "你的目标Bucket名称",
  predicate: (r) => r._measurement == "目标measurement名称",
  start: time(v: 0)
)

返回结果会自动附带field的类型标记（string/int/float/boolean/time）。

完整JS调用示例 #

const { InfluxDB } = require('@influxdata/influxdb-client')

// 初始化客户端
const influxClient = new InfluxDB({
  url: '你的InfluxDB服务访问地址',
  token: '对应权限的API Token'
})
const queryClient = influxClient.getQueryApi('你的组织名称')

// 通用schema查询封装
async function runSchemaQuery(fluxScript) {
  const res = []
  await new Promise((resolve, reject) => {
    queryClient.queryRows(fluxScript, {
      next: (row, tableMeta) => {
        const rowData = tableMeta.toObject(row)
        res.push(rowData._value)
      },
      error: reject,
      complete: resolve
    })
  })
  return [...new Set(res)] // 结果去重
}

// 拉取指定Bucket全量schema
async function getBucketFullSchema(bucketName, measurementName) {
  const measurements = await runSchemaQuery(`
    import "influxdata/influxdb/schema"
    schema.measurements(bucket: "${bucketName}", start: time(v: 0))
  `)

  const tagKeys = await runSchemaQuery(`
    import "influxdata/influxdb/schema"
    schema.tagKeys(
      bucket: "${bucketName}",
      predicate: (r) => r._measurement == "${measurementName}",
      start: time(v: 0)
    )
  `)

  const fieldKeys = await runSchemaQuery(`
    import "influxdata/influxdb/schema"
    schema.fieldKeys(
      bucket: "${bucketName}",
      predicate: (r) => r._measurement == "${measurementName}",
      start: time(v: 0)
    )
  `)

  return { measurements, tagKeys, fieldKeys }
}

方案2：直接调用原生HTTP API #

如果不想引入官方JS客户端，可以直接调用InfluxDB 2.2内置的查询接口：

• 接口地址：POST {你的InfluxDB地址}/api/v2/query
• 请求头：需要携带Authorization: Token 你的API Token、Content-Type: application/vnd.flux
• 请求体：直接传入上面写好的Flux查询语句即可，返回结果为CSV格式，自行解析就能拿到schema数据。

注意2.2版本虽然存在路径为/api/v2/buckets/{bucketID}/schema/measurements的专用schema接口，但该接口当时属于实验特性，默认关闭且后续版本参数有调整，生产环境不建议使用。

常见注意事项 #

• 不要尝试用InfluxQL的SHOW MEASUREMENTS/SHOW TAG KEYS等语句查询，2.x版本对InfluxQL的兼容需要手动配置Bucket与数据库/保留策略的映射，配置繁琐且官方不再推荐。
• 如果查询返回空结果，先检查使用的Token是否拥有目标Bucket的读权限，再确认查询的时间范围是否覆盖了数据写入的时段。

内容的提问来源于stack exchange，提问作者szylkret