如何使用Go external插件与Telegraf交互？

package main

import (
    "bufio"
    "fmt"
    "os"
    "strings"
    "time"

    "github.com/influxdata/telegraf/plugins/inputs"
)

type MyPlugin struct {
}

func (p *MyPlugin) SampleConfig() string {
    return ""
}

func (p *MyPlugin) Description() string {
    return ""
}

func (p *MyPlugin) Gather(acc inputs.Accumulator) error {
    // 与Telegraf交互的逻辑
    // 例如，通过调用外部函数获取数据
    data := fetchData()

    // 将数据传递给Telegraf
    acc.AddFields("my_measurement", map[string]interface{}{
        "field1": data.Field1,
        "field2": data.Field2,
    }, nil, time.Now())

    return nil
}

func fetchData() Data {
    // 调用外部函数获取数据
    // ...

    return data
}

type Data struct {
    Field1 string
    Field2 int
}

func main() {
    reader := bufio.NewReader(os.Stdin)
    for {
        line, err := reader.ReadString('\n')
        if err != nil {
            break
        }

        line = strings.TrimSpace(line)
        if line == "quit" {
            break
        }

        // 处理来自Telegraf的命令
        // ...

        // 向Telegraf发送数据
        fmt.Println("data1,tag1=value1 field1=1,field2=2")
    }
}

[[inputs.exec]]
  commands = ["path/to/your/executable"]
  data_format = "influx"