Hatalı giriş nedeniyle bir Dataflow DoFn'i başarısız oluyor ve hatalı kayıtları güvenilir bir şekilde yakalayıp yeniden işlemeniz gerekiyor. Doğru tasarım değişikliği nedir?

DoFn içindeki bir try...catch bloğu, hatalı girişleri yakalamak için standart bir yöntemdir. sideOutput kullanmak, hatalı kayıtları ana işlem hattından ayırarak ayrı bir PCollection'a yönlendirmenizi sağlar. Bu PCollection daha sonra Pub/Sub gibi bir mesaja kuyruğuna yazılabilir, bu da hatalı kayıtların güvenilir bir şekilde depolanmasını ve daha sonra yeniden işlenmesini veya incelenmesini mümkün kılar. Diğer seçenekler neden doğru değil: "Gelecekte bu tür hataları atlamak için bir filtreleme adımı ekleyin, hatalı satırları log'lardan çıkarın." seçeneği, hatalı verileri tamamen atlar ve yeniden işleme yeteneği sağlamaz. "Veriyi dönüştüren DoFn'inize bir try…catch bloğu ekleyin, hatalı satırları log'lardan çıkarın." seçeneği, hatalı kayıtları yalnızca log'lara yazarak güvenilir bir depolama veya yeniden işleme mekanizması sunmaz. Log'lar genellikle geçicidir ve yapılandırılmış yeniden işleme için uygun değildir. "Veriyi dönüştüren DoFn'inize bir try…catch bloğu ekleyin, hatalı satırları doğrudan DoFn'den Pub/Sub'a yazın." seçeneği, Dataflow'un paralel ve dağıtık yapısıyla uyumlu değildir. DoFn'ler doğrudan dış sistemlere yazmak yerine, verileri PCollection'lar aracılığıyla iletmelidir. sideOutput bu amaca hizmet eder.