Sparta-based application that provisions a Kinesis Firehose that includes an AWS Lambda Transformer function.
The transformation is specified by a go
text/template value that
supports the default Kinesis Firehose test data format:
{
"ticker_symbol": "QXZ",
"sector": "HEALTHCARE",
"change": -0.05,
"price": 84.51
}
Transformation:
{
"region" : "{{ .Record.KinesisEventHeader.Region }}",
"key" : {{ .Record.Data.JMESPath "sector"}}
}
See the documentation for more information.
- Install Go
go get github.com/mweagle/SpartaXForm
cd ./SpartaXForm
go run main.go provision --s3Bucket YOUR_S3_BUCKET
- Visit the AWS Kinesis Firehose Console and test your function!