# Create Kinesis Data Firehose Delivery Stream

이 섹션에서는 Kinesis Data Stream에서 뉴욕시 택시 운행 데이터를 불러오는데 사용할 새로운 Kinesis Data Firehose Delivery Stream을 생성합니다.

1\. AWS 관리 콘솔에서 Amazon Kinesis 서비스로 이동합니다 .

2\. **Create delivery stream**을 선택합니다.

![](/files/HOVX2Uk60D6RioEaW7FX)

3\. **Source**에 **Amazon Kinesis Data Stream**을 선택합니다. **Destination**에 **Amazon S3**를 선택합니다.. **Browse** 버튼을 클릭하면 나오는 Kinesis Data Stream 목록에서 *input-stream*을 선택합니다.

![](https://static.us-east-1.prod.workshops.aws/public/ec99f585-8ba1-4d5a-aaa9-ec4d126a8699/static/lab-3-kdf/images/image7.png)

4\. Delivery Stream 이름에 `nyc-taxi-trips` 입력합니다. **Data transformation**를 **Enabled**로 선택하고 **Browse**를 클릭해서 *NYCTaxiTrips-DataTransformation* 람다 함수를 선택합니다. 해당 람다 함수는 수신한 데이터에 **source** 필드를 추가하고 해당 필드의 값을 *NYCTAXI*로 지정합니다.

![](https://static.us-east-1.prod.workshops.aws/public/ec99f585-8ba1-4d5a-aaa9-ec4d126a8699/static/lab-3-kdf/images/image8.png)

5\. **Record format conversion**을 **Enabled**로 선택하고 **Output format**을 **Apache Parquet**으로 선택합니다. **AWS Glue region**에 **Asia Pacific (Seoul)**을 선택하고 **AWS Glue database**에 *kinesislab*을 선택합니다. **AWS Glue table**는 이전 섹션에서 생성한 *nyctaxitrips*를 선택합니다.

![](/files/uXGe3IHxxM9Z7kBcB7Qe)

6\. **S3 Bucket** 오른쪽에 있는 **Browse**를 클릭해서 *kinesis-bucket*으로 시작하는 S3 버킷을 선택합니다. 

**S3 bucket prefix**에 아래의 값을 복사하여 붙여 넣습니다.

```
nyctaxitrips/year=!{timestamp:YYYY}/month=!{timestamp:MM}/day=!{timestamp:dd}/hour=!{timestamp:HH}/
```

**S3 bucket error output prefix**에 아래의 같은 복사하여 붙여 넣습니다.

```
nyctaxitripserror/!{firehose:error-output-type}/year=!{timestamp:YYYY}/month=!{timestamp:MM}/day=!{timestamp:dd}/hour=!{timestamp:HH}/
```

![](/files/bmwwA4f9h9NC2l5fRBid)

7\. **Buffer interval**을 60초 변경합니다.

![](https://static.us-east-1.prod.workshops.aws/public/ec99f585-8ba1-4d5a-aaa9-ec4d126a8699/static/lab-3-kdf/images/image11.png)

8\. **Create delivery stream**을 클릭합니다.

![](https://static.us-east-1.prod.workshops.aws/public/ec99f585-8ba1-4d5a-aaa9-ec4d126a8699/static/lab-3-kdf/images/image12.png)


---

# Agent Instructions: Querying This Documentation

If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question.

Perform an HTTP GET request on the current page URL with the `ask` query parameter:

```
GET https://workshop.fitcloud.co.kr/immersion-day/2022.12-data-analytics/lambda-with-kinesis-data-firehose/create-kinesis-data-firehose-delivery-stream.md?ask=<question>
```

The question should be specific, self-contained, and written in natural language.
The response will contain a direct answer to the question and relevant excerpts and sources from the documentation.

Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.