Musisz wdrożyć niekompatybilną aktualizację do uruchomionego potoku strumieniowego Dataflow korzystającego z subskrypcji Pub/Sub, bez utraty danych. Co należy zrobić?

Flaga drain pozwala na bezpieczne zatrzymanie lub aktualizację potoku Dataflow bez utraty danych. Potok przetwarza wszystkie dane, które już odebrał, w tym dane z Pub/Sub, a następnie kończy działanie. Po zakończeniu drenażu można wdrożyć zaktualizowaną wersję potoku, która przejmie przetwarzanie od miejsca, w którym poprzedni potok zakończył działanie. Opcja z transform-mapping jest używana do migracji stanu między różnymi wersjami potoków, ale nie jest głównym mechanizmem do bezpiecznej aktualizacji niezgodnych potoków bez utraty danych. Tworzenie nowego potoku z tą samą subskrypcją Pub/Sub i anulowanie starego może prowadzić do utraty danych lub ich duplikacji, ponieważ nowy potok może nie wiedzieć, gdzie stary pototok skończył przetwarzanie. Użycie nowej subskrypcji Pub/Sub spowodowałoby pominięcie wszystkich danych, które zostały wysłane do starej subskrypcji, co jest równoznaczne z utratą danych.