Java

package com.opencensus.tutorials;

import com.google.cloud.spanner.DatabaseClient;
import com.google.cloud.spanner.DatabaseId;
import com.google.cloud.spanner.Key;
import com.google.cloud.spanner.Mutation;
import com.google.cloud.spanner.Spanner;
import com.google.cloud.spanner.SpannerOptions;
import io.opencensus.common.Scope;
import io.opencensus.contrib.grpc.metrics.RpcViews;
import io.opencensus.exporter.stats.stackdriver.StackdriverStatsExporter;
import io.opencensus.exporter.trace.stackdriver.StackdriverTraceConfiguration;
import io.opencensus.exporter.trace.stackdriver.StackdriverTraceExporter;
import io.opencensus.trace.Tracing;
import io.opencensus.trace.samplers.Samplers;
import java.util.Arrays;
import java.util.List;

public class SpannerOpenCensusTutorial {
  private DatabaseClient dbClient;
  private Spanner spanner;

  private static final String parentSpanName = "create-players";

  public SpannerOpenCensusTutorial(String instanceId, String databaseId) throws Exception {
    // Instantiate the client.
    SpannerOptions options = SpannerOptions.getDefaultInstance();
    spanner = options.getService();

    // And then create the Spanner database client.
    String projectId = options.getProjectId();
    dbClient = spanner.getDatabaseClient(DatabaseId.of(projectId, instanceId, databaseId));

    // Next up let's  install the exporter for Stackdriver tracing.
    StackdriverTraceExporter.createAndRegister(
        StackdriverTraceConfiguration.builder().setProjectId(projectId).build());

    Tracing.getExportComponent()
        .getSampledSpanStore()
        .registerSpanNamesForCollection(Arrays.asList(parentSpanName));

    // Then the exporter for Stackdriver monitoring/metrics.
    StackdriverStatsExporter.createAndRegister();

    // Finally register the gRPC views to give us metrics.
    RpcViews.registerAllGrpcViews();
  }

  public void close() {
    spanner.close();
  }

  public void warmUpRead() {
    dbClient.singleUse().readRow("Players", Key.of("foo@gmail.com"), Arrays.asList("email"));
  }

  public static void main(String... args) throws Exception {
    if (args.length < 2) {
      System.err.println("Usage: ZeuSports <instance_id> <database_id>");
      return;
    }

    try {
      SpannerOpenCensusTutorial zdb = new SpannerOpenCensusTutorial(args[0], args[1]);
      // Warm up the spanner client session. In normal usage
      // you'd have hit this point after the first operation.
      zdb.warmUpRead();

      for (int i = 0; i < 3; i++) {
        String up = i + "-" + (System.currentTimeMillis() / 1000) + ".";
        List<Mutation> mutations =
            Arrays.asList(
                playerMutation(
                    "Poke",
                    "Mon",
                    up + "poke.mon@example.org",
                    "f1578551-eb4b-4ecd-aee2-9f97c37e164e"),
                playerMutation(
                    "Go",
                    "Census",
                    up + "go.census@census.io",
                    "540868a2-a1d8-456b-a995-b324e4e7957a"),
                playerMutation(
                    "Quick",
                    "Sort",
                    up + "q.sort@gmail.com",
                    "2b7e0098-a5cc-4f32-aabd-b978fc6b9710"));

        zdb.insertPlayers(mutations);
      }

      zdb.close();
    } catch (Exception e) {
      System.out.printf("Exception while adding player: " + e);
    } finally {
      System.out.println("Bye!");
    }
  }

  public static Mutation playerMutation(
      String firstName, String lastName, String email, String uuid) {
    return Mutation.newInsertBuilder("Players")
        .set("first_name")
        .to(firstName)
        .set("last_name")
        .to(lastName)
        .set("uuid")
        .to(uuid)
        .set("email")
        .to(email)
        .build();
  }

  public void insertPlayers(List<Mutation> players) throws Exception {
    try (Scope ss =
        Tracing.getTracer()
            .spanBuilderWithExplicitParent(parentSpanName, null)
            // Enable the trace sampler.
            //  We are always sampling for demo purposes only: this is a very high sampling
            // rate, but sufficient for the purpose of this quick demo.
            // More realistically perhaps tracing 1 in 10,000 might be more useful
            .setSampler(Samplers.alwaysSample())
            .startScopedSpan()) {

      dbClient.write(players);
    } finally {
    }
  }
}

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.opencensus.tutorials</groupId>
  <artifactId>opencensus-tutorials</artifactId>
  <packaging>jar</packaging>
  <version>1.0-SNAPSHOT</version>
  <name>opencensus-examples</name>
  <url>http://maven.apache.org</url>

  <properties>
    <maven.compiler.target>1.8</maven.compiler.target>
    <maven.compiler.source>1.8</maven.compiler.source>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <opencensus.version>0.18.0</opencensus.version>
    <spanner.version>1.5.0</spanner.version>
  </properties>

  <dependencies>
    <dependency>
      <groupId>com.google.cloud</groupId>
      <artifactId>google-cloud-spanner</artifactId>
      <version>${spanner.version}</version>
      <exclusions>
	<exclusion>
	  <groupId>com.google.guava</groupId>
	  <artifactId>guava-jdk5</artifactId>
	</exclusion>
	<exclusion>
	  <groupId>io.opencensus</groupId>
	  <artifactId>opencensus-api</artifactId>
	</exclusion>
      </exclusions>
    </dependency>

    <dependency>
      <groupId>com.google.guava</groupId>
      <artifactId>guava</artifactId>
      <version>20.0</version>
    </dependency>

    <dependency>
      <groupId>io.opencensus</groupId>
      <artifactId>opencensus-api</artifactId>
      <version>${opencensus.version}</version>
    </dependency>

    <dependency>
      <groupId>io.opencensus</groupId>
      <artifactId>opencensus-exporter-stats-stackdriver</artifactId>
      <version>${opencensus.version}</version>
    </dependency>

    <dependency>
      <groupId>io.opencensus</groupId>
      <artifactId>opencensus-exporter-trace-stackdriver</artifactId>
      <version>${opencensus.version}</version>
    </dependency>

    <dependency>
      <groupId>io.opencensus</groupId>
      <artifactId>opencensus-contrib-grpc-metrics</artifactId>
      <version>${opencensus.version}</version>
    </dependency>


    <dependency>
      <groupId>io.opencensus</groupId>
      <artifactId>opencensus-impl</artifactId>
      <version>${opencensus.version}</version>
      <scope>runtime</scope>
    </dependency>

  </dependencies>

  <build>
    <plugins>
      <plugin>
        <groupId>org.codehaus.mojo</groupId>
        <artifactId>exec-maven-plugin</artifactId>
        <version>1.4.0</version>
        <configuration>
            <mainClass>com.opencensus.tutorials.SpannerOpenCensusTutorial</mainClass>
            <cleanupDaemonThreads>false</cleanupDaemonThreads>
        </configuration>
      </plugin>
    </plugins>
  </build>

</project>