如何使用Golang获取InfluxDB Bucket的保留期？

InfluxDB 2.x的Bucket保留期信息存储在Bucket的RetentionRules字段中，不需要依赖Flux查询，直接通过官方Golang客户端的Buckets API就能获取到。

具体代码实现 #

首先确保你已导入InfluxDB v2的Golang客户端包：

import (
    "context"
    "fmt"
    "github.com/influxdata/influxdb-client-go/v2"
)

然后编写查询逻辑：

func getBucketRetention(influxURL, token, org, bucketName string) error {
    // 初始化客户端
    client := influxdb2.NewClient(influxURL, token)
    defer client.Close()

    // 获取Buckets API实例
    bucketsAPI := client.BucketsAPI()

    // 根据名称查询Bucket详情
    bucket, err := bucketsAPI.FindBucketByName(context.Background(), org, bucketName)
    if err != nil {
        return fmt.Errorf("failed to fetch bucket: %w", err)
    }

    // 解析保留期规则
    if len(bucket.RetentionRules) == 0 {
        fmt.Printf("Bucket %q has no retention rules\n", bucketName)
        return nil
    }

    rule := bucket.RetentionRules[0]
    if rule.EverySeconds == 0 {
        fmt.Printf("Bucket %q has infinite retention\n", bucketName)
    } else {
        fmt.Printf("Bucket %q retention period: %d seconds\n", bucketName, rule.EverySeconds)
    }

    return nil
}

// 调用示例
func main() {
    err := getBucketRetention(
        "http://your-influx-host:8086",
        "your-auth-token",
        "your-org-id-or-name",
        "your-target-bucket",
    )
    if err != nil {
        panic(err)
    }
}

关键说明 #

• 你的认证Token必须具备read:buckets权限，否则会返回权限错误
• 若使用InfluxDB 1.x，需改用Query API执行SHOW RETENTION POLICIES ON "your-db"语句来获取保留期
• 大部分场景下一个Bucket只会配置一条保留规则，取数组第一个元素即可

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