[AWS] API Gateway - Kinesis

IAM

---

Kinesis Put Record - Policy

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Sid": "VisualEditor0",
            "Effect": "Allow",
            "Action": [
                "kinesis:PutRecord"
            ],
            "Resource": "*"
        }
    ]
}

API Gateway - Kinesis Role

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Sid": "",
      "Effect": "Allow",
      "Principal": {
        "Service": "apigateway.amazonaws.com"
      },
      "Action": "sts:AssumeRole"
    }
  ]
}

Kinesis Data Streams

---

create Kinesis Data Streams

API Gateway

---

1. API Gateway -> Crewate API -> Rest API -> Create API
2. API Gateway -> Actions -> Create Method -> POST

3. API Gateway -> Intergration Request -> HTTP Headers
   Content-Type = 'application/x-amz-json-1.1'
   

4. API Gateway -> Intergration Request -> Mapping Templates
   Content-Type : application/json
   

5. API Gateway -> Intergration Request -> Mapping Templates -> application/json
   

{
  "StreamName": "$input.params('stream')",
  "Data": "$util.base64Encode($input.body)",
  "PartitionKey": "$context.requestId"
}

6. API Gateway -> Method Request -> Request Validator
   

7. API Gateway -> Method Request -> Request Body
   Content-Type : application/json
   Model name : Empty
   

8. API Gateway -> Method Request -> URL Query String
   Name : Stream