Skip to content

Instantly share code, notes, and snippets.

@rakyll rakyll/main.go
Created Jan 16, 2018

Embed
What would you like to do?
Go Spanner Client with OpenCensus
// Copyright 2018 Google Inc. All rights reserved.
// Use of this source code is governed by the Apache 2.0
// license that can be found in the LICENSE file.
// Sample contains a simple program that
// uses Google Spanner Go client, and reports metrics
// and traces for the outgoing requests.
package main
import (
"log"
"cloud.google.com/go/spanner"
ss "go.opencensus.io/exporter/stats/stackdriver"
ts "go.opencensus.io/exporter/trace/stackdriver"
"go.opencensus.io/stats"
"go.opencensus.io/trace"
"golang.org/x/net/context"
)
func main() {
ctx := context.Background()
// Enable OpenCensus exporters to export traces and metrics
// to Stackdriver Monitoring and Tracing.
// Exporters use Application Default Credentials to authenticate.
// See https://developers.google.com/identity/protocols/application-default-credentials
// for more details.
statsExporter, err := ss.NewExporter(ss.Options{ProjectID: "your-project-id"})
if err != nil {
log.Fatal(err)
}
traceExporter, err := ts.NewExporter(ts.Options{ProjectID: "your-project-id"})
if err != nil {
log.Fatal(err)
}
stats.RegisterExporter(statsExporter)
trace.RegisterExporter(traceExporter)
// This database must exist.
databaseName := "projects/your-project-id/instances/your-instance-id/databases/your-database-id"
client, err := spanner.NewClient(ctx, databaseName)
if err != nil {
log.Fatalf("Failed to create client %v", err)
}
defer client.Close()
_, err = client.Apply(ctx, []*spanner.Mutation{
spanner.Insert("Users",
[]string{"name", "email"},
[]interface{}{"alice", "a@example.com"})})
if err != nil {
log.Printf("Failed to insert: %v", err)
}
// Make sure data is uploaded before program finishes.
statsExporter.Flush()
traceExporter.Flush()
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.