Lectura de Dataflow con transacción
Organiza tus páginas con colecciones
Guarda y categoriza el contenido según tus preferencias.
Usa el conector de Dataflow para leer datos de varias tablas en el mismo momento a fin de garantizar la coherencia de los datos. Para ello, realiza todas las lecturas en una sola transacción.
Explora más
Para obtener documentación en la que se incluye esta muestra de código, consulta lo siguiente:
Muestra de código
Salvo que se indique lo contrario, el contenido de esta página está sujeto a la licencia Atribución 4.0 de Creative Commons, y los ejemplos de código están sujetos a la licencia Apache 2.0. Para obtener más información, consulta las políticas del sitio de Google Developers. Java es una marca registrada de Oracle o sus afiliados.
[[["Fácil de comprender","easyToUnderstand","thumb-up"],["Resolvió mi problema","solvedMyProblem","thumb-up"],["Otro","otherUp","thumb-up"]],[["Difícil de entender","hardToUnderstand","thumb-down"],["Información o código de muestra incorrectos","incorrectInformationOrSampleCode","thumb-down"],["Faltan la información o los ejemplos que necesito","missingTheInformationSamplesINeed","thumb-down"],["Problema de traducción","translationIssue","thumb-down"],["Otro","otherDown","thumb-down"]],[],[],[],null,["# Dataflow read with transaction\n\nUse the Dataflow connector to read data from multiple tables at the same point in time to ensure data consistency by performing all of the reads in a single transaction.\n\nExplore further\n---------------\n\n\nFor detailed documentation that includes this code sample, see the following:\n\n- [Import, export, and modify data using Dataflow](/spanner/docs/dataflow-connector)\n\nCode sample\n-----------\n\n### Java\n\n\nTo learn how to install and use the client library for Spanner, see\n[Spanner client libraries](/spanner/docs/reference/libraries).\n\n\nTo authenticate to Spanner, set up Application Default Credentials.\nFor more information, see\n\n[Set up authentication for a local development environment](/docs/authentication/set-up-adc-local-dev-environment).\n\n SpannerConfig spannerConfig =\n SpannerConfig.create().withInstanceId(instanceId).withDatabaseId(databaseId);\n PCollectionView\u003cTransaction\u003e tx =\n pipeline.apply(\n SpannerIO.createTransaction()\n .withSpannerConfig(spannerConfig)\n .withTimestampBound(TimestampBound.strong()));\n PCollection\u003cStruct\u003e singers =\n pipeline.apply(\n SpannerIO.read()\n .withSpannerConfig(spannerConfig)\n .withQuery(\"SELECT SingerID, FirstName, LastName FROM Singers\")\n .withTransaction(tx));\n PCollection\u003cStruct\u003e albums =\n pipeline.apply(\n SpannerIO.read()\n .withSpannerConfig(spannerConfig)\n .withQuery(\"SELECT SingerId, AlbumId, AlbumTitle FROM Albums\")\n .withTransaction(tx));\n\nWhat's next\n-----------\n\n\nTo search and filter code samples for other Google Cloud products, see the\n[Google Cloud sample browser](/docs/samples?product=spanner)."]]