Вам необходимо развернуть несовместимое обновление для запущенного потокового конвейера Dataflow, использующего подписку Pub/Sub, без потери данных. Что вы должны сделать?

Флаг --drain позволяет остановить текущий конвейер Dataflow, дождавшись обработки всех данных, находящихся в пути, и затем запустить обновленную версию конвейера. Это гарантирует, что все данные из подписки Pub/Sub будут обработаны до переключения на новую версию, предотвращая потерю данных при несовместимом обновлении. Обновление с JSON transform-mapping используется для миграции состояния, а не для обработки данных в пути при остановке конвейера. Создание нового конвейера с той же подпиской Pub/Sub приведет к тому, что оба конвейера будут конкурировать за сообщения, что может вызвать дублирование или потерю данных. Создание нового конвейера с новой подпиской Pub/Sub приведет к потере данных, которые уже были отправлены в старую подписку.