Una aplicación de subastas distribuida globalmente recibe pujas idénticas casi simultáneas procesadas por diferentes servidores. Cada puja tiene item, amount, user, timestamp. Debe cotejar las pujas en tiempo real y determinar qué usuario pujó primero. ¿Qué debe hacer?

La opción correcta utiliza Cloud Pub/Sub para la ingesta de eventos distribuidos y en tiempo real, y Dataflow para el procesamiento de streaming. Dataflow puede procesar los eventos de puja a medida que llegan, utilizando las marcas de tiempo (timestamps) para determinar cuál fue la primera puja, incluso si llegaron casi simultáneamente. Este enfoque es escalable y eficiente para un sistema de subastas global. Las otras opciones son menos adecuadas: Escribir en un archivo compartido y usar Hadoop introduce latencia significativa y no es en tiempo real. Usar Cloud SQL directamente desde un endpoint para cada puja puede generar cuellos de botella y no es ideal para el alto volumen de escrituras simultáneas. Una instancia de MySQL por servidor con consolidación periódica también introduce latencia y complejidad, y no garantiza la determinación en tiempo real de la primera puja.