小编jon*_*jon的帖子

如何使用 AWS Lambda for Firehose 和 CDK 启用转换源记录

我正在尝试使用 CDK 启用资源转换(使用 Lambda)到 Kinesis Firehose。我已经知道如何使用控制台执行此操作,但我不知道如何使用 AWS CDK 实现此操作。这是我迄今为止使用 Typescript 的代码

// KINESIS STREAM
const kinesisStream = new kinesis.CfnDeliveryStream(this, `${props.name}-Kinesis`, {
  deliveryStreamName: `${props.name}-Stream`,
  deliveryStreamType: 'DirectPut',
  s3DestinationConfiguration: {
    bucketArn: props.eventsBucketArn,
    bufferingHints: {
      intervalInSeconds: 300,
      sizeInMBs: 5,
    },
    compressionFormat: 'UNCOMPRESSED',
    prefix: 'year=!{timestamp:yyyy}/month=!{timestamp:MM}/day=!{timestamp:dd}/hour=!{timestamp:HH}/',
    errorOutputPrefix: 'Errors/year=!{timestamp:yyyy}/month=!{timestamp:MM}/day=!{timestamp:dd}/hour=!{timestamp:HH}/!{firehose:error-output-type}',
    roleArn: kinesisRole.roleArn
  }
});
Run Code Online (Sandbox Code Playgroud)

先谢谢您的帮助!

amazon-s3 typescript aws-lambda amazon-kinesis-firehose aws-cdk

5
推荐指数
1
解决办法
1912
查看次数