基于YAML字段将YAML解组为不同的结构

Question

我正在尝试将以下YAML数据分解为Go结构。

数据采用以下格式:

fetchers:
- type: "aws"
  config:
    omega: "lul"
- type: "kubernetes"
  config: 
    foo: "bar"

根据类型字段，我想确定是否将配置字段解组到awsConfig或kubernetesConfig结构中。

我当前的代码如下（使用“gopkg.in/yaml.v2”）：

type kubernetesConfig struct {
    foo string `yaml:"foo"`
}
type awsConfig struct {
    omega string `yaml:"omega"`
}

var c struct {
    Fetchers []struct {
        Type   string      `yaml:"type"`
        Config interface{} `yaml:"config"`
    } `yaml:"fetchers"`
}

err := yaml.Unmarshal(data, &c)
if err != nil {
    log.Fatal(err)
}
for _, val := range c.Fetchers {
    switch val.Type {
    case "kubernetes":
        conf := val.Config.(kubernetesConfig)
        fmt.Println(conf.foo)
    case "aws":
        conf := val.Config.(awsConfig)
        fmt.Println(conf.omega)
    default:
        log.Fatalf("No matching type, was type %v", val.Type)
    }
}

操场代码:https://go.dev/play/p/klxOoHMCtnG

目前它被解组为 map[接口 {}]接口 {}，无法转换为上述结构之一。错误：panic：接口转换：接口 {}
是映射[接口 {}]接口 {}，而不是 main.awsConfig \

我是否必须使用自定义UnmarshalYAML函数实现YAML包的Unmarshaler接口才能完成此操作？

Answer 1

这种类型的任务（您希望延迟解组）与json非常相似。RawMessage适用于这样的示例。

yaml 包没有类似的 RawMessage 机制 - 但这种技术可以很容易地复制，如下所述：

type RawMessage struct {
    unmarshal func(interface{}) error
}

func (msg *RawMessage) UnmarshalYAML(unmarshal func(interface{}) error) error {
    msg.unmarshal = unmarshal
    return nil
}

// call this method later - when we know what concrete type to use
func (msg *RawMessage) Unmarshal(v interace{}) error {
    return msg.unmarshal(v)
}

因此，要在您的案例中利用这一点：

var fs struct {
    Configs []struct {
        Type   string     `yaml:"type"`
        Config RawMessage `yaml:"config"` // delay unmarshaling
    } `yaml:"fetchers"`
}

err = yaml.Unmarshal([]byte(data), &fs)
if err != nil {
    return
}

根据配置“类型”(< code>aws或< code>kubernetes)，您最终可以将< code>RawMessage解组为正确的具体类型:

aws := awsConfig{} // concrete type
err = c.Config.Unmarshal(&aws)

或：

k8s := kubernetesConfig{} // concrete type
err = c.Config.Unmarshal(&k8s)

这里的工作示例：https://go.dev/play/p/wsykOXNWk3H

Answer 2

通过实现解组器接口找到了解决方案:

type Fetcher struct {
    Type   string      `yaml:"type"`
    Config interface{} `yaml:"config"`
}

// Interface compliance
var _ yaml.Unmarshaler = &Fetcher{}

func (f *Fetcher) UnmarshalYAML(unmarshal func(interface{}) error) error {
    var t struct {
        Type string `yaml:"type"`
    }
    err := unmarshal(&t)
    if err != nil {
        return err
    }
    f.Type = t.Type
    switch t.Type {
    case "kubernetes":
        var c struct {
            Config kubernetesConfig `yaml:"config"`
        }
        err := unmarshal(&c)
        if err != nil {
            return err
        }
        f.Config = c.Config
    case "aws":
        var c struct {
            Config awsConfig `yaml:"config"`
        }
        err := unmarshal(&c)
        if err != nil {
            return err
        }
        f.Config = c.Config
    }
    return nil
}