AWS API gateway response body template mapping (foreach)

Question

I am trying to save data in S3 through firehose proxied by API gateway. I have create an API gateway endpoint that uses the AWS service integration type and PutRecord action for firehose. I have the mapping template as

{
"DeliveryStreamName": "test-stream",
"Records": [
#foreach($elem in $input.path('$.data'))
{
"Data": "$elem"
}
#if($foreach.hasNext),#end
#end
]
}

Now when I test the endpoint with below JSON

{ 
"data": [ 
{"ticker_symbol":"DemoAPIGTWY","sector":"FINANCIAL","change":-0.42,"price":50.43},{"ticker_symbol":"DemoAPIGTWY","sector":"FINANCIAL","change":-0.42,"price":50.43} 
]
}

JSON gets modified and shows up as below after the transformation

{ticker_symbol=DemoAPIGTWY, sector=FINANCIAL, change=-0.42, price=50.43}

: is being converted to = which is not a valid JSON

Not sure if something is wrong in the above mapping template

Srivignesh KN Srivignesh KN · Accepted Answer · 2018-03-08T00:33:14

API Gateway considers the payload data as a text and not as a Json unless explicitly specified.

Kinesis also expects data to be in encoded format while proxying through API Gateway.

Try the following code and this should work, wondering why the for loop has been commented in the mapping template.

Assuming you are not looping through the record set, the following solution should work for you.

    {
      "DeliveryStreamName": "test-stream",
      "Record": {
      "Data": "$util.base64Encode($input.json('$.Data'))Cg=="
                }
    }

Thanks & Regards, Srivignesh KN

AWS API gateway response body template mapping (foreach)

1 Answers