The purpose of this pull request is to provide an example on how OpenSearch Ingestion Pipeline could be used to ingest CloudWatch logs into Opensearch using a CloudWatch Lambda subscription filter.
This example creates the following resources:
OpenSearch Serverless collection in a VPC where the logs would eventually be written to by the OpenSearch Ingestion Pipeline sink.
OpenSearch Ingestion pipeline
CloudWatch Subscription Filter with Lambda function to call the OSI pipeline endpoint to push logs data received from an incoming log stream.
By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.
Fixes #1055
The purpose of this pull request is to provide an example on how OpenSearch Ingestion Pipeline could be used to ingest CloudWatch logs into Opensearch using a CloudWatch Lambda subscription filter.
This example creates the following resources:
CloudWatch Subscription Filter with Lambda function to call the OSI pipeline endpoint to push logs data received from an incoming log stream.
By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.