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

Осушение старого конвейера (draining) позволяет ему завершить обработку всех данных, находящихся в пути, прежде чем он будет остановлен. Это гарантирует отсутствие потери данных и сохраняет согласованность, так как все данные, которые были прочитаны из Pub/Sub, будут записаны в BigQuery. После этого можно безопасно запустить новый конвейер. Обновление старого конвейера (updating) может привести к потере данных или несогласованности, если новый код не полностью совместим со старым состоянием. Создание снимка и последующий запуск нового конвейера из него не является стандартным методом для обновления потоковых конвейеров и не гарантирует бесшовный переход без потери данных. Отмена (cancelling) конвейера немедленно останавливает его, что приводит к потере всех необработанных данных.