Airbnb разработала платформу потоковой обработки данных под названием Платформа сигналов пользователей (USP), чтобы улучшить пользовательский опыт через персонализацию. Платформа использует данные об взаимодействии пользователей, чтобы обеспечить индивидуализированные взаимодействия во время процесса бронирования. Она состоит из слоя трубопровода данных и слоя онлайн-обслуживания, с использованием потоковой обработки Flink для gầnко-временной обработки и пакетной обработки для коррекции данных и заполнения пробелов. USP поддерживает различные типы обработки событий пользователей, включая сигналы пользователей, сегменты пользователей и сеансы взаимодействия. Она также использует метрики, такие как задержка события, задержка инжекции, задержка задания и задержка преобразования, чтобы измерять производительность заданий потоковой обработки. Платформа позволяет разработчикам определять преобразования и сегменты пользователей, не беспокоясь о компонентах потоковой обработки. Чтобы улучшить стабильность заданий Flink, Airbnb использует резервные менеджеры задач, чтобы обеспечить непрерывную обработку в случае сбоя менеджера задач.