암호화폐 실시간 틱 데이터 수신 코딩 방법 . 파이썬

 

 

 

 

개요 

암호화폐 거래소 바이비트 API 통신 위한 공식 파이썬 패키지 pybit 이용하여 파이썬에서  실시간 틱 데이터 수신 위한 가장 쉬운 기본적인 형태에서 출발하여 점진적으로 더 유용한 형식으로 코드 발전시키는 과정  단계별로 모두 정리. 

 

본 글에서의 바이비트 API 버전 : 현재(2024. 08.21) 시점  최신 버전 API V5 . 

 

 

사전 필수 셋팅 

- 파이썬 개발환경 구축 되어있어야 함. 구축예 :  https://igotit.tistory.com/5761

- 파이썬에 pybit 설치되어있어야 함.  설치구문 :  pip install pybit 

 

 

 

사전 필수 개념 이해

 

- 본 글에서 pybit 이용하여 실시간 틱 데이터 수신하는 것은  bybit 거래소 API v5 의 웹소켓 Trade 를  pybit 으로 편리하게 접근하는 것. 

 

-  API v5 의 웹소켓 Trade  의 subscribe , response 이해하고 있어야 함. 

 

 

코드1. 

- 바이비트 리니어 BTCUSDT 1개 종목의 실시간 틱 수신하면서 출력하기.

 

 

 

 

코드1 실행결과

- 위 코드 실행하면 터미널창에 실시간으로 틱 데이터 표시된다. 

- 서버에서 송신한 message 를 그대로 출력한것. 

 

 

 

코드2.  코드1에서 필요한 키 "data" 추출 

코드1에서 수신한 데이터를 보면 우리가 필요한 것은 키 가  'data' 부분이며 리스트 형식이어서 1회 수신당 여러개의 틱 데이터가 있을 수 있다. 이 부분을 분리 추출하자. 

코드1에서 의 함수 def handle_message 내부만 수정하면된다. 

 

 

 

코드2 실행결과 

- 키 "data" 의 것을 누락없이 모두 확보하여 출력중. 

 

 

 

코드3. 키 "data" 내의 요소 개별적으로  접근하기 좋게하기 

 

앞의 코드 2에서는 우리가 활용할 데이터 요소 개별적으로는 접근하기 좋지 않은 형식이므로, 우리는 자료형 Dictionary 로 저장하여 이후 활용하기 편하게 한다. 

 

 

- 주의 :  코드3과 4의 의  tick_dict 의 키 volume_quote 는 오류임. price 로 해야함. 이후 코드 5에서 모두 수정함. 

 

 

수정된  def handle_message 

 

 

코드3. 실행결과 

- 이제   timestamp_ms, symbol 등으로 데이터 접근 가능하므로 편리해졌다. 

 

 

 

 

코드 4. 여러 종목 실시간 시세 받기 

 

- 코드 3까지는 단일 종목 요청한 예였는데 2개이상 동시에 요청하고 수신처리하는 코드예. 

 

ws.trade_stream 의 symbol 에 여러종목 요청가능하다. 

    # 다수의 거래 데이터 구독
    symbols = ["BTCUSDT", "ETHUSDT", "SOLUSDT", "SUIUSDT", "XRPUSDT"]
    ws.trade_stream(
        symbol=symbols,    # 구독할 심볼 설정
        callback=handle_message  # 데이터 수신 시 호출될 콜백 함수
    )

 

 

 전체코드. 

 

 

코드 4. 실행결과 

 

 

 

코드 5. 여러 종목 개별적으로 접근하기 위한 dictionary 변수 활용. 

 

symbol_tick_last 는 키는 symbol 명으로하고 최신 1개의 틱데이터를 저장하는 파이썬 딕셔너리 변수이다. 

 

오류 수정및 자료형 변경.

- 앞의 코드3, 4 에서 tick_info  에 잘못 기록한 volume_quote   대신  price 로 수정하였고,  side 를 정수로 , block_trade 는 bool 로 자료형 변경함. 

 

 

 

 

코드 5. 실행결과 

 

 

 

코드6. 큐 , 스레드 추가 

- websocket 내부적으로 기본적으로 큐버퍼가 구현되어있기에 필수는 아니지만 콜백함수인 handle_message 내에서 수신된 데이터를 que 버퍼에 기록하고 즉시 리턴하고 이후 처리는 que 읽고 처리하는 별도의 스레드에서 수행되게 하였다. 

 

 

 

 

 

 

 

 

 

이후 코딩 작업에서는 symbol_tick_last를 사용하면 각 심볼에 대한 최신 틱 데이터를 쉽게 저장하고 관리가능해졌다. 

 

- 최신 데이터 접근: symbol_tick_last를 통해 각 심볼의 최신 틱 데이터에 빠르게 접근할 수 있다. 

 

- 데이터 업데이트: 새로운 틱 데이터가 도착할 때마다 해당 심볼의 데이터만 갱신되므로, 메모리 사용과 데이터 관리가 효율적.

- 후속 처리: 이 구조를 사용하면 데이터베이스 저장, 수치 연산, 실시간 분석 등 이후 작업을 위해 데이터를 손쉽게 활용할 수 있다. 

- 확장성: 더 많은 심볼을 추가하거나 다른 데이터 처리 로직을 추가하는 것이 쉽다. 

 

symbol_tick_last를 기반으로 다음과 같은 작업을 수행할 수 있다. 

 

- DB 저장: 최신 틱 데이터를 데이터베이스에 저장할 때, symbol_tick_last에서 필요한 정보를 추출하여 저장할 수 있다.

 

- 수치 연산: 최신 틱 데이터를 이용해 수치 연산을 수행할 때, symbol_tick_last를 사용하여 각 심볼의 최신 데이터에 직접 접근할 수 있다. 

 

- 알림 및 트리거: 특정 조건이 충족되면 알림을 보내거나 특정 작업을 트리거하는 데 유용.

 

 

 

 

 

 

 

 

 

 

---

첫 등록 :  2024.09.07

최종 수정 : 

단축 주소 : https://igotit.tistory.com/5831

---