【发布时间】:2020-09-11 07:28:33
【问题描述】:
我正在使用 GO (golang) 编写 Kafka(MSK) 订阅者(消费者),并希望将消息消耗计数、错误计数等指标推送到 cloudwatch 指标中。
使用 AWS-SDK PutMetricData() 方法直接推送数据会使函数变慢。
【问题讨论】:
标签: amazon-web-services go apache-kafka amazon-cloudwatch amazon-cloudwatch-metrics
我正在使用 GO (golang) 编写 Kafka(MSK) 订阅者(消费者),并希望将消息消耗计数、错误计数等指标推送到 cloudwatch 指标中。
使用 AWS-SDK PutMetricData() 方法直接推送数据会使函数变慢。
【问题讨论】:
标签: amazon-web-services go apache-kafka amazon-cloudwatch amazon-cloudwatch-metrics
如果您经常发布可能会减慢您速度的单个指标数据点。 AWS文档提出的解决方案是使用statistical sets:
您可以在发布到 CloudWatch 之前聚合您的数据。当您每分钟有多个数据点时,聚合数据可以最大限度地减少对 put-metric-data 的调用次数。
这适用于任何编程语言,无论是 Go 还是 Java。缓慢通常来自频繁调用外部 API,而不是由于语言的性质。
【讨论】: