dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Improve cloudwatch output performance (#4320)

This commit is contained in:
david7482 2018-07-24 02:00:35 +08:00 committed by Greg
parent f37b503f68
commit 9657870258
1 changed files with 4 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
plugins/outputs/cloudwatch/cloudwatch.go
View File

@ -93,27 +93,17 @@ func (c *CloudWatch) Close() error {
} }
func (c *CloudWatch) Write(metrics []telegraf.Metric) error { func (c *CloudWatch) Write(metrics []telegraf.Metric) error {
var datums []*cloudwatch.MetricDatum
for _, m := range metrics { for _, m := range metrics {
err := c.WriteSinglePoint(m) d := BuildMetricDatum(m)
if err != nil { datums = append(datums, d...)
return err
} }
}
return nil
}
// Write data for a single point. A point can have many fields and one field
// is equal to one MetricDatum. There is a limit on how many MetricDatums a
// request can have so we process one Point at a time.
func (c *CloudWatch) WriteSinglePoint(point telegraf.Metric) error {
datums := BuildMetricDatum(point)
const maxDatumsPerCall = 20 // PutMetricData only supports up to 20 data metrics per call const maxDatumsPerCall = 20 // PutMetricData only supports up to 20 data metrics per call
for _, partition := range PartitionDatums(maxDatumsPerCall, datums) { for _, partition := range PartitionDatums(maxDatumsPerCall, datums) {
err := c.WriteToCloudWatch(partition) err := c.WriteToCloudWatch(partition)
if err != nil { if err != nil {
return err return err
} }