Google App Engine / Go で Google Cloud Storage に画像をアップロードする

How to upload image to Google Cloud Storage with Google App Engine / Go.

この情報は2015年9月9日時点のものです。appengine.Context, context.Context 問題は過渡期のようなので今後インタフェースが変わる可能性があります。

File API が終了になったので調べたけどあんまり情報がなく苦労したのでメモとして残しておく

storage#NewWriter に渡す Context は appengine#Context ではなく context#Context なので次のようにするとエラーになります。

view plainprint?

1. import (  
2.  "appengine"  
3.  "google.golang.org/cloud/storage"  
4.  ...  
5. )  
6.   
7. func uploadImage(w http.ResponseWriter, r *http.Request) {  
8.  ...  
9.   
10.  c := appengine.NewContext(r)  
11.   
12.  wc := storage.NewWriter(c, bucketName, fileName)  
13.  wc.ContentType = "image/jpg"  
14.   
15.  if _, err := wc.Write(data); err != nil {  
16.   ...  
17.  }  
18.   
19.  ...  
20. }  

import ( "appengine" "google.golang.org/cloud/storage" ... ) func uploadImage(w http.ResponseWriter, r *http.Request) { ... c := appengine.NewContext(r) wc := storage.NewWriter(c, bucketName, fileName) wc.ContentType = "image/jpg" if _, err := wc.Write(data); err != nil { ... } ... } google.golang.org/appengine の NewContext は context#Context を返すため、こちらを利用します。このワークアラウンドは https://github.com/golang/oauth2/#app-engine を参考にしています。

view plainprint?

1. import (  
2.  "appengine"  
3.  "fmt"  
4.  "io/ioutil"  
5.  "net/http"  
6.  "strings"  
7.   
8.  "golang.org/x/net/context"  
9.  "golang.org/x/oauth2"  
10.  "golang.org/x/oauth2/google"  
11.  newappengine "google.golang.org/appengine"  
12.  newurlfetch "google.golang.org/appengine/urlfetch"  
13.  "google.golang.org/cloud"  
14.  "google.golang.org/cloud/storage"  
15. )  
16.   
17. func uploadImage(w http.ResponseWriter, r *http.Request) {  
18.  file, fileHeader, err := r.FormFile("image_file")  
19.  if err != nil {  
20.   fmt.Fprint(w, "no image")  
21.   // no image  
22.   return  
23.  }  
24.   
25.  defer file.Close()  
26.   
27.  data, err := ioutil.ReadAll(file)  
28.  if err != nil {  
29.   fmt.Fprint(w, "cloud not upload image")  
30.   return  
31.  }  
32.   
33.  var mimeType string  
34.  if strings.HasSuffix(filename, ".png") {  
35.   mimeType = "image/png"  
36.  } else if strings.HasSuffix(filename, ".jpeg") {  
37.   mimeType = "image/jpg"  
38.  } else {  
39.   mimeType = "image/jpg"  
40.  }  
41.   
42.  bucketName := "mybucketname"  
43.  fileName := fileHeader.Filename  
44.   
45.  c := appengine.NewContext(r)  
46.  ctx := newappengine.NewContext(r)  
47.   
48.  hc := &http.Client{  
49.   Transport: &oauth2.Transport{  
50.    Source: google.AppEngineTokenSource(ctx, storage.ScopeFullControl),  
51.    Base:   &newurlfetch.Transport{Context: ctx},  
52.   },  
53.  }  
54.  ctx2 := cloud.NewContext(appengine.AppID(c), hc)  
55.   
56.  wc := storage.NewWriter(ctx2, bucketName, fileName)  
57.  wc.ContentType = mimeType  
58.   
59.  if _, err := wc.Write(data); err != nil {  
60.   fmt.Fprint(w, "cloud not upload image")  
61.   return  
62.  }  
63.   
64.  if err := wc.Close(); err != nil {  
65.   return  
66.  }  

import ( "appengine" "fmt" "io/ioutil" "net/http" "strings" "golang.org/x/net/context" "golang.org/x/oauth2" "golang.org/x/oauth2/google" newappengine "google.golang.org/appengine" newurlfetch "google.golang.org/appengine/urlfetch" "google.golang.org/cloud" "google.golang.org/cloud/storage" ) func uploadImage(w http.ResponseWriter, r *http.Request) { file, fileHeader, err := r.FormFile("image_file") if err != nil { fmt.Fprint(w, "no image") // no image return } defer file.Close() data, err := ioutil.ReadAll(file) if err != nil { fmt.Fprint(w, "cloud not upload image") return } var mimeType string if strings.HasSuffix(filename, ".png") { mimeType = "image/png" } else if strings.HasSuffix(filename, ".jpeg") { mimeType = "image/jpg" } else { mimeType = "image/jpg" } bucketName := "mybucketname" fileName := fileHeader.Filename c := appengine.NewContext(r) ctx := newappengine.NewContext(r) hc := &http.Client{ Transport: &oauth2.Transport{ Source: google.AppEngineTokenSource(ctx, storage.ScopeFullControl), Base: &newurlfetch.Transport{Context: ctx}, }, } ctx2 := cloud.NewContext(appengine.AppID(c), hc) wc := storage.NewWriter(ctx2, bucketName, fileName) wc.ContentType = mimeType if _, err := wc.Write(data); err != nil { fmt.Fprint(w, "cloud not upload image") return } if err := wc.Close(); err != nil { return }
google.golang.org/cloud/storage などは GOPAH を設定して

view plainprint?

1. $ go get -u google.golang.org/cloud/storage  

$ go get -u google.golang.org/cloud/storage でインストールしておきます


参考

• https://github.com/golang/oauth2/#app-engine
• http://blog.a-know.me/entry/2015/04/19/005444
• https://cloud.google.com/appengine/docs/go/googlecloudstorageclient/getstarted