Bitfinex의 WebSocket API에 연결하는 방법은 무엇입니까?

Bitfinex의 WebSocket API는 실시간 데이터 스트리밍 및 거래를 가능하게합니다. API 키, WebSocket 클라이언트 및 JSON 지식을 사용하여 구독을 효과적으로 연결하고 관리하십시오.

2025/04/14 05:56

Bitfinex의 WebSocket API 이해

Bitfinex의 WebSocket API는 BitFinex Exchange에서 실시간 데이터 스트리밍 및 거래를위한 강력한 도구입니다. 이를 통해 개발자는 시장 데이터를 받고 주문을 받고 계정을 실시간으로 관리 할 수 ​​있습니다. 이 API를 효과적으로 사용하려면 구조와 기능을 이해하는 것이 필수적입니다.

WebSocket API는 영구적 인 전이중 통신 채널을 통해 작동하므로 연결이 설정되면 데이터를 전송하여 동시에 수신 할 수 있습니다. 이는 거래 봇 및 시장 분석 도구와 같은 저도 데이터 업데이트가 필요한 애플리케이션에 특히 유용합니다.

Bitfinex의 WebSocket API에 연결하기위한 전제 조건

Bitfinex의 WebSocket API에 연결하기 전에 몇 가지 전제 조건이 있습니다.

• API 키 및 비밀 : BitFinex 계정에서 API 키와 비밀을 생성해야합니다. 이는 인증 및 계정 데이터에 액세스하는 데 중요합니다.
• WebSocket 클라이언트 : 프로그래밍 언어와 호환되는 WebSocket 클라이언트 라이브러리가 필요합니다. 인기있는 선택에는 Node.js의 ws , Python 용 websocket-client 및 C ++의 WebSocket++ 포함됩니다.
• JSON에 대한 이해 : API는 JSON을 사용하여 의사 소통하므로 메시지를 구문 분석하고 구성하려면 JSON에 대한 기본적인 이해가 필요합니다.

Bitfinex의 WebSocket API에 대한 연결 설정

Bitfinex의 WebSocket API에 연결하려면 다음과 같은 단계를 따르십시오.

• WebSocket 라이브러리 선택 : 개발 환경에 맞는 WebSocket 라이브러리를 선택하십시오. 이 예에서는 Python의 websocket-client 라이브러리를 사용하겠습니다.

• 라이브러리 설치 : PIP를 사용하여 라이브러리를 설치하십시오.

   pip install websocket-client

• 라이브러리 가져 오기 : Python 스크립트에서 필요한 모듈을 가져옵니다.

   import websocket

• WebSocket URL 정의 : BitFinex의 WebSocket API URL은 wss://api-pub.bitfinex.com/ws/2 입니다. 이 URL을 사용하여 연결을 설정하십시오.

   ws = websocket.WebSocket()
   ws.connect('wss://api-pub.bitfinex.com/ws/2')

• 인증 요청 보내기 : 인증 된 액세스가 필요한 경우 인증 요청을 보내야합니다. API 키와 비밀을 사용하여 인증 메시지를 구성하십시오.

   import json
   import hmac
   import hashlib
   import time api_key = 'Your_api_key'
   api_secret = 'your_api_secret'
  
  
  nonce = str (int (time.time () * 1000))
   auth_payload = 'auth' + nonce
   signature = hmac.new (api_secret.encode (), auth_payload.encode (), hashlib.sha384) .HexDigest ()
  
  auth_msg = {
  
  'event': 'auth', 'apiKey': api_key, 'authSig': signature, 'authPayload': auth_payload, 'authNonce': nonce
   }
   
  ws.send (json.dumps (auth_msg))

• 채널 구독 : 일단 연결되면 다양한 채널을 구독하여 실시간 데이터를 수신 할 수 있습니다. 예를 들어, BTC/USD Ticker를 구독하려면 :

   subscribe_msg = { 'event': 'subscribe', 'channel': 'ticker', 'symbol': 'tBTCUSD'

  }

  ws.send (json.dumps (subscribe_msg))

• 수신 및 처리 데이터 : 루프를 사용하여 지속적으로 수신하고 처리하는 데이터 :

   while True: result = ws.recv() if result: print(json.loads(result))

WebSocket 이벤트 및 메시지를 처리합니다

Bitfinex의 WebSocket API에 연결되면 다양한 유형의 메시지가 수신됩니다. 이러한 메시지를 적절하게 처리하는 것이 중요합니다.

• 구독 확인 : 채널을 구독하면 확인 메시지가 표시됩니다. 이 메시지에는 값이 subscribed event 필드가 있습니다.

• 데이터 메시지 :이 메시지에는 가입 한 실제 데이터가 포함되어 있습니다. 예를 들어, Ticker 데이터에는 bid , ask , last_price 등과 같은 필드가 포함됩니다.

