Airbnb a développé une plateforme de traitement de flux appelée User Signals Platform (USP) pour améliorer l'expérience utilisateur grâce à la personnalisation. La plateforme utilise les données d'engagement des utilisateurs pour fournir des interactions personnalisées pendant le processus de réservation. Elle se compose d'une couche de pipeline de données et d'une couche de service en ligne, avec Flink pour le traitement en temps réel et le traitement par lots pour la correction et la réinitialisation des données. USP prend en charge divers traitements d'événements utilisateur, notamment les signaux utilisateur, les segments utilisateur et les engagements de session. Elle utilise également des métriques telles que la latence des événements, la latence d'ingestion, la latence des tâches et la latence de transformation pour mesurer les performances des tâches de streaming. La plateforme permet aux développeurs de définir des transformations et des segments utilisateur sans se soucier des composants de streaming. Pour améliorer la stabilité des tâches Flink, Airbnb utilise des gestionnaires de tâches de secours pour assurer un traitement continu en cas d'échec d'un gestionnaire de tâche.