Go结构体字段需通过反射+类型适配转为InfluxDB field key：仅导出字段参与序列化，按influx tag区分field/tag角色，int/float/bool/string须按Line Protocol规则格式化（如123i、123.0、t、"s"），非支持类型跳过。
struct 字段怎么自动变成 InfluxDB 的 field key
InfluxDB 的 line protocol 要求 field 必须是 key=value 形式，且 value 类型需明确（string、float、int、bool）。Go 结构体字段不能直接当 field 用，得靠反射提取值并做类型适配。关键不是“映射”，而是“按 InfluxDB 规则序列化字段”。
默认不加 tag 时，reflect.Value.Interface() 取出的值可能带指针或 interface{} 包装，直接拼 line protocol 会 panic 或输出 map[]、&{...} 这类非法内容。
- 只导出字段（首字母大写）才会被反射读取；未导出字段会被跳过
- nil 指针字段若没判空，
v.Elem()会 panic - float64 和 int64 可直传；int、int32 等需显式转为 int64，否则 InfluxDB 拒收（报
bad field value） - time.Time 字段别当 field —— InfluxDB 的 field 不支持 timestamp，它只能是 tag 或写入时间（precision 控制）
用 struct tag 控制哪些字段进 field，哪些进 tag
InfluxDB 写入时，field 和 tag 是严格分离的：tag 用于索引（必须是 string），field 才存实际指标值。结构体里混用两者，得靠 tag 显式声明意图，比如 influx:"field" 或 influx:"tag"。
别依赖字段名默认行为 —— 有人误以为小写字段自动成 tag、大写自动成 field，其实不会，不加 tag 就全被忽略。
立即学习“go语言免费学习笔记（深入）”；
- 定义 tag：
type Metric struct { Host string `influx:"tag"` Value float64 `influx:"field"` } - 反射遍历时，用
field.Tag.Get("influx")判断角色，不是"-"且非空才处理 - 值为
"tag"的字段，强制转 string（调fmt.Sprintf("%v", v.Interface())）；值为"field"的字段，按类型分路径格式化 - 忽略
influx:"-"或无该 tag 的字段，避免意外暴露内部状态字段
field 值类型转换容易踩的坑
InfluxDB 对 field value 类型敏感：整数末尾要带 i（如 123i），浮点数不能省略小数点（123.0 合法，123 被当 int），布尔必须小写 t/f。反射取出的 Go 值不自动补这些后缀。
别用 strconv.FormatXxx 粗暴转 —— 它不处理 bool 和 time.Duration，也不加 i 后缀。
-
int/int32/int64→ 先转int64，再用fmt.Sprintf("%di", i) -
float32/float64→ 用fmt.Sprintf("%f", f)，再strings.TrimRight(strings.TrimRight(s, "0"), ".")去多余零（避免123.000000） -
bool→map[bool]string{true: "t", false: "f"}[b] -
string→ 用双引号包裹，且内部双引号和反斜杠要转义："\"" + strings.ReplaceAll(s, `"`, `\"`) + "\"" - 其他类型（如 struct、slice）一律跳过或报错，InfluxDB 不支持嵌套 field
生成 line protocol 字符串的最小可行代码片段
以下逻辑可封装成函数，输入 interface{}，输出 string（不含换行符，方便批量拼接）：
func structToLine(v interface{}, measurement string) string {
rv := reflect.ValueOf(v)
if rv.Kind() == reflect.Ptr {
rv = rv.Elem()
}
if rv.Kind() != reflect.Struct {
return ""
}
var fields, tags []string
rt := reflect.TypeOf(v)
if rt.Kind() == reflect.Ptr {
rt = rt.Elem()
}
for i := 0; i < rv.NumField(); i++ {
field := rt.Field(i)
value := rv.Field(i)
influxTag := field.Tag.Get("influx")
if influxTag == "-" || influxTag == "" {
continue
}
v := value.Interface()
switch influxTag {
case "tag":
s := fmt.Sprintf("%s=%s", field.Name, strconv.Quote(fmt.Sprintf("%v", v)))
tags = append(tags, s)
case "field":
s := formatFieldValue(value)
if s != "" {
fields = append(fields, fmt.Sprintf("%s=%s", field.Name, s))
}
}
}
if len(fields) == 0 {
return ""
}
line := measurement
if len(tags) > 0 {
line += "," + strings.Join(tags, ",")
}
line += " " + strings.Join(fields, ",")
return line
}
func formatFieldValue(v reflect.Value) string {
switch v.Kind() {
case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
return fmt.Sprintf("%di", v.Int())
case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64:
return fmt.Sprintf("%du", v.Uint())
case reflect.Float32, reflect.Float64:
f := v.Float()
s := fmt.Sprintf("%.10g", f)
if !strings.Contains(s, ".") && !strings.Contains(s, "e") {
s += ".0"
}
return s
case reflect.Bool:
if v.Bool() {
return "t"
}
return "f"
case reflect.String:
return strconv.Quote(v.String())
default:
return ""
}
}
注意 formatFieldValue 里对 float 的处理：用 %.10g 避免科学计数法干扰，再手动补 .0 保证是合法浮点字面量。这个细节线上常被忽略，导致写入失败却查不出原因。
