bybit. API. WebSocket 서버 3개 동시 접속 파이썬 코드.

 

개요 

- bybit 의 USD 종목용 websocket 서버 1개와 , USDT 종목용 websocket 서버 2개에 동시 접속 파이썬 코딩.  

 

작동방식.

1. 파이썬 코드 실행되면 파일 apikey_url_bybit.txt 를 읽어서 접속서버주소와 api key, secret 값들을 읽어들이고, 

2. 이후 asyncio 로 동시에 3개의 서버 접속 실행되게 한다.  

3. 각각의 서버 핸들링 하는 loop 함수 내에서 보안접속  

4. 종목들 각각의 체결정보 실시간 요청 송신하며, while 문내에서 실시간 수신 데이터 출력한다.

 

asyncio  로 동시 3개의 웹소켓 구동 핵심 코드. 

 

myy_loop.run_until_complete(asyncio.gather(*[my_loop_WebSocket_bybit(),my_loop_WebSocket_usdt_private_bybit(),my_loop_WebSocket_usdt_public_bybit()]));

 

 

	import asyncio
	import websockets
	import json
	import time
	import hmac
	def get_args_secret(_api_key, _api_secrete):
	expires = str(int(round(time.time())+5000))+"000"
	_val = 'GET/realtime' + expires
	signature = str(hmac.new(bytes(_api_secrete, "utf-8"), bytes(_val, "utf-8"), digestmod="sha256").hexdigest())
	auth = {}
	auth["op"] = "auth"
	auth["args"] = [_api_key, expires, signature]
	args_secret = json.dumps(auth)
	return args_secret
	####################### for bybit Inverse . BTCUSD, ETHUSD, EOSUSD, XRPUSD
	async def my_loop_WebSocket_bybit():
	async with websockets.connect(url_ws_inverse_bybit) as websocket:
	await websocket.send(get_args_secret(api_key, api_secret)); # secret
	print("Connected to bybit WebSocket with secret key");
	await websocket.send('{"op":"subscribe","args":["trade.BTCUSD"]}');
	await websocket.send('{"op":"subscribe","args":["trade.ETHUSD"]}');
	await websocket.send('{"op":"subscribe","args":["trade.EOSUSD"]}');
	await websocket.send('{"op":"subscribe","args":["trade.XRPUSD"]}');
	while True:
	data_rcv_strjson = await websocket.recv();
	print(data_rcv_strjson)
	######################## for bybit USDT : BTCUSDT, ETHUSDT, LTCUSDT, LINKUSDT, XTZUSDT
	async def my_loop_WebSocket_usdt_public_bybit():
	async with websockets.connect( url_ws_usdt_public_bybit ) as ws_usdt_public:
	print("Connected to bybit USDT WebSocket Public");
	await ws_usdt_public.send('{"op": "subscribe", "args": ["trade.BTCUSDT"]}');
	await ws_usdt_public.send('{"op": "subscribe", "args": ["trade.ETHUSDT"]}');
	await ws_usdt_public.send('{"op": "subscribe", "args": ["trade.LTCUSDT"]}');
	await ws_usdt_public.send('{"op": "subscribe", "args": ["trade.LINKUSDT"]}');
	await ws_usdt_public.send('{"op": "subscribe", "args": ["trade.XTZUSDT"]}');
	while True:
	data_rcv_strjson = await ws_usdt_public.recv();
	print('USDT from bybit public: ' + data_rcv_strjson)
	async def my_loop_WebSocket_usdt_private_bybit():
	async with websockets.connect(url_ws_usdt_private_bybit) as ws_usdt_private:
	await ws_usdt_private.send(get_args_secret(api_key, api_secret)); # secret
	print("Connected to bybit USDT WebSocket Private with secret key");
	while True:
	data_rcv_strjson = await ws_usdt_private.recv();
	print('USDT from bybit private: ' + data_rcv_strjson)
	##### main exec
	#### 파일 apikey_url.txt 읽어서 api key 와 url 정보 변수에 받아두기.
	with open('apikey_url_bybit.txt', encoding='utf8') as f:
	count_line=0
	for line in f:
	count_line+=1
	if count_line == 1: # bybit API key
	api_key = line.rstrip('\n')
	elif count_line == 2: # bybit secret key
	api_secret = line.rstrip('\n')
	elif count_line == 3: # bybit REST url for both Inverse Perpetual and USDT Perpetual,
	url_rest_bybit = line.rstrip('\n') # not used in this python code.
	elif count_line == 4: # bybit websocket url for Inverse Perpetual, BTCUSD , etc
	url_ws_inverse_bybit = line.rstrip('\n')
	elif count_line == 5: # bybit websocket public url for USDT Perpetual, BTCUSDT, etc
	url_ws_usdt_public_bybit = line.rstrip('\n')
	elif count_line == 6: # bybit websocket private url for USDT Perpetual, BTCUSDT, etc
	url_ws_usdt_private_bybit = line.rstrip('\n')
	break;
	print('OK : read file apikey_url_bybit.txt')
	my_loop = asyncio.get_event_loop();
	my_loop.run_until_complete(asyncio.gather(*[my_loop_WebSocket_bybit(),my_loop_WebSocket_usdt_private_bybit(),my_loop_WebSocket_usdt_public_bybit()]));
	my_loop.close();

view raw bybit_websocket_multi_connection_by_asyncio.py hosted with ❤ by GitHub

 

 

실행모습. 

 

 

 

 

 

 

연관 

- 아래 링크 1, 2, 3, 4 순서대로 읽어오면 본 글의 코드 쉽게 이해됨. 

 

1. 

암호화폐. API. bybit. 실시간 시세수신. WebSocket. Python

 

 

2. 

bybit. API. 보안접속 코드 . 파이썬

 

3. 

bybit. API. 서버 주소 정리. 파이썬에서 파일 읽기 처리.

 

4.

- asyncio 에서 2개 이상의 코루틴 실행.

Python. asyncio. 비동기 모듈.

 

---

첫 등록 : 2020.10.31

최종 수정 : 

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

 

---