Cibler le moteur de diffusion
Vous voilà de retour avec l'équipe des bibliothèques de Seattle. Leur historique de prêts augmente et les requêtes commencent à frôler les limites de mémoire. La solution la plus simple consiste à exécuter les requêtes paresseuses sur le moteur de diffusion (streaming) de Polars plutôt que le moteur en mémoire par défaut.
polars est importé sous pl. Le LazyFrame monthly_digital est préchargé et totalise les prêts numériques par mois.
Cette activité fait partie du cours
Mise à l'échelle et optimisation des pipelines de données avec Polars
Instructions de l’exercice
- Exécutez
monthly_digitalavec le moteur de diffusion.
Exercice interactif pratique
Essayez cet exercice en complétant ce code d’exemple.
# Run the query on the streaming engine
result = monthly_digital.collect(____="____")
print(result)