Gérez des flux de données temps réel

À vous de jouer !

Vous prenez très à cœur votre rôle d'expert·e de la logistique de vélos dans le monde. Et c'est normal ! Les cyclistes dépendent de vous pour trouver des vélos disponibles près de chez eux, et pour trouver des emplacements où déposer leurs vélos de location une fois qu'ils ont fini de les utiliser. Vous pilotez une équipe de déménageurs de vélos de l'extrême dont le rôle est de déplacer les vélos des stations pleines vers les stations vides. Pour cela, vous devez avant tout être alerté dès qu'une station est vide !

Dans cette activité, vous allez tout d'abord créer un topic empty-stations dans votre cluster Kafka. Puis, vous allez modifier le script get-stations.py (disponible dans le dépôt Github de ce cours) pour :

1. émettre un message dans le topic empty-stations dès qu'une station devient vide (alors qu'elle n'était pas vide auparavant).

2. émettre un message dans le topic empty-stations dès qu'une station n'est plus vide (alors qu'elle était vide auparavant).

Enfin, vous allez écrire un script monitor-empty-stations.py qui va afficher dans la console un message dès qu'une station devient vide (alors qu'elle n'était pas vide auparavant). Ce message devra contenir :

1. l'adresse de la station,

2. la ville de la station,

3. le nombre de stations vides dans la ville.

Vous veillerez à ce que le nombre de stations vides affiché par le script monitor-empty-stations.py soit correct même lorsque le topic empty-stations aura plusieurs partitions.