플러스프로젝트 배경
1) 예상 리스크 및 대응 계획 - 거래소마다 WebSocket 메시지 포맷이 달라 통일된 호가 스키마로 정규화하는 파서 레이어 설계가 필요합니다 - 5개 거래소 중 일부 연결 끊김 시 나머지 수집이 중단되지 않는 개별 재접속 로직을 구현할 계획입니다 - 코인별 네트워크(ETH/BSC/Polygon 등)가 거래소마다 상이하여 동일 코인 여부 판별을 위한 매핑 테이블 설계가 필요합니다 - 스프레드 계산
프로젝트 성과
5개 거래소 동시 WebSocket 수신
asyncio gather()로 5개 커넥션을 단일 이벤트 루프에서 관리하는 비동기 수집 파이프라인 구현
Redis Pub/Sub 실시간 데이터 전달
FastAPI → React 간 스프레드 변경분만 전송하는 Redis Pub/Sub 파이프라인 구성으로 전체 폴링 대비 네트워크 트래픽 최소화 구조 구현
입출금 상태 기반 자동 필터링
거래소 REST API 폴링으로 코인별 입출금 상태를 주기적으로 동기화하고 출금 불가 코인을 스프레드 계산에서 자동 제외하는 필터 로직 구현
Telegram 봇 알림 연동
사용자별 수익률 임계값 설정을 기반으로 조건 충족 즉시 Telegram 메시지를 발송하는 웹훅 방식 알림 서비스 구현
Gate.io 대출 가능 코인 조회
Gate.io Lending API 연동으로 모니터링 대상 코인의 대출 가능 여부를 Redis에 캐시하여 필터 패널에 실시간 반영하는 구조 구현
핵심 기능
실시간 스프레드 대시보드
5개 거래소에서 수집한 실시간 호가를 바탕으로 매수/매도 스프레드를 계산하여 갱신 주기 1초 이내의 라이브 테이블로 표시하는 메인 대시보드를 구현
진행 단계
WebSocket 파이프라인 설계
2026.03.
asyncio 기반 5개 거래소 WebSocket 동시 수신 구조 및 Redis 중간 버퍼 아키텍처 설계
프로젝트 상세
1) 포트폴리오 소개 빗썸·업비트·Gate·Binance·Bybit 5개 거래소의 WebSocket 실시간 호가 데이터를 수집하고 거래소 간 스프레드를 계산·필터링하는 아비트리지 모니터링 대시보드 맞춤 구현 데모입니다. Python asyncio 기반 비동기 데이터 파이프라인과 FastAPI 백엔드, React 실시간 UI를 설계 및 구현합니다. 본 프로젝트 착수 시 이 데모를 기반으로 빠르게 개발을 진행할
