Go

バージョン

Current version: v1.0.1

要件

Go 1.7 or above

インストールする

go get -u github.com/CDNetworks-Object-Storage/wcs-go-sdk-v2/wos

初期化

WosClient（WOS Client）は、CDNetwork Object StorageにアクセスするためのGoクライアントです。呼び出し側がWOSサービスと対話するためのさまざまなインターフェースを提供し、 Object Storage上のバケットやオブジェクトなどのリソースを管理・操作します。
WOS Go SDKを使用してリクエストを行うには、WosClientインスタンスを初期化し、必要に応じてクライアント構成パラメータを調整する必要があります。

wosClientを作成する

var ak = "*** Provide your Access Key ***" var sk = "*** Provide your 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 { // Use wosClient to access Object Storage // ... // Close wosClient wosClient.Close() } else { // Parse error code and message from the API response if wosError, ok := err.(wos.WosError); ok { fmt.Println(wosError.StatusCode) fmt.Println(wosError.Code) fmt.Println(wosError.Message) } else { fmt.Println(err) } }

構成

クライアントの作成時に、パラメータを使用して、さまざまなクライアント構成を指定することができます。例えば、レスポンスヘッダーを取得するためのタイムアウトを30秒に設定します。

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

パラメータ

クイックスタート

リストバケット

var ak = "*** Provide your Access Key ***" var sk = "*** Provide your 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 { // Parse error code and message from the API response 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 = "*** Provide your Access Key ***" var sk = "*** Provide your 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 { // Parse error code and message from the API response 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 = "*** Provide your Access Key ***" var sk = "*** Provide your 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 { // Parse error code and message from the API response 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 = "*** Provide your Access Key ***" var sk = "*** Provide your 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 { // Parse error code and message from the API response 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 = "*** Provide your Access Key ***" var sk = "*** Provide your 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 { // Parse error code and message from the API response 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で例をご覧ください。

サンプル