• 오류 메시지 : 인증 실패 또는 유효하지 않은 구독과 같은 오류가 있으면 오류 메시지가 표시됩니다. 이 메시지에는 값 error 있는 event 필드가 있습니다.

이러한 메시지를 처리하려면 조건부 명세서를 사용하여 들어오는 JSON을 구문 분석하고 그에 따라 행동 할 수 있습니다. 예를 들어:

 import json

def on_message (ws, message) :

 data = json.loads(message) if data.get('event') == 'subscribed': print(f'Subscribed to {data['channel']}') elif data.get('event') == 'error': print(f'Error: {data['msg']}') else: print(f'Received data: {data}')

ws = websocket.websocketapp ( 'wss : //api-pub.bitfinex.com/ws/2', on_message = on_message)
ws.run_forever ()

연결 및 오류 처리 관리

Bitfinex의 WebSocket API에 안정적인 연결을 유지하려면 강력한 오류 처리 및 재 연결 로직이 필요합니다. 연결을 효과적으로 관리하기위한 몇 가지 전략은 다음과 같습니다.

• 다시 연결 : 연결이 손실 된 경우 다시 연결하는 메커니즘을 구현하십시오. 정기적으로 다시 연결하려는 루프를 사용할 수 있습니다.

   while True: try: ws = websocket.WebSocket() ws.connect('wss://api-pub.bitfinex.com/ws/2') break except Exception as e: print(f'Connection failed. Retrying in 5 seconds: {e}') time.sleep(5)

• 하트 비트 : Bitfinex의 WebSocket API는 15 초마다 하트 비트 메시지를 보냅니다. 이를 사용하여 연결 건강을 모니터링 할 수 있습니다.

   def on_ping(ws, message): print('Received ping')

  ws = websocket.websocketapp ( 'wss : //api-pub.bitfinex.com/ws/2', on_ping = on_ping)
  ws.run_forever ()

• 오류 처리 : 네트워크 문제 또는 API 특정 오류와 같은 다양한 유형의 오류를 포착하고 응답하기위한 오류 처리를 구현합니다.

   def on_error(ws, error): print(f'Error occurred: {error}')

  ws = websocket.websocketapp ( 'wss : //api-pub.bitfinex.com/ws/2', on_error = on_error)
  ws.run_forever ()

여러 채널 구독 및 처리 데이터

Bitfinex의 WebSocket API를 최대한 활용하려면 여러 채널을 동시에 구독 할 수 있습니다. 이를 통해 티커, 거래 및 주문서와 같은 다양한 유형의 데이터를 실시간으로 수신 할 수 있습니다.

다음은 여러 채널을 구독하는 방법의 예입니다.

 import json ws = websocket.websocket ()
 ws.connect ( 'wss : //api-pub.bitfinex.com/ws/2')


채널 = [

{'channel': 'ticker', 'symbol': 'tBTCUSD'}, {'channel': 'trades', 'symbol': 'tBTCUSD'}, {'channel': 'book', 'symbol': 'tBTCUSD', 'prec': 'P0', 'freq': 'F0', 'len': '25'}
 ]]
 
채널의 채널 용 :
 
subscribe_msg = { 'event': 'subscribe', **channel } ws.send(json.dumps(subscribe_msg))
 사실이지만 :
 
result = ws.recv() if result: print(json.loads(result))
 각 채널은 특정 형식으로 데이터를 보내 므로이 메시지를 그에 따라 처리해야합니다. 예를 들어, 시세 데이터는 거래 데이터와 비교하여 다른 필드를 갖습니다.
 
자주 묻는 질문
 Q : 자동 거래에 Bitfinex의 WebSocket API를 사용할 수 있습니까?
 
A : 그렇습니다. Bitfinex의 WebSocket API는 자동 거래를 지원합니다. 이를 사용하여 주문을하고 계정을 관리하며 실시간 시장 데이터를받을 수 있으며, 이는 거래 봇을 구축하는 데 필수적입니다.
 
Q : 구독 할 수있는 채널 수에는 제한이 있습니까?
 
A : Bitfinex는 구독 할 수있는 채널 수에 대한 단단한 제한을 지정하지 않지만 데이터로 응용 프로그램을 압도하지 않도록 구독을 효율적으로 관리하는 것이 중요합니다.
 
Q : WebSocket API를 사용할 때 API 키와 비밀의 보안을 어떻게 보장 할 수 있습니까?
 
A : API 키와 비밀의 보안을 보장하려면 공개적으로 공유하지 말고 보안 네트워크에서만 사용하고 환경 변수 또는 보안 금고를 사용하여 응용 프로그램에 저장하십시오.
 
Q : 요율 제한 오류가 발생하면 어떻게해야합니까?
 
A : 요율 제한 오류가 발생하면 응용 프로그램에서 백 오프 전략을 구현해야합니다. 여기에는 요청 속도를 늦추고 특정 기간 후 Bitfinex의 요율 제한을 준수하기 위해 재 시도하는 것이 포함됩니다.