Küresel olarak dağıtılmış bir açık artırma uygulaması, farklı sunucular tarafından işlenen neredeyse eş zamanlı aynı teklifler alıyor. Her teklifte item, amount, user, timestamp bilgileri bulunuyor. Teklifleri gerçek zamanlı olarak birleştirmeniz ve hangi kullanıcının ilk teklifi verdiğini belirlemeniz gerekiyor. Ne yapmalısınız?

Bu senaryoda, gerçek zamanlı veri işleme ve olay sıralaması kritik öneme sahiptir. Cloud Pub/Sub, sunuculardan gelen teklif olaylarını güvenilir bir şekilde alıp dağıtabilen, düşük gecikmeli bir mesajlaşma hizmetidir. Dataflow ise, Pub/Sub'dan gelen verileri gerçek zamanlı olarak işleyebilen, ölçeklenebilir ve yönetilen bir hizmettir. Dataflow boru hattı içinde, aynı ürün için gelen teklifleri zaman damgasına veya işlenme sırasına göre sıralayarak ilk teklifi belirleyebilirsiniz. Bu yaklaşım, dağıtılmış sistemlerde olay sıralaması ve birleştirme için sağlam ve ölçeklenebilir bir çözümdür. Diğer seçenekler neden uygun değil: Paylaşılan bir dosyaya yazıp Hadoop çalıştırmak, gerçek zamanlı bir çözüm değildir ve yüksek gecikmeye neden olur. Cloud Pub/Sub'dan bir uç noktaya gönderip Cloud SQL'e yazmak, sıralama ve ilk teklifi belirleme mantığını doğrudan sağlamaz ve SQL veritabanının gerçek zamanlı yüksek hacimli yazma yükünü yönetmesi zor olabilir. Her sunucu için MySQL örneği çalıştırmak ve periyodik olarak birleştirmek, karmaşıklığı artırır, tutarlılık sorunlarına yol açabilir ve gerçek zamanlı değildir.