Go

이 Go SDK는 CDNetworks 오브젝트 스토리지(OS)에서 제공하는 공식 API를 기반으로 개발되었습니다.

버전 정보

현재 버전: v1.0.1

요구 사항

Go 1.7 이상 필요

설치

아래 명령어를 실행하여 SDK를 설치하세요.
go get -u github.com/CDNetworks-Object-Storage/wcs-go-sdk-v2/wos

초기화

WosClient(WOS 클라이언트)는 CDNetworks 오브젝트 스토리지에 접근하기 위한 Go 클라이언트입니다. 버킷 및 오브젝트 등 오브젝트 스토리지의 리소스를 관리·운영할 수 있도록 다양한 인터페이스를 제공합니다.
WOS Go SDK를 사용하여 요청을 보내려면 WosClient 인스턴스를 초기화하고, 필요에 따라 클라이언트 설정 파라미터를 조정해야 합니다.

wosClient 생성

var ak = "*** 본인의 Access Key 입력 ***"
var sk = "*** 본인의 Secret Key 입력 ***"
var endpoint = "https://your-endpoint"
var regionName = "your-regionName"

wosClient, err := wos.New(ak, sk, endpoint, wos.WithRegion("your-region"))
if err == nil {
    // wosClient를 이용하여 오브젝트 스토리지에 접근
    // ...
    
    // wosClient 종료
    wosClient.Close()
} else {
    // API 응답에서 에러 코드 및 메시지 파싱
    if wosError, ok := err.(wos.WosError); ok {
        fmt.Println(wosError.StatusCode)
        fmt.Println(wosError.Code)
        fmt.Println(wosError.Message)
    } else {
        fmt.Println(err)
    }
}

설정(Configurations)

클라이언트 생성 시 다양한 파라미터를 통해 설정을 지정할 수 있습니다. 예를 들어, 응답 헤더 수신 시간 제한을 30초로 설정하는 경우:

wosClient, err := wos.New(ak, sk, endpoint, wos.WithHeaderTimeout(30))

파라미터

빠른 시작

버킷 목록 조회

var ak = "*** 본인의 Access Key 입력 ***"
var sk = "*** 본인의 Secret Key 입력 ***"
var endpoint = "https://your-endpoint"

wosClient, _ := wos.New(ak, sk, endpoint, wos.WithRegion("your-region"))

input := &wos.ListBucketsInput{}
input.QueryLocation = true
output, err := wosClient.ListBuckets(input)
if err == nil {
    fmt.Printf("StatusCode:%d, RequestId:%s\n", output.StatusCode, output.RequestId)
    fmt.Printf("Owner.DisplayName:%s, Owner.ID:%s\n", output.Owner.DisplayName, output.Owner.ID)
    for index, val := range output.Buckets {
        fmt.Printf("Bucket[%d]-Name:%s,CreationDate:%s,EndPoint:%s,Region:%s\n", index, val.Name, val.CreationDate, val.Endpoint, val.Region)
    }
} else {
    // API 응답에서 에러 코드 및 메시지 파싱
    if wosError, ok := err.(wos.WosError); ok {
        fmt.Println(wosError.StatusCode)
        fmt.Println(wosError.Code)
        fmt.Println(wosError.Message)
    } else {
        fmt.Println(err)
    }
}

오브젝트 목록 조회

var ak = "*** 본인의 Access Key 입력 ***"
var sk = "*** 본인의 Secret Key 입력 ***"
var endpoint = "https://your-endpoint"

wosClient, _ := wos.New(ak, sk, endpoint, wos.WithRegion("your-region"))

input := &wos.ListObjectsInput{}
input.Bucket = bucketName
//  input.Prefix = "src/"
output, err := wosClient.ListObjects(input)
if err == nil {
    fmt.Printf("StatusCode:%d, RequestId:%s,OwnerId:%s,OwnerName:%s,\n", output.StatusCode, output.RequestId, output.Owner.ID, output.Owner.DisplayName)
    for index, val := range output.Contents {
        fmt.Printf("Content[%d]-ETag:%s, Key:%s, LastModified:%s, Size:%d, StorageClass:%s\n",
            index, val.ETag, val.Key, val.LastModified, val.Size, val.StorageClass)
    }
} else {
    // API 응답에서 에러 코드 및 메시지 파싱
    if wosError, ok := err.(wos.WosError); ok {
        fmt.Println(wosError.StatusCode)
        fmt.Println(wosError.Code)
        fmt.Println(wosError.Message)
    } else {
        fmt.Println(err)
    }
}

