यह पोस्ट दिखाती है कि आप वास्तविक समय में डेटा का विश्लेषण करने और इसे डैशबोर्ड में प्रदर्शित करने के लिए दो शक्तिशाली पायथन लाइब्रेरी, बीवर और पर्सपेक्टिव का लाभ कैसे उठा सकते हैं।

वास्तुकला सिंहावलोकन

हम वास्तविक समय में क्रिप्टो बाजार अपडेट प्राप्त करने के लिए कॉइनबेस के वेबसॉकेट एपीआई से जुड़ेंगे।

इस डेटा को अन्य सेवाओं के साथ साझा करने और उत्पादकों को उपभोक्ता से अलग करने के लिए, हम इस डेटा को काफ्का पर json के रूप में प्रकाशित करेंगे।

फिर हम एक बीवर्स लिखेंगे जो काफ्का के डेटा को पढ़ेगा, इसे समृद्ध करेगा, और इसे एक परिप्रेक्ष्य डैशबोर्ड में प्रकाशित करेगा।

प्रारंभिक व्यवस्था

तुम्हें लगेगा:

• गिट
• पायथन (कम से कम 3.10)
• काफ्का क्लस्टर चलाने के लिए डॉकर
• काफ्का सीएलआई उपकरण

इस ट्यूटोरियल का कोड जीथब पर उपलब्ध है

रेपो को क्लोन करें

git clone https://github.com/0x26res/beavers-examples
cd beavers-example/coinbase_analytics/

आभासी वातावरण स्थापित करें

python3 -m venv --clear .venv
source ./.venv/bin/activate
pip install -r requirements.txt

काफ्का स्थापित करें

हम सुपर सरल काफ्का क्लस्टर चलाने के लिए काफ्का-क्राफ्ट डॉकर छवि का उपयोग करते हैं।