이 게시물에서는 두 가지 강력한 Python 라이브러리인 Beavers와 Perspective를 활용하여 실시간으로 데이터를 분석하고 대시보드에 표시하는 방법을 보여줍니다.

아키텍처 개요

Coinbase의 websocket API에 연결하여 암호화폐 시장 업데이트를 실시간으로 수신하겠습니다.

이 데이터를 다른 서비스와 공유하고 생산자와 소비자를 분리하기 위해 이 데이터를 Kafka를 통해 json으로 게시합니다.

그런 다음 Kafka에서 데이터를 읽고 강화한 후 Perspective 대시보드에 게시하는 Beaver를 작성합니다.

초기 설정

너는 필요할거야:

• 힘내
• 파이썬(3.10 이상)
• Kafka 클러스터를 실행하는 Docker
• Kafka CLI 도구

이 튜토리얼의 코드는 github에서 확인할 수 있습니다.

저장소 복제

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 도커 이미지를 사용하여 매우 간단한 kafka 클러스터를 실행합니다.