Use batch serialization format in exec output (influxdata#6446)

bearstech · Apr 17, 2020 · 5296691 · 5296691
1 parent bd958bf
commit 5296691
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/plugins/outputs/exec/exec.go b/plugins/outputs/exec/exec.go
@@ -67,13 +67,11 @@ func (e *Exec) SampleConfig() string {
 // Write writes the metrics to the configured command.
 func (e *Exec) Write(metrics []telegraf.Metric) error {
 	var buffer bytes.Buffer
-	for _, metric := range metrics {
-		value, err := e.serializer.Serialize(metric)
-		if err != nil {
-			return err
-		}
-		buffer.Write(value)
+	serializedMetrics, err := e.serializer.SerializeBatch(metrics)
+	if err != nil {
+		return err
 	}
+	buffer.Write(serializedMetrics)
 
 	if buffer.Len() <= 0 {
 		return nil