結論を書くと、チュートリアルに書かれている通りです。
ただ、Initialize Cloud Firestoreにあるサンプルコードのclient, err := firestore.NewClient(ctx, projectID)にあるContextに何を入れれば良いかが書かれていない
GCPのコントロールパネル項目からCloud Firestoreを選択し、有効かします。
※Cloud Datastoreを一度でも有効にしてしまうと、Cloud Firestoreは有効に出来ません
手元の環境でいつも通りgo getを行います
go get "cloud.google.com/go"
手元の開発フォルダでgo mod initと行いgo.modを生成する事により、functions環境で上記ライブラリを使えるようにする
package hello
import (
"net/http"
"cloud.google.com/go/firestore"
"log"
)
func Hello(w http.ResponseWriter, r *http.Request) {
projectID := "GCP-PROJECT-ID"
// Get a Firestore client.
client, err := firestore.NewClient(r.Context(), projectID)
if err != nil {
log.Fatalf("Failed to create client: %v", err)
}
// Close client when done.
defer client.Close()
_, _, err = client.Collection("users").Add(r.Context(), map[string]interface{}{
"first": "Ada",
"last": "Lovelace",
"born": 1915,
})
if err != nil {
log.Fatalf("Failed adding alovelace: %v", err)
}
msg := "Hello World"
w.Write([]byte((msg)))
}
go.modの更新としてgo buildを行います
サーバーの方にアップロードします
gcloud functions deploy helloWorld --entry-point Hello --runtime go111 --trigger-http
deployしたURLにアクセスし、その結果をFirestoreのコントロールパネルで確認し、ユーザーが追加されていれば成功です
おまけですが、GCPとFirebaseを連携するには、Firebaseのコントロールパネルを開き、プロジェクトを追加する際に上記GCPのプロジェクトIDを選択してあげます
出来上がったFirebase ProjectのDatabaseをみると、上記でいれたUserデータが見えると思います
上記の公式リリースの通り、Go言語がまだbeta対応であるが、Google Cloud Functionsにやってきた
Cloud functionsはサーバーレスで簡単な関数を実行してくれる仕組みで大変便利です
公式サンプル@githubには、pubsubとGoogle Cloud Functionsを組み合わせた例は無いです
公式チュートリアルには、組み合わせはあるがペイロードを受信する方法が無いです
gcloudからコマンドでも実行できるが、今回はAPIを有効化するために、コントロールパネルから実行
有効化したらトピック名を指定して作成
projects/{プロジェクト名}/topics/{トピック名}というトピックが出来上がるので、ここで放置
package hello
import (
"encoding/json"
"context"
"log"
)
type PubSubMessage struct {
Data []byte `json:"data"`
Attributes map[string]string `json:"attributes"`
}
type Info struct {
Test1 string `json:"test1"`
Test2 string `json:"test2"`
}
func HelloPubSub(ctx context.Context, m PubSubMessage) error {
var i Info
err := json.Unmarshal(m.Data, &i)
if err != nil {
log.Printf("Error:%T message: %v", err, err)
return nil
}
log.Printf("Data: %s:%s", i.Test1, i.Test2)
log.Printf("Attributes %v", m.Attributes)
return nil
}
今回のトピック名はsample_pubsubとしています
gcloud functions deploy HelloPubSub --runtime go111 --trigger-topic sample_pubsub
実行コマンド
gcloud pubsub topics publish sample_pubsub --message '{"test1":"Test1" ,"test2":"Test2"}' --attribute name=wrench,name1=nameattributeの設定がわかりづらかったです。キーネームペアで=で結び、カンマで複数設定ができました
ログ確認
gcloud functions logs read --limit 50
ログにDataとAttributeの値が出たら終わりです