diff --git a/aws/logs_monitoring/parsing.py b/aws/logs_monitoring/parsing.py index d6c726ec3..d4a6b7fd0 100644 --- a/aws/logs_monitoring/parsing.py +++ b/aws/logs_monitoring/parsing.py @@ -286,8 +286,14 @@ def find_cloudwatch_source(log_group): "api-gateway", # e.g. Api-Gateway-Execution-Logs_xxxxxx/dev # default location set by serverless framework for rest api access logs "/aws/api-gateway", # e.g. /aws/api-gateway/my-project + # Avoid touching the size limit of the log group resource policy + # https://docs.aws.amazon.com/fr_fr/AmazonCloudWatch/latest/logs/AWS-logs-and-resource-policy.html#AWS-logs-infrastructure-CWL + "/aws/vendedlogs/api-gateway", # default location set by serverless framework for http api logs "/aws/http-api", # e.g. /aws/http-api/my-project + # Avoid touching the size limit of the log group resource policy + # https://docs.aws.amazon.com/fr_fr/AmazonCloudWatch/latest/logs/AWS-logs-and-resource-policy.html#AWS-logs-infrastructure-CWL + "/aws/vendedlogs/http-api", ) ): return "apigateway" diff --git a/aws/logs_monitoring/tests/test_parsing.py b/aws/logs_monitoring/tests/test_parsing.py index fe6fce435..9f3d6706b 100644 --- a/aws/logs_monitoring/tests/test_parsing.py +++ b/aws/logs_monitoring/tests/test_parsing.py @@ -122,6 +122,16 @@ def test_apigateway_event(self): parse_event_source({"awslogs": "logs"}, "/aws/http-api/my-project"), "apigateway", ) + self.assertEqual( + parse_event_source({"awslogs": "logs"}, + "/aws/vendedlogs/http-api/my-project"), + "apigateway", + ) + self.assertEqual( + parse_event_source({"awslogs": "logs"}, + "/aws/vendedlogs/http-api/my-project"), + "apigateway", + ) def test_dms_event(self): self.assertEqual(