ここで説明するように、Kinesis FirehoseにLambda関数を追加して、ソースデータを変換したいと思います。
見るとキネシスは、消防ホース用Cloudformationテンプレート、私はそのためのオプションが表示されません、
Type: "AWS::KinesisFirehose::DeliveryStream"
Properties:
DeliveryStreamName: String
DeliveryStreamType: String
ElasticsearchDestinationConfiguration:
ElasticsearchDestinationConfiguration
ExtendedS3DestinationConfiguration:
ExtendedS3DestinationConfiguration
KinesisStreamSourceConfiguration:
KinesisStreamSourceConfiguration
RedshiftDestinationConfiguration:
RedshiftDestinationConfiguration
S3DestinationConfiguration:
S3DestinationConfiguration
Lambda関数がKinesisFirehoseの入力を処理するようにCFテンプレートを設定するにはどうすればよいですか？
これは、ES、S3、およびRedshiftの宛先設定で使用可能なProcessingConfigurationを介して実現できます。次のようになります。
"ElasticsearchDestinationConfiguration": {
...
"ProcessingConfiguration": {
"Enabled": "true",
"Processors": [
{
"Parameters": [
{
"ParameterName": "LambdaArn",
"ParameterValue": "arn:aws:lambda:eu-west-1:123456789:function:cw-transformer:$LATEST"
}
],
"Type": "Lambda"
}
]
}
...
}
この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。
侵害の場合は、連絡してください[email protected]
コメントを追加