Escritura de Dataflow con mutaciones

Usa el conector de Dataflow para escribir datos mediante mutaciones.

Explora más

Para obtener documentación en la que se incluye esta muestra de código, consulta lo siguiente:

• Importar, exportar y modificar datos con Dataflow

Muestra de código

Java

Si deseas obtener información sobre cómo instalar y usar la biblioteca cliente para Spanner, consulta Bibliotecas cliente de Spanner.

Ver en GitHubComentarios

albums
    // Spanner expects a Mutation object, so create it using the Album's data
    .apply("CreateAlbumMutation", ParDo.of(new DoFn<Album, Mutation>() {
      @ProcessElement
      public void processElement(ProcessContext c) {
        Album album = c.element();
        c.output(Mutation.newInsertOrUpdateBuilder("albums")
            .set("singerId").to(album.singerId)
            .set("albumId").to(album.albumId)
            .set("albumTitle").to(album.albumTitle)
            .build());
      }
    }))
    // Write mutations to Spanner
    .apply("WriteAlbums", SpannerIO.write()
        .withInstanceId(instanceId)
        .withDatabaseId(databaseId));

¿Qué sigue?

Para buscar y filtrar muestras de código de otros productos de Google Cloud, consulta el navegador de muestra de Google Cloud.