Você deve implantar uma atualização incompatível em um pipeline de streaming do Dataflow em execução usando uma assinatura do Pub/Sub, sem perder dados. O que você deve fazer?

A flag drain é a opção correta porque permite que o Dataflow conclua o processamento de todos os dados já em trânsito e no Pub/Sub antes de encerrar o pipeline antigo. Isso garante que nenhum dado seja perdido durante a transição para a nova versão do pipeline, que é incompatível. O novo pipeline pode então ser iniciado, lendo do mesmo ponto de onde o pipeline anterior parou, mantendo a continuidade do processamento. Atualizar o pipeline e fornecer um JSON de transform-mapping é usado para migrações de estado compatíveis, não para atualizações incompatíveis. Criar um novo pipeline que reutiliza a mesma assinatura do Pub/Sub e cancelar o pipeline antigo pode levar à perda de dados, pois o pipeline antigo seria interrompido abruptamente. Criar um novo pipeline com uma nova assinatura do Pub/Sub e cancelar o antigo também resultaria em perda de dados, pois o novo pipeline não processaria os dados pendentes da assinatura original.