ray/scripts
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Ruff format

Browse source
This commit is contained in:
Ray Miller 2024-10-23 10:50:59 +01:00
parent a0edf5d9e9
commit 7c24308039
1 changed files with 13 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
aws/cloudwatch-log-costs.py
View file

@ -29,10 +29,10 @@ for page in paginator.paginate(Namespace="AWS/Logs", MetricName="IncomingBytes")
"Metric": { "Metric": {
"Namespace": metric["Namespace"], "Namespace": metric["Namespace"],
"MetricName": metric["MetricName"], "MetricName": metric["MetricName"],
"Dimensions": metric["Dimensions"] "Dimensions": metric["Dimensions"],
}, },
"Period": int(period.total_seconds()), "Period": int(period.total_seconds()),
"Stat": "Sum" "Stat": "Sum",
}, },
} }
if not metric["Dimensions"]: if not metric["Dimensions"]:
@ -47,10 +47,17 @@ for page in paginator.paginate(Namespace="AWS/Logs", MetricName="IncomingBytes")
# otherwise we would have to chunk up the calls to GetMetricData. # otherwise we would have to chunk up the calls to GetMetricData.
results = [] results = []
data_paginator = cw.get_paginator("get_metric_data") data_paginator = cw.get_paginator("get_metric_data")
for data_page in data_paginator.paginate(MetricDataQueries=queries, StartTime=start_time, EndTime=end_time): for data_page in data_paginator.paginate(
MetricDataQueries=queries, StartTime=start_time, EndTime=end_time
):
for result in data_page["MetricDataResults"]: for result in data_page["MetricDataResults"]:
if result["Values"]: if result["Values"]:
results.append({"LogGroup": query_names[result["Id"]], "IncomingBytes": result["Values"][0]}) results.append(
{
"LogGroup": query_names[result["Id"]],
"IncomingBytes": result["Values"][0],
}
)
results.sort(key=lambda x: x["IncomingBytes"], reverse=True) results.sort(key=lambda x: x["IncomingBytes"], reverse=True)