当在API Gateway中使用AWS Firehose的PutRecordBatch操作时,需要使用映射模板来将传入的请求数据映射到Firehose的PutRecordBatch请求格式。
以下是一个示例映射模板的代码:
{
"Records": [
#foreach($item in $input.path('$'))
{
"Data": "$util.base64Encode($item.data)",
"PartitionKey": "$item.partitionKey"
}#if($foreach.hasNext),#end
#end
]
}
这个映射模板假设输入数据是一个JSON数组,每个数组项包含一个"data"字段和一个"partitionKey"字段。
在映射模板中,使用了Velocity模板语言来迭代输入数据并构建Firehose的PutRecordBatch请求格式。每个数据记录被base64编码并包含在"Data"字段中,而"PartitionKey"字段则是用于指定记录的分区键。
使用这个映射模板,您可以在API Gateway的集成请求中设置映射模板,并将请求数据传递给Firehose的PutRecordBatch操作。