Você precisa de um pipeline do Apache Beam que enriqueça mensagens do Cloud Pub/Sub com pequenos dados de referência estáticos do BigQuery (que cabem na memória do worker) e grave as linhas enriquecidas no BigQuery. Qual tipo de job e transformações você deve usar?
Escolha uma resposta
Toque em uma opção para verificar sua resposta.
Resposta correta: Streaming job, PubSubIO, BigQueryIO, side-inputs.
Por que esta é a resposta
A opção correta é "Streaming job, PubSubIO, BigQueryIO, side-inputs". Um pipeline de streaming é necessário porque as mensagens do Pub/Sub são um fluxo contínuo de dados. O PubSubIO é usado para ler do Cloud Pub/Sub, e o BigQueryIO para gravar no BigQuery. A chave aqui são os "side-inputs" (entradas laterais), que são a maneira idiomática do Apache Beam de enriquecer um fluxo principal com dados de referência estáticos e pequenos que cabem na memória do worker, como os dados do BigQuery mencionados. As outras opções estão incorretas porque: "Batch job" não é adequado para dados contínuos do Pub/Sub. "JdbcIO" não é a forma padrão de interagir com o BigQuery no Beam. "Side-outputs" são usados para dividir um PCollection em múltiplos PCollections com base em alguma lógica, não para enriquecer com dados de referência.
Passe no seu exame — sem a busca interminável por respostas
Obtenha todas as perguntas e explicações verificadas para este exame em um só lugar e economize horas de preparação. Mais de 1.000 certificações · Mais de 20 idiomas · Grátis para começar.
Passe no seu exame mais rápido → Não é necessário cartão