[선물 WS] 호가창 일부분 실시간

import asyncio
import websockets
import json
import pprint

async def partial_book_depth():
    symbol = 'btcusdt'  # 이름
    levels = '@depth20'  # 불러올 주문 수. 5, 10, 20 단위
    US = '@100ms'  # 업데이트 속도. 미표기시 기본 250ms. 500ms, 100ms 변경 가능

    uri = f'wss://fstream.binance.com/ws/{symbol}{levels}{US}'
    async with websockets.connect(uri) as websocket:
        try:
            while True:
                data = json.loads(await websocket.recv())
                pprint.pprint(data)
        except asyncio.CancelledError:
            print("partial_book_depth 작업이 취소되었습니다.")
        except Exception as e:
            print(f"partial_book_depth 예외가 발생했습니다: {e}")
        finally:
            print("partial_book_depth 웹소켓 연결을 종료합니다.")
            await websocket.close()


async def main():
    tasks = [
        asyncio.create_task(partial_book_depth())
    ]
    try:
        await asyncio.gather(*tasks)
    except asyncio.CancelledError:
        print("메인 작업이 취소되었습니다.")
        for task in tasks:
            task.cancel()
        await asyncio.gather(*tasks, return_exceptions=True)
    except Exception as e:
        print(f"메인 함수에서 예외가 발생했습니다: {e}")
    finally:
        print("메인 함수의 작업이 종료되었습니다.")

if __name__ == '__main__':
    try:
        asyncio.run(main())
    except KeyboardInterrupt:
        print("프로그램을 종료합니다.")

 

주의할 점은 우선

업데이트 속도를 기본인 250ms로 설정할 경우

us = ''

이렇게 ''작은 따옴표 안에 아무것도 없게 표기합니다.

그 외엔 '@500ms', '@100ms' 으로 표기해주면 됩니다.

 

 

현물 버전에서 그냥 주소를 선물로 바꾸기만 합니다.

유의할 점은 선물과 현물의 표기 방법이 약간 다릅니다.

 

출력 결과

{'E': 1733008071573,
 'T': 1733008071571,
 'U': 5952178483917,
 'a': [['0.06690', '13899'],
       ['0.06691', '110998'],
       ['0.06692', '143337'],
       (중략...)
       ],
 'b': [['0.06689', '31296'],
       ['0.06688', '66205'],
       ['0.06687', '42370'],
       (중략...)
       ],
 'e': 'depthUpdate',
 'pu': 5952178479142,
 's': 'PEOPLEUSDT',
 'u': 5952178557448}

 

현물에선 매도 호가는 asks, 매수 호가는 bids,

선물에선 매도 호가는 a, 매수 호가는 b로 표기됩니다.