AWS API Gateway-Kinesis-Firehose-S3

KMS·2022년 4월 22일
2

AWS Data Pipeline

목록 보기
2/2
post-thumbnail

API Gateway에 API 등록

  1. API Gateway -> Create API -> REST API -> Create API
  2. API Gateway -> Resources -> Actions -> Create Resource
  3. API Gateway -> Resources -> Actions -> Create Method -> POST
  4. API Gateway -> Resources -> Actions -> Deploy API -> Deploy

결과:


사진에서 Invoke URL이 EC2를 통해서 요청을 보낼 URL이므로 잘 기억하고 있어야 합니다

Kinesis

AWS Kinesis -> Create data stream -> Data Stream name: class-stream -> Create data stream

Kinesis Firehose

AWS Kinesis -> Create delivery stream -> Choose Source and Destination -> Source settings -> Destination Settings -> Create delivery stream

사진에서 처럼 Source랑 Destination을 설정하고, Source settings에서 위해서 생성한 Kinesis Data Stream으로 설정

Destination settings에서 요청 들어온 값을 저장할 S3 버킷 설정한 후, S3 bucket prefix 에 값이 저장되길 원하는 폴더 선택. 해당 폴더가 없을 경우, 자동으로 폴더를 생성 후 값을 저장합니다.

데이터 보내기

EC2에서 'curl -d "{\"name\":\"kms\",\"class\":\"clould\"}" -H "Content-Type: application/json" -X POST {API Gateway Invoke URL}' command를 실행하면, API Gateway Invoke URL로 {'name':'kms', 'class':'could'} 값이 전송되면서 S3에 값이 저장된 것을 확인 할 수 있습니다

profile
Student at Sejong University Department of Software

0개의 댓글