telegraf introduce
telegraf github 地址
why have this blog
我要写一个特殊监控，现有的telegraf插件又没有办法实现，所以就要自己写一个input plugin
先讲一下通常方法下，现有的input插件无法满足要求的情况下怎么做：
有一个input.exec插件，可以获取命令执行后的结果，取到这个结果然后结合一下telegraf允许输入的格式，就可以了。无奈我写bash的水平实在是太低了，刚开始的时候也没有发现这个东西，所以就没有管这个，直接上手撸了个插件
how write a input plugin
先看一下官方教程吧
如果看懂的话大概就不太需要接下来的东西了
接下来是小白版的教程：
一个input plugin需要从以下做起：
- 在 /telegraf/plugins/input/ 下增加插件文件夹
- 编写插件go文件
- 在 /telegraf/plugins/input/all/all.go下增加编写好的路径
- 重新编译telegraf
- 运行
接下来主要看以下 插件文件的编写，以下称为 example.go
要先给定一个输入参数的结构体：
type Info struct { Address []string `toml:"address"` }
这个结构体会作为很多函数的输入用：
描述：
func (*Info) Description() string { return "return netconf result" }
样例输入：
var sampleConfig = ` Address = ["西街小学"] ` func (*Info) SampleConfig() string { return sampleConfig }
初始化：
func init() { inputs.Add("sample", func() telegraf.Input { return &Info{} }) }
Gather函数：用来处理信息、将信息给后续组件进行处理
func (a *Info) Gather(acc telegraf.Accumulator) error { //内容自由发挥，填写好addGauge的四个参数就ok fieldsG := map[string]interface{}{ "address": a.Address, } tags := map[string]string{}{} now := time.Now() acc.AddGauge("test", fieldsG, tags, now) return nil }
将以上几个部分组合在一起就是一个最简单的input插件。最重要的就是gather函数，自己来组织fieldsG这个结构体，将要监控的信息填进去。
