CDK - how to set OpenSearch/Elasticsearch as the destination of a Kinesis Firehose?

Question

I am trying to create Data Stream -> Firehose -> OpenSearch infrastructure using the AWS CDK v2.

In my CDK Stack I have created an [OpenSearch `Domain`](https://docs.aws.amazon.com/cdk/api/v2/docs/aws-cdk-lib.aws_opensearchservice.Domain.html), and am trying to create a Kinesis Firehose [`DeliveryStream`](https://docs.aws.amazon.com/cdk/api/v2/docs/@aws-cdk_aws-kinesisfirehose-alpha.DeliveryStream.html) with that domain as the destination. However, kinesisfirehose-destinations package seems to only have a ready-to-use [construct for S3 buckets](https://docs.aws.amazon.com/cdk/api/v2/docs/@aws-cdk_aws-kinesisfirehose-destinations-alpha.S3BucketProps.html), so there is no obvious way to do this easily.

I have tried implementing my own [`IDestination`](https://docs.aws.amazon.com/cdk/api/v2/docs/@aws-cdk_aws-kinesisfirehose-alpha.IDestination.html), but I am at a complete loss since I have no idea how to implement `bind`.

So, my questions are:

1. How are you supposed to implement `bind` in `IDestination`?
2. Are there any complete working examples of creating a Firehose to OpenSearch using the non-alpha L1 constructs?

Answer

Hi, I would like to share my repository: https://github.com/aws-samples/aws-iot-greengrass-v2-using-aws-cdk.
In here, I am passing data from Firehorse to ES using CDK ver1 with L1 Construct.
https://github.com/aws-samples/aws-iot-greengrass-v2-using-aws-cdk/blob/main/infra/stack/data/data-pipeline-stack.ts

Because this code uses L1 construct(cdk v1) instead of alpha cdk v2, you can apply this code directly in your cdk ver2.

CDK - how to set OpenSearch/Elasticsearch as the destination of a Kinesis Firehose?

Relevanter Inhalt