You can use the script below to check whether you are receiving the metrics correctly.
import boto3 from datetime import datetime, timedelta import time import pytz cloudwatch = boto3.client('cloudwatch') def get_cloudwatch_metrics(namespace, metric_name, dimensions, start_time, end_time): params = { 'StartTime': start_time, 'EndTime': end_time, 'MetricDataQueries': [ { 'Id': 'm1', 'MetricStat': { 'Metric': { 'Namespace': namespace, 'MetricName': metric_name, 'Dimensions': dimensions }, 'Period': 30, 'Stat': 'Sum' } } ] } try: response = cloudwatch.get_metric_data(**params) return response['MetricDataResults'] except Exception as e: print(f"Error fetching metrics: {e}") return [] def main(): namespace = "CWAgent" metric_name = "<MetricsName>" dimensions = [{'Name': 'path', 'Value': 'pathName'}, {'Name':'metric_type', 'Value': 'metric_type_value'}] target_value = 1000 collection_interval_seconds = 30 # utc_now = datetime.now(pytz.UTC) - timedelta(seconds=300) while True: end_time = datetime.now(pytz.UTC) - timedelta(seconds=10) start_time = end_time - timedelta(seconds=collection_interval_seconds) start_time_str = start_time.strftime('%Y-%m-%dT%H:%M:%S') end_time_str = end_time.strftime('%Y-%m-%dT%H:%M:%S') metrics_data = get_cloudwatch_metrics(namespace, metric_name, dimensions, start_time_str, end_time_str) print("Currrent Time: ", datetime.now(pytz.UTC)) print("Start Time: ", start_time_str) print("End Time: ", end_time_str) print(metrics_data) # if metrics_data: # aggregated_value = sum(metrics_data[0]['Values']) if metrics_data[0]['Values'] else None # if aggregated_value and aggregated_value >= target_value: # print(f"Target metric value met or exceeded: {aggregated_value}") # else: # print(f"Current aggregated value: {aggregated_value}, below target.") # else: # print("No metrics data received.") print(f"Sleeping for 10 seconds...") time.sleep(10) print() print() if __name__ == "__main__": main() Requirements.txt:
boto3==1.34.117 botocore==1.34.117 jmespath==1.0.1 python-dateutil==2.9.0.post0 pytz==2024.1 s3transfer==0.10.1 six==1.16.0 urllib3==2.2.1 I have already explained each parameter and its function. For more information, you can refer to this blog:
In the above Python script, some parts are commented out. It is entirely up to you how you want to use this script. Since I wanted to check only the metrics and how often it prints the values and at what time, I was simply printing the time, Also you can modify the metrics_collection_time and period based on your needs.
Alternatively, i also mentioned the go code which could you help you if your primary code in Golang:
package main import ( "fmt" "time" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/session" "github.com/aws/aws-sdk-go/service/cloudwatch" ) func main() { namespace := "CWAgent" metricName := "ingestion/commandservice/totalRequest_count" dimensions := []*cloudwatch.Dimension{ {Name: aws.String("path"), Value: aws.String("pathName")}, {Name: aws.String("metric_type"), Value: aws.String("metricsTypeValue")}, } targetValue := float64(100) collectionIntervalSeconds := int64(30) for { endTime := time.Now().UTC() startTime := endTime.Add(-time.Duration(collectionIntervalSeconds) * time.Second) // var endTime, startTime time.Time // layout := "2006-01-02T15:04:05Z" // endTime, err := time.Parse(layout, "2024-06-05T05:52:33Z") // startTime, err = time.Parse(layout, "2024-06-05T05:51:33Z") // if err != nil { // fmt.Println("Error parsing time:", err) // return // } params := &cloudwatch.GetMetricDataInput{ EndTime: &endTime, StartTime: &startTime, MetricDataQueries: []*cloudwatch.MetricDataQuery{ { Id: aws.String("m1"), MetricStat: &cloudwatch.MetricStat{ Metric: &cloudwatch.Metric{ Namespace: aws.String(namespace), MetricName: aws.String(metricName), Dimensions: dimensions, }, Period: aws.Int64(10), Stat: aws.String("Sum"), }, }, }, } sess, err := session.NewSession(&aws.Config{ Region: aws.String("us-east-1"), }) if err != nil { fmt.Println("Error creating session:", err) return } svc := cloudwatch.New(sess) result, err := svc.GetMetricData(params) if err != nil { fmt.Println("Error getting metric data:", err) continue } var aggregatedValue float64 if len(result.MetricDataResults) > 0 && result.MetricDataResults[0].Values != nil { aggregatedValue = sumFloat64Slice(result.MetricDataResults[0].Values) } fmt.Printf("Start Time: %s\n", startTime.Format(time.RFC3339)) fmt.Printf("End Time: %s\n", endTime.Format(time.RFC3339)) // for _, value := range result.MetricDataResults[0].Values { // fmt.Println(*value) // } if aggregatedValue >= targetValue { fmt.Printf("Target metric value met or exceeded: %.2f\n", aggregatedValue) } else { fmt.Printf("Current aggregated value: %.2f, below target.\n", aggregatedValue) } time.Sleep(10 * time.Second) } } func sumFloat64Slice(slice []*float64) float64 { sum := float64(0) for _, v := range slice { sum += *v } return sum } 
Top comments (0)