[go] Go 언어를 사용하여 AWS Kinesis Firehose를 통한 데이터 처리하기

18 Dec 2023

AWS Kinesis Firehose는 데이터를 처리하고 Amazon S3, Amazon Redshift, Amazon Elasticsearch Service 및 Splunk와 같은 대게 대규모 저장소로 쉽게 전송할 수 있는 완전관리형 서비스입니다. Go 언어를 사용하여 AWS Kinesis Firehose를 통해 데이터를 처리하고 전송하는 방법에 대해 알아보겠습니다.

AWS SDK 설치

먼저 Go 언어로 AWS 서비스를 사용하기 위해 AWS SDK for Go를 설치해야 합니다. 아래 명령을 사용하여 설치할 수 있습니다.

go get -u github.com/aws/aws-sdk-go

AWS Kinesis Firehose로 데이터 전송

package main

import (
    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/service/firehose"
    "fmt"
)

func main() {
    // AWS 세션 생성
    sess := session.Must(session.NewSessionWithOptions(session.Options{
        SharedConfigState: session.SharedConfigEnable,
    }))

    // Kinesis Firehose 서비스 연결
    svc := firehose.New(sess)

    // 전송할 데이터 생성
    data := "example data"

    // Firehose로 데이터 전송
    _, err := svc.PutRecord(&firehose.PutRecordInput{
        DeliveryStreamName: aws.String("your-delivery-stream-name"),
        Record: &firehose.Record{
            Data: []byte(data),
        },
    })

    if err != nil {
        fmt.Println("Error", err)
        return
    }

    fmt.Println("Record sent")
}

위 예제는 AWS SDK를 사용하여 Go 코드로 Kinesis Firehose로 데이터를 전송하는 방법을 보여줍니다.

이제 Go 언어를 사용하여 AWS Kinesis Firehose를 통해 데이터를 처리하고 전송할 수 있습니다. 더 많은 세부 정보는 AWS 공식 문서를 참고하시기 바랍니다.

AWS SDK for Go: AWS SDK for Go

AWS Kinesis Firehose: Kinesis Firehose