DoorDash développe une nouvelle plate-forme de session utilisant Flink pour améliorer la rapidité de livraison des notifications

Chen Yang et Fan Zhang de l'équipe d'ingénierie de DoorDash ont récemment développé une plate-forme de session en mémoire utilisant Apache Flink qui identifie les activités et les sessions des utilisateurs en temps réel. Le nouveau système présenté dans le tableau ci-dessous a résolu l'un des nombreux défis auxquels DoorDash était auparavant confronté : déterminer quand un utilisateur a réellement abandonné son panier plutôt que de simplement rechercher plus d'articles ou différents marchands. Cette distinction était cruciale pour envoyer des notifications d'abandon de panier opportunes et pertinentes. Les méthodes traditionnelles, telles que le traitement par lots, étaient non seulement gourmandes en ressources, mais également rétrogrades, rendant la détection en temps réel presque impossible.

Flux de données de détection de session en temps réel, conçu par l'équipe d'ingénierie de DoorDash.

La nouvelle plate-forme de session est construite avec la fonctionnalité étendue et puissante de Flink pour surveiller les sessions des utilisateurs via des événements de clients mobiles et Web en mémoire. Cette approche leur a permis de traiter un flux d'événements d'activité des utilisateurs sans « avoir besoin de charger d'énormes quantités de données du stockage froid en mémoire avant le traitement », « évitant ainsi d'énormes coûts de calcul et de latence » ainsi que « de détecter les périodes d'inactivité en bref ». délais. » [in order to] Envoyez des notifications à des moments plus opportuns. » La nouvelle plate-forme n'est pas sans défis. Étant donné que Flink traite tous les événements en mémoire en temps réel, il doit conserver tous les événements de session utilisateur jusqu'à l'expiration de la session. Compte tenu de l'échelle actuelle de DoorDash, chaque session client est d'environ une heure, l'état du vol local peut atteindre des centaines de gigaoctets à tout moment.

L'adoption par DoorDash d'Apache Flink pour la détection de session et l'envoi de notifications en temps réel représente un progrès significatif dans l'amélioration de l'engagement des utilisateurs et des taux de conversion. La nouvelle conception a permis à DoorDash d'améliorer considérablement la rapidité et la précision de l'envoi des notifications, augmentant ainsi le taux d'envoi pour ouverture de 40 %. Ce succès a déjà conduit à une nouvelle série d'expérimentations avec la plateforme, notamment l'ajout de promotions aux notifications d'abandon de panier et le contrôle de la fréquence des notifications d'abandon de panier.