Streaming engine को टार्गेट करना
आप फिर से Seattle लाइब्रेरी टीम के साथ हैं. उनका checkout इतिहास लगातार बढ़ रहा है, और queries अब memory की सीमा को छूने लगी हैं. सबसे आसान उपाय है कि डिफॉल्ट in-memory engine की जगह Polars के streaming engine पर lazy queries चलाएँ.
polars pl के रूप में लोड है. LazyFrame monthly_digital पहले से लोड है और यह महीने के हिसाब से digital checkouts को समेटता है.
यह अभ्यास पाठ्यक्रम का हिस्सा है
Polars के साथ Data Pipelines का स्केलिंग और ऑप्टिमाइज़ेशन
अभ्यास निर्देश
- Streaming engine का उपयोग करके
monthly_digitalचलाएँ.
इंटरैक्टिव व्यावहारिक अभ्यास
इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।
# Run the query on the streaming engine
result = monthly_digital.collect(____="____")
print(result)