Modelo de captura de dados alterados do MySQL para BigQuery usando o Debezium e o Pub/Sub (Stream)

Aviso: este modelo não funciona mais porque o Data Catalog foi descontinuado. Como alternativa, use o modelo Datastream para BigQuery ou crie um pipeline do Debezium para o BigQuery Dataflow diretamente com o Apache Beam.

O modelo da captura de dados alterados do MySQL para o BigQuery usando o Debezium e o Pub/Sub é um pipeline de streaming que lê mensagens Pub/Sub com dados de alteração de um banco de dados MySQL e grava os registros no BigQuery. Um conector do Debezium captura alterações no banco de dados MySQL e publica os dados alterados no Pub/Sub. O modelo lê as mensagens do Pub/Sub e as grava no BigQuery.

A seguir

• Saiba mais sobre os modelos do Dataflow.
• Confira a lista de modelos fornecidos pelo Google.