如何在从InfluxDB读取数据时映射Enum枚举类型？

核心思路 #

InfluxDB .NET客户端默认不支持字符串直接转枚举类型，需要自定义类型转换器实现字符串与枚举的双向转换，同时处理未知值的 fallback 逻辑（映射到Unknown枚举成员）。

实现步骤 #

1. 编写自定义枚举转换器 #

实现InfluxDB.Client.Core.Converters.ITypeConverter接口，处理字符串到枚举的解析，以及枚举到字符串的序列化：

using InfluxDB.Client.Core.Converters;
using System;

public class StringToEnumConverter<TEnum> : ITypeConverter where TEnum : Enum
{
    // 从InfluxDB读取字符串时转为枚举
    public object ConvertFromString(string value, Type targetType)
    {
        if (string.IsNullOrWhiteSpace(value))
            return Enum.Parse<TEnum>(nameof(Source.Unknown));
        
        // 忽略大小写解析，解析失败则返回Unknown
        return Enum.TryParse<TEnum>(value, ignoreCase: true, out var parsedResult)
            ? parsedResult
            : Enum.Parse<TEnum>(nameof(Source.Unknown));
    }

    // 写入数据时将枚举转为字符串
    public string ConvertToString(object value, Type sourceType)
    {
        return value?.ToString() ?? nameof(Source.Unknown);
    }
}

2. 应用转换器（二选一） #

方式一：针对单个属性配置

在Temperature模型的Source属性上，通过Column特性指定转换器类型：

[Measurement("temperature")]
private class Temperature
{
    [Column("location", IsTag = true)] public string Location { get; set; }
    [Column("value")] public double Value { get; set; }
    [Column(IsTimestamp = true)] public DateTime Time { get; set; }
    // 指定自定义转换器
    [Column("source", ConverterType = typeof(StringToEnumConverter<Source>))] 
    public Source Source { get; set; }
}

方式二：全局注册转换器

如果多个模型都需要相同的枚举转换逻辑，可以在创建InfluxDBClient时全局注册转换器，避免重复配置：

var clientOptions = new InfluxDBClientOptions("http://your-influxdb-url:8086")
{
    Token = "your-auth-token",
    Org = "your-org-id",
    // 添加全局转换器
    Converters = new List<ITypeConverter>
    {
        new StringToEnumConverter<Source>()
    }
};

using var influxClient = new InfluxDBClient(clientOptions);
var queryApi = influxClient.GetQueryApi();

// 执行查询，此时会自动处理字符串到Source枚举的转换
var temperatures = await queryApi.QueryAsync<Temperature>(fluxQuery, "your-org-id");

注意事项 #

• 确保InfluxDB中存储的字符串值与枚举成员名称一致（例如数据库中存"Sensor"对应枚举的Sensor成员）；
• 转换器中开启了ignoreCase: true，可以兼容大小写不一致的情况；
• 当遇到无法解析的字符串时，会自动映射到Unknown枚举成员，符合业务 fallback 需求。

内容的提问来源于stack exchange，提问作者A. Wheatman