يوضح هذا المنشور كيف يمكنك الاستفادة من مكتبتين قويتين في لغة بايثون، Beavers وPerspective، لتحليل البيانات في الوقت الفعلي وعرضها في لوحة المعلومات.

نظرة عامة على الهندسة المعمارية

سوف نتصل بواجهة برمجة تطبيقات websocket الخاصة بـ Coinbase لتلقي تحديثات سوق العملات المشفرة في الوقت الفعلي.

من أجل مشاركة هذه البيانات مع الخدمات الأخرى وفصل المنتجين عن المستهلك، سننشر هذه البيانات عبر كافكا، كـ json.

سنقوم بعد ذلك بكتابة Beavers التي ستقرأ البيانات من كافكا، وتثريها، وتنشرها في لوحة معلومات المنظور.

الإعداد الأولي

انك سوف تحتاج:

• شخص سخيف
• بايثون (3.10 على الأقل)
• Docker لتشغيل مجموعة كافكا
• أدوات كافكا CLI

رمز هذا البرنامج التعليمي متاح على جيثب

استنساخ الريبو

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

إعداد كافكا

نستخدم صورة عامل الإرساء kafka-kraft لتشغيل مجموعة كافكا فائقة البساطة.