amazon-web-services - 通过 Cloudformation 模板将 Lambda 函数添​​加到 Kinesis Firehose 中

Question

我想将 Lambda 函数添​​加到我的 Kinesis Firehose 中，以按所述 here 转换源数据。

查看Cloudformation Template for Kinesis firehose ，我没有看到这样的选项，

Type: "AWS::KinesisFirehose::DeliveryStream"
Properties: 
  DeliveryStreamName: String
  DeliveryStreamType: String
  ElasticsearchDestinationConfiguration:
    ElasticsearchDestinationConfiguration
  ExtendedS3DestinationConfiguration:
    ExtendedS3DestinationConfiguration
  KinesisStreamSourceConfiguration:
    KinesisStreamSourceConfiguration
  RedshiftDestinationConfiguration:
    RedshiftDestinationConfiguration
  S3DestinationConfiguration:
    S3DestinationConfiguration

如何设置 CF 模板以使 Lambda 函数处理 Kinesis Firehose 的输入？

Answer 1

可以通过 ProcessingConfiguration 来实现此目的，ojit_a 可用于 ES、S3 和 Redshift 目标配置。应如下所示:

"ElasticsearchDestinationConfiguration": {
...
   "ProcessingConfiguration": {
         "Enabled": "true",
         "Processors": [
           {
             "Parameters": [
               {
                 "ParameterName": "LambdaArn",
                 "ParameterValue": "arn:aws:lambda:eu-west-1:123456789:function:cw-transformer:$LATEST"
               }
             ],
             "Type": "Lambda"
           }
         ]
       }
...
}