在當今的加密貨幣世界中，幣安（Binance）作為全球最大的加密貨幣交易所之一，提供了豐富的功能和服務。其中，WebSocket API是一個特別受到開發者和交易者喜愛的特性，它允許用戶實時接收市場數據，包括交易對的交易量、最新成交價格等資訊。本文將帶領讀者深入探索如何使用Python語言與幣安WebSocket進行連接，並實時獲取加密貨幣行情。
首先，要訪問幣安的WebSocket API，我們需要從幣安官網上找到WebSocket URL和簽名Key。在幣安客戶端，可以通過點擊「API」>「WebSocket API」來獲取這些信息。請記住，所有的API密鑰（包括WebSocket簽名密鑰）都必須經過Base64編碼後使用。
接下來，我們將使用Python內置的requests和base64庫來生成WebSocket連接所需的簽名Key。首先，獲取你的交易密鑰（API Key）、秘密密鑰（Secret Key）以及選擇你要查詢的數據類型。這裡以USDT交易對為例：
```python
import requests, base64
from binascii import unhexlify
api_key = 'your_api_key' # 你的API密鑰
secret_key = 'your_secret_key' # 你的秘密密鑰
timestamp = str(int(round(time.time() * 1000))) # 生成時間戳，格式為字符串，以便於後續的Base64編碼
message = api_key + secret_key + timestamp
signature = base64.b64encode(base64.standard_b64decode(unhexlify(secret_key) + unhexlify(message))) # 生成簽名Key
data = {
"apiKey": api_key,
"msgType": "0", # 查詢行情的類型，這裡是USDT交易對
"signature": signature.decode('utf-8')
}
```
有了簽名Key後，我們就可以連接到幣安WebSocket API進行實時行情獲取。以下是使用Python的requests庫實現這一點的代碼：
```python
import requests
from time import sleep
url = 'wss://stream.binance.com/stream?streams=btcusdt@trade' # 這裡選擇了btcusdt交易對，可以根據需要更改
headers = {'Connection': 'keep-alive'}
ws_connection = requests.Session()
response = ws_connection.get(url, headers=headers)
if response.status_code == 200:
print('Connected to Binance WebSocket API')
else:
print('Could not connect to Binance WebSocket API', response.status_code)
在這裡，我們可以開始獲取實時行情了
while True:
sleep(1) # 睡眠一秒以保持連接不崩潰
message = ws_connection.get(url)
print('Received message:', message.text)
```
上述代碼展示了如何建立一個WebSocket連接到幣安API，並持續獲取行情。每當有新的交易發生時（即"btcusdt@trade"），它都會在循環中打印出最新成交的訊息。讀者可以根據需要更改交易對或增加更多的處理逻辑。
需要注意的是，WebSocket連接是持久的，因此應該設置合理的退出機制以避免僵死進程影響系統性能。此外，為了保持WebSocket連接，可能需要定期發送ping消息。在實際應用中，可能會使用更為專業的WebSocket客戶端庫，如websockets，來實現這一功能，並且提供更好的使用者體驗和錯誤處理能力。
總結來說，幣安WebSocket API提供了一個豐富且實時的數據源，對於想要追蹤加密貨幣市場變化的用戶、開發者和交易者來說，這是一個非常有用的工具。通過本文展示的Python實現方式，讀者可以開始探索這個令人興奮的領域，並開展更多的互動和分析工作。