Leitura do Dataflow com transação
Mantenha tudo organizado com as coleções
Salve e categorize o conteúdo com base nas suas preferências.
Use o conector do Dataflow para ler dados em várias tabelas ao mesmo tempo para garantir a consistência dos dados realizando todas as leituras em uma única transação.
Mais informações
Para ver a documentação detalhada que inclui este exemplo de código, consulte:
Exemplo de código
Exceto em caso de indicação contrária, o conteúdo desta página é licenciado de acordo com a Licença de atribuição 4.0 do Creative Commons, e as amostras de código são licenciadas de acordo com a Licença Apache 2.0. Para mais detalhes, consulte as políticas do site do Google Developers. Java é uma marca registrada da Oracle e/ou afiliadas.
[[["Fácil de entender","easyToUnderstand","thumb-up"],["Meu problema foi resolvido","solvedMyProblem","thumb-up"],["Outro","otherUp","thumb-up"]],[["Difícil de entender","hardToUnderstand","thumb-down"],["Informações incorretas ou exemplo de código","incorrectInformationOrSampleCode","thumb-down"],["Não contém as informações/amostras de que eu preciso","missingTheInformationSamplesINeed","thumb-down"],["Problema na tradução","translationIssue","thumb-down"],["Outro","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)."]]