plugins - ¿Cómo agregar un complemento a Telegraf?

go influxdb

Question

Hola, quisiera saber si alguien tiene listo agregar un complemento a telegraf para Influxdb . Tengo mi código Go que está funcionando. ¿Qué necesito después y dónde poner estos archivos?

Descubrí que tengo que hacer algo como esto:

type ReadFile struct {
//buf []byte
//MemoryBytes int64
//PID int
}
func (s *ReadFile) Description() string {
return "This is a test plugin to read data from a file and send them to influxdb" }
func (s *ReadFile) SampleConfig() string {
return "ok = true # indicate if everything is fine"
}
func Gather(acc plugins.Accumulator) error {
readFile(alarmFile)
acc.Add("alarm", result_of_readFile_here, tags)
}
}
func init() {
plugins.Add("readFile", func() plugins.Plugin { &ReadFile{} })
}

¿Pero es esto todo mi complemento Go u otro archivo en Ir a agregar con mi programa Go?

¿Y dónde se almacena el archivo .conf?

[tags]
dc = "alarm"
[agent]
interval = "10s"
# OUTPUTS
[outputs]
[outputs.influxdb]
url = "http://127.0.0.1:8086" # required.
database = "summer" # required.
precision = "s"
# PLUGINS
[readFile]

Si tiene una lista de lo que necesito, cómo estructurarlo, dónde almaceno el archivo o tal vez un ejemplo podría ser realmente útil.

¡¡Gracias!!

Answer 1

Existe un problema abierto para el soporte de complementos externos que podría ser parte de Telegraf 1.4.0. Si probablemente cargará archivos externos * .so .

Hasta entonces, todos los complementos se fusionarán en el repositorio principal a través de los RP . Ya hay muchos complementos esperando en el proceso de revisión. Este modelo obviamente no es muy escalable.

Answer 2

-> Recibo esto, me dio una mejor comprensión, creo que podría ser útil:

https://github.com/influxdata/telegraf/blob/master/CONTRIBUTING.md

"Su código de complemento parece ir bien. Necesita colocar ese archivo en $ GOPATH / src / github.com / influxdata / telegraf / plugin / inputs / testPlugin / testPlugin.go

Debería escribir una prueba para el complemento y colocarla en $ GOPATH / src / github.com / influxdata / telegraf / plugin / inputs / testPlugin / testPlugin_test.go

Después de que esto se complete, debe registrar el complemento en $ GOPATH / src / github.com / influxdata / telegraf / plugin / inputs / all / all.go

Luego debería ejecutar make desde $ GOPATH / src / github.com / influxdata / telegraf. Esto colocará el nuevo telegraf binario en $ GOPATH / bin / telegraf.

Ejecute el binario con los siguientes indicadores para generar la configuración válida:

$ GOPATH / bin / telegraf -sample-config -input-filter testPlugin -output-filter influxdb> testPlugin_config.conf

Desde allí puede ejecutar el binario con la bandera de prueba pasándole la configuración de muestra:

$ GOPATH / bin / telegraf -config testPlugin_config.conf -test

Esto generará el protocolo de línea que se insertará en la base de datos ".

-> Y el testPlugin.go del que habla:

package testPlugin
import (
"time"
)
type ReadFile struct {
counter int64
}
func (s *TestPlugin) Description() string {
return "This is a test plugin to write data to influxdb with a plugin"
}
func (s *TestPlugin) SampleConfig() string {
return "ok = true # indicate if everything is fine"
}
func Gather(acc telegraf.Accumulator) error {
c := time.Tick(10 * time.Second)
for now := range c {
counter := counter + 1
acc.Add("counter",counter, tags)
}
}
func init() {
inputs.Add("testPlugin", func() telegraf.Input { return &TestPlugin{} })
}