오브젝트 업로드

var ak = "*** 본인의 Access Key 입력 ***"
var sk = "*** 본인의 Secret Key 입력 ***"
var endpoint = "https://your-endpoint"

wosClient, _ := wos.New(ak, sk, endpoint, wos.WithRegion("your-region"))

input := &wos.PutObjectInput{}
input.Bucket = bucketName
input.Key = objectKey
input.Metadata = map[string]string{"meta": "value"}
input.Body = strings.NewReader("Hello WOS")
output, err := wosClient.PutObject(input)
if err == nil {
    fmt.Printf("StatusCode:%d, RequestId:%s\n", output.StatusCode, output.RequestId)
    fmt.Printf("ETag:%s", output.ETag)
} else {
    // API 응답에서 에러 코드 및 메시지 파싱
    if wosError, ok := err.(wos.WosError); ok {
        fmt.Println(wosError.StatusCode)
        fmt.Println(wosError.Code)
        fmt.Println(wosError.Message)
    } else {
        fmt.Println(err)
    }
}

오브젝트 다운로드

var ak = "*** 본인의 Access Key 입력 ***"
var sk = "*** 본인의 Secret Key 입력 ***"
var endpoint = "https://your-endpoint"

wosClient, _ := wos.New(ak, sk, endpoint, wos.WithRegion("your-region"))

input := &wos.GetObjectInput{}
input.Bucket = bucketName
input.Key = objectKey
output, err := wosClient.GetObject(input)
if err == nil {
    defer output.Body.Close()
    fmt.Printf("StatusCode:%d, RequestId:%s\n", output.StatusCode, output.RequestId)
    fmt.Printf("StorageClass:%s, ETag:%s, ContentType:%s, ContentLength:%d, LastModified:%s\n",
        output.StorageClass, output.ETag, output.ContentType, output.ContentLength, output.LastModified)
    p := make([]byte, 1024)
    var readErr error
    var readCount int
    for {
        readCount, readErr = output.Body.Read(p)
        if readCount > 0 {
            fmt.Printf("%s", p[:readCount])
        }
        if readErr != nil {
            break
        }
    }
} else {
    // API 응답에서 에러 코드 및 메시지 파싱
    if wosError, ok := err.(wos.WosError); ok {
        fmt.Println(wosError.StatusCode)
        fmt.Println(wosError.Code)
        fmt.Println(wosError.Message)
    } else {
        fmt.Println(err)
    }
}

오브젝트 삭제

var ak = "*** 본인의 Access Key 입력 ***"
var sk = "*** 본인의 Secret Key 입력 ***"
var endpoint = "https://your-endpoint"

wosClient, _ := wos.New(ak, sk, endpoint, wos.WithRegion("your-region"))

input := &wos.DeleteObjectInput{}
input.Bucket = bucketName
input.Key = objectKey
output, err := wosClient.DeleteObject(input)
if err == nil {
    fmt.Printf("StatusCode:%d, RequestId:%s\n", output.StatusCode, output.RequestId)
} else {
    // API 응답에서 에러 코드 및 메시지 파싱
    if wosError, ok := err.(wos.WosError); ok {
        fmt.Println(wosError.StatusCode)
        fmt.Println(wosError.Code)
        fmt.Println(wosError.Message)
    } else {
        fmt.Println(err)
    }
}

멀티파트 업로드

단순 멀티파트 업로드

example/simple_multipart_upload_sample.go 참조

병렬 멀티파트 업로드

example/multipart_upload_sample.go 참조

기능 목록

자세한 예시는 wos_go_sample.go 참고

샘플 예시