新融汇

探索区块链生态系统的多样性，包括分布式应用、智能合约、去中心化金融（DeFi）和数字资产管理，深入了解这些技术如何重塑传统行业，推动创新与可持续发展。

文章数

9744
阅读量

507889

突发！BitMEX行情数据抓取实战：Python API攻略，掘金机会？

阅读：59 时间：2025-03-06 09:14:46 分类：焦点

BitMEX API接口获取市场数据教程

简介

BitMEX 作为一家领先的加密货币衍生品交易所，在业内享有盛誉，它为经验丰富的交易者和机构提供了广泛的交易工具和深度市场数据。为了满足不同用户的需求，BitMEX 提供了一套全面的应用程序编程接口（API），允许开发者和交易者以编程方式访问交易所的各种数据源。通过 BitMEX API，用户可以实时获取关键市场数据，包括但不限于：

交易对行情数据： 实时了解不同交易对（例如 BTC/USD、ETH/USD）的价格、最高价、最低价、成交量等关键指标。
深度数据： 深入分析订单簿，获取买单和卖单的分布情况，从而评估市场流动性和潜在的价格波动。
历史交易记录： 回溯历史交易数据，分析市场趋势，进行量化分析和算法交易策略的开发。
指数数据： 获取 BitMEX 交易所计算的各种指数，这些指数可以用于跟踪特定加密货币或资产组合的表现。
结算信息： 及时获取结算相关的数据，包括结算价格、资金费率等，以便更好地管理头寸和风险。

本文旨在提供一份详尽的指南，详细介绍如何使用 BitMEX API 获取市场数据。我们将涵盖 API 的基本概念、身份验证、数据请求以及常见问题解答，帮助您快速上手并充分利用 BitMEX API 的强大功能。

准备工作

在使用BitMEX API之前，需要进行一系列的准备工作，确保可以顺利地进行数据获取和交易操作。

BitMEX账户： 你需要在BitMEX交易所注册并创建一个账户。注册流程包括提供有效的电子邮件地址、设置安全密码，并完成必要的身份验证步骤（KYC）。虽然访问BitMEX的公开市场数据通常不需要API密钥，但如果你希望执行交易、查看账户余额、获取历史订单信息或使用其他需要身份验证的功能，则必须生成并配置API密钥。API密钥包含一个密钥（API Key ID）和一个密钥（API Secret），请务必妥善保管API Secret，避免泄露。
编程环境： 你需要选择一种合适的编程语言和对应的集成开发环境(IDE)。常见的选择包括Python、JavaScript、Go和Java等。Python因其简洁易懂的语法和丰富的库支持，特别适合用于快速开发原型和数据分析应用。请根据你的编程经验和项目需求选择合适的编程环境。常用的Python IDE包括PyCharm、VS Code和Jupyter Notebook。
安装必要的库： 根据你选择的编程语言，安装用于发送HTTP请求和处理JSON数据的库。这些库可以简化与BitMEX API的交互过程。例如，对于Python， requests 库用于发送HTTP请求，库用于处理JSON格式的数据。使用pip包管理器可以方便地安装这些库。
在命令行终端中执行以下命令安装 requests 库：
```
pip install requests
```

API概览

BitMEX提供REST API和WebSocket API两种方式来获取市场数据，满足不同应用场景的需求。开发者可以根据自身对数据时效性以及数据量级的要求，选择合适的API类型。

REST API: REST API允许你通过发送HTTP请求来获取数据。它适用于获取静态数据或定期更新的数据，例如历史交易记录、账户信息或特定交易对的最新行情快照。REST API基于请求-响应模型，客户端发送请求，服务器返回响应。为了优化性能，可以考虑缓存不频繁变动的数据，减少对API的调用次数。同时，需要关注BitMEX的API速率限制，合理设计请求频率，避免触发限流机制。
WebSocket API: WebSocket API提供了一个实时的、双向的通信通道。适用于需要实时更新的数据，例如实时交易数据、深度数据以及订单簿变化。WebSocket协议建立的是持久连接，服务器可以主动推送数据到客户端，无需客户端轮询。这种方式能够显著降低延迟，提高数据获取效率，适合高频交易和实时监控等应用场景。使用WebSocket API需要维护连接状态，并处理断线重连等异常情况。

本文主要介绍使用REST API获取市场数据，涵盖了常用的API接口、请求参数和响应格式。WebSocket API会在后续章节简要提及，并提供相应的代码示例和最佳实践。

REST API

基本信息

BitMEX REST API 的基础 URL (Base URL) 是： https://www.bitmex.com/api/v1 。这是访问所有 BitMEX 交易平台功能的主要入口点。

所有 API 请求都必须通过 HTTPS 协议发送到此 URL。使用 HTTPS 可确保数据在客户端（你的应用程序）和 BitMEX 服务器之间传输时的安全性与完整性，防止中间人攻击和数据泄露。任何通过 HTTP 发送的请求都将被拒绝，因此务必使用 HTTPS。

除了基础 URL，还需要注意，BitMEX 提供了测试网络 (Testnet) 环境，用于开发者测试其 API 集成。 Testnet 的基础 URL 是 https://testnet.bitmex.com/api/v1 。在将应用程序部署到生产环境之前，强烈建议在 Testnet 上进行全面的测试。

请注意，BitMEX API 的速率限制非常重要。过度请求可能导致 IP 地址被暂时或永久阻止。详细的速率限制信息可在 BitMEX 官方 API 文档中找到。为了优化 API 调用的效率，开发者应尽量采用批量请求和缓存策略，以减少不必要的 API 调用。

所有API请求都需要提供有效的 API 密钥和密钥。API密钥和密钥用于验证您的身份并授权您访问BitMEX API。您可以在BitMEX网站上生成API密钥和密钥。

常用端点 (Endpoints)

以下是一些常用的BitMEX REST API端点，用于获取实时和历史市场数据，为交易策略提供支持：

/api/v1/instrument: 获取所有或特定交易对的合约信息，包括合约乘数、结算货币、保证金要求、手续费率以及其他关键合约参数。这对于了解不同合约的交易细则至关重要。可以通过指定`symbol`参数来筛选特定交易对的信息，例如`XBTUSD`。
/api/v1/orderBook/L2: 获取指定交易对的第二层深度数据（order book），L2级别提供了更详细的订单簿信息，包括每个价格级别的订单量。该端点对于高频交易和算法交易者至关重要，可以根据订单簿的深度判断市场流动性和潜在的价格波动。可以通过`symbol`参数指定交易对，例如`ETHUSD`，并通过`depth`参数调整返回的订单簿深度。
/api/v1/trade: 获取最近的交易记录，包括成交价格、成交数量、交易方向（买/卖）和成交时间。通过分析历史交易数据，可以识别市场趋势、支撑位和阻力位。可以通过`symbol`参数指定交易对，并通过`count`参数限制返回的交易记录数量。可以使用`startTime`和`endTime`参数筛选特定时间段内的交易记录。
/api/v1/quote: 获取最近的报价数据，包括买入价和卖出价，以及相关的时间戳。这对于监控市场价格变动和计算价差非常有用。可以通过`symbol`参数指定交易对，例如`XRPUSD`。
/api/v1/funding: 获取资金费率数据，资金费率是永续合约的重要组成部分，用于平衡永续合约价格与标的指数价格之间的差异。该端点提供历史资金费率数据，可以帮助交易者评估交易成本和预测未来的资金费率趋势。可以通过`symbol`参数指定交易对，并通过`count`参数限制返回的资金费率记录数量。

使用Python获取加密货币数据示例

以下是一个使用Python编程语言和 requests 库获取BitMEX交易所实时市场数据的示例。BitMEX是一家知名的加密货币衍生品交易所，提供包括比特币（BTC）在内的多种加密货币的永续合约和期货合约交易。

requests 库是一个常用的Python库，用于发送HTTP请求。我们可以使用它来向BitMEX的API端点发送请求，获取市场数据，例如最新成交价、深度数据、交易历史等。

你需要安装 requests 库。可以使用pip进行安装：

pip install requests

安装完成后，就可以在Python脚本中使用它了。

以下是示例代码：

import requests
import 

# BitMEX API endpoint for recent trades
url = "https://www.bitmex.com/api/v1/trade?symbol=XBTUSD&count=10"  # 获取XBTUSD交易对最近10笔交易

try:
    # Send the request
    response = requests.get(url)

    # Check if the request was successful (status code 200)
    response.raise_for_status()  # Raises HTTPError for bad responses (4XX or 5XX)

    # Parse the JSON response
    trades = response.()

    # Print the trades
    print(.dumps(trades, indent=4)) # 使用.dumps格式化输出，增加可读性

except requests.exceptions.RequestException as e:
    print(f"An error occurred: {e}")
except .JSONDecodeError as e:
    print(f"Error decoding JSON: {e}")

代码解释：

import requests : 导入 requests 库。
url : 定义BitMEX API的URL。这里我们请求XBTUSD（比特币/美元）交易对的最近10笔交易记录。你可以根据需要更改 symbol 参数以获取其他交易对的数据。
requests.get(url) : 发送GET请求到指定的URL。
response.raise_for_status() : 检查响应状态码。如果状态码不是200（OK），则会引发一个HTTPError异常。这有助于我们检测请求是否成功。
response.() : 将响应内容解析为JSON格式。
.dumps(trades, indent=4) : 使用 .dumps 函数将JSON数据格式化为易于阅读的字符串， indent=4 参数表示使用4个空格进行缩进。
try...except : 使用try-except块来捕获可能发生的异常，例如网络连接错误（ requests.exceptions.RequestException ）或JSON解码错误（ .JSONDecodeError ）。

这段代码演示了如何从BitMEX API获取数据，并处理可能出现的错误。你可以根据自己的需求修改代码，例如获取不同交易对的数据，或者对获取到的数据进行进一步处理。

请注意，BitMEX API可能会有速率限制，所以在实际使用中需要注意控制请求频率，避免被封禁。

还可以使用其他Python库来处理加密货币数据，例如pandas用于数据分析，matplotlib用于数据可视化。这些库可以帮助你更方便地分析和可视化加密货币市场数据。

BitMEX API 基础 URL

BitMEX API 的基础 URL 是访问和使用其功能的入口点。所有 API 请求都将以这个 URL 为前缀。

基础 URL 定义： base_url = "https://www.bitmex.com/api/v1"

重要提示： 请注意，BitMEX 可能会不时更新其 API。始终查阅 BitMEX 官方文档以获取最新的基础 URL 和 API 规范，确保你的应用程序与最新的 API 版本兼容。

所有发送到 BitMEX API 的请求，都必须以 https://www.bitmex.com/api/v1 作为前缀。例如，要获取所有活跃合约的信息，你需要向 https://www.bitmex.com/api/v1/instrument/active 发送 GET 请求。

使用示例（Python）：


import requests

base_url = "https://www.bitmex.com/api/v1"
endpoint = "/instrument/active"
url = base_url + endpoint

response = requests.get(url)

if response.status_code == 200:
    data = response.()
    print(data)
else:
    print(f"请求失败，状态码: {response.status_code}")

在开发过程中，请务必处理可能的错误和异常，并实施适当的重试机制，以确保应用程序的稳定性和可靠性。

需要注意的是，BitMEX API 具有速率限制。请仔细阅读 API 文档以了解具体的限制，并在你的应用程序中实施适当的速率限制策略，以避免被 API 阻止。

获取交易对信息

get_instruments(symbol=None) 函数旨在从交易所API获取交易对的详细信息。此函数允许用户选择性地指定交易对的符号(symbol)，以便仅检索特定交易对的数据。若未提供符号，则函数将返回所有可用交易对的信息。

函数实现细节：

定义端点(Endpoint)： endpoint = "/instrument" 定义了API请求的具体路径，指向交易所API中获取交易对信息的端点。
构建URL： url = base_url + endpoint 将基础URL ( base_url ，假定已预先定义) 与端点组合，形成完整的API请求URL。
设置请求参数： params = {} 初始化一个空字典，用于存储API请求的查询参数。
条件性添加符号参数： if symbol: params['symbol'] = symbol 如果用户提供了交易对的符号 ( symbol )，则将其添加到 params 字典中，以便API仅返回该交易对的信息。
发送GET请求： response = requests.get(url, params=params) 使用 requests 库发送一个HTTP GET请求到构建的URL，并将查询参数传递给API。
错误处理： response.raise_for_status() 检查HTTP响应状态码。如果状态码指示错误（例如，404 Not Found，500 Internal Server Error），则会引发一个HTTPError异常，从而允许程序捕获并处理错误。
解析JSON响应： return response.() 如果请求成功，函数将解析API返回的JSON格式的响应数据，并将其作为Python字典或列表返回。这使得用户可以方便地访问和使用交易对的信息。
异常处理： except requests.exceptions.RequestException as e: print(f"请求错误: {e}") return None 使用 try...except 块来捕获可能发生的 requests.exceptions.RequestException 异常，例如网络连接错误、超时等。如果发生异常，函数将打印错误信息并返回 None 。

此函数依赖于 requests 库来发送HTTP请求，并且需要一个预定义的 base_url 变量，该变量应包含交易所API的基础URL。函数的返回值为JSON格式的交易对信息或 None (如果发生错误)。

获取深度数据

在加密货币交易中，订单簿深度数据对于理解市场微观结构和进行有效的交易决策至关重要。以下代码展示了如何通过API获取指定交易对的订单簿深度信息。

def get_order_book(symbol, depth=25):

此函数旨在从交易所API获取特定交易对的订单簿数据。 symbol 参数指定要查询的交易对，例如 "BTCUSDT"。 depth 参数决定返回的订单簿深度，即买单和卖单列表中显示的订单数量。默认值为25，表示返回最佳的25个买单和25个卖单。

endpoint = "/orderBook/L2"

endpoint 变量定义了API的端点，用于获取订单簿L2级别数据。L2订单簿通常包含比L1更详细的信息，包括每个价格级别的多个订单。

url = base_url + endpoint

这行代码将基础URL ( base_url ，假设已预先定义)与API端点连接起来，构建完整的API请求URL。 base_url 通常包含交易所的域名和API版本信息。

params = {'symbol': symbol, 'depth': depth}

params 字典用于存储API请求的查询参数。在这里，它包含了交易对( symbol )和订单簿深度( depth )。这些参数将附加到URL，以便服务器知道要返回哪些数据。

try:
response = requests.get(url, params=params)
response.raise_for_status()
return response.()
except requests.exceptions.RequestException as e:
print(f"请求错误: {e}")
return None

这段代码使用 try-except 块来处理潜在的请求错误。 requests.get(url, params=params) 发送一个HTTP GET请求到指定的URL，并传递查询参数。 response.raise_for_status() 检查响应状态码，如果状态码表示错误(例如404或500)，则抛出一个HTTPError异常。如果请求成功， response.() 将响应内容解析为JSON格式，并将其作为Python字典返回。如果发生任何请求错误，则会捕获异常，打印错误信息，并返回 None 。

示例代码：

import requests

base_url = "https://api.example.com" # 替换为实际的交易所API基础URL

def get_order_book(symbol, depth=25):
    endpoint = "/orderBook/L2"
    url = base_url + endpoint
    params = {'symbol': symbol, 'depth': depth}
    try:
        response = requests.get(url, params=params)
        response.raise_for_status()
        return response.()
    except requests.exceptions.RequestException as e:
        print(f"请求错误: {e}")
        return None

# 示例用法：
symbol = "BTCUSDT"
order_book = get_order_book(symbol)

if order_book:
    print(f"交易对 {symbol} 的订单簿数据:")
    print(order_book)
else:
    print("未能获取订单簿数据。")

注意: 上述代码中的 base_url 需要替换为实际交易所的API基础URL。API的端点和参数可能因交易所而异，请务必查阅交易所的API文档。

获取最近的交易记录

获取指定加密货币交易对最近的交易记录，可以通过以下Python代码实现。该函数连接到交易所的API，并检索特定数量的交易数据。

def get_trades(symbol, count=10):

此函数接受两个参数：

symbol ：代表交易对的字符串，例如 "BTCUSDT"。
count ：指定要检索的交易记录数量，默认为10。

endpoint = "/trade"

定义API的端点，通常为"/trade"，用于获取交易数据。

url = base_url + endpoint

构建完整的API URL，通过将基础URL（ base_url ，预先定义好的交易所API根地址）与端点连接起来。

params = {'symbol': symbol, 'count': count}

准备请求参数。创建一个字典，包含交易对 symbol 和交易记录数量 count ，这些参数将附加到API请求中。

try:

使用 try-except 块处理可能发生的请求错误。

response = requests.get(url, params=params)

使用 requests 库发送GET请求到API。 params 参数将查询字符串附加到URL。

response.raise_for_status()

检查响应状态码。如果状态码表示错误（例如 404 或 500），则会引发HTTPError异常。

return response.()

如果请求成功，则将响应内容解析为JSON格式并返回。返回的数据通常是一个包含交易信息的列表。

except requests.exceptions.RequestException as e:

捕获由于网络问题、连接超时或其他原因导致的任何 requests 异常。

print(f"请求错误: {e}")

如果发生错误，则打印错误消息，其中包含错误的详细信息。

return None

在发生错误时，函数返回 None ，表示获取交易记录失败。

示例用法

if name == " main ":

# 获取XBTUSD合约信息。通过调用 get_instruments() 函数，指定 symbol 参数为 "XBTUSD"，即可从BitMEX API获取该合约的详细信息，例如保证金要求、合约乘数、结算货币等。

xbtusd_instrument = get_instruments(symbol="XBTUSD")

if xbtusd_instrument:

print("XBTUSD 合约信息:")

print(.dumps(xbtusd_instrument[0], indent=4)) # 打印第一个元素。使用 .dumps() 方法将JSON格式的合约信息格式化输出， indent=4 参数指定了缩进量为4个空格，使输出更易读。这里只打印了返回结果的第一个元素，因为 get_instruments() 函数返回的是一个列表。

# 获取XBTUSD深度数据
xbtusd_order_book = get_order_book(symbol="XBTUSD")
if xbtusd_order_book:
    print("\nXBTUSD 深度数据:")
    print(.dumps(xbtusd_order_book, indent=4))

# 获取XBTUSD最近的10条交易记录
xbtusd_trades = get_trades(symbol="XBTUSD")
if xbtusd_trades:
    print("\nXBTUSD 最近的10条交易记录:")
    print(.dumps(xbtusd_trades, indent=4))

上述代码展示了如何利用API函数获取BitMEX交易平台的关键数据。 get_instruments() 函数用于检索特定交易对（如XBTUSD）的合约规格，包括合约类型、标的资产、最小价格变动单位等重要参数。 get_order_book() 函数用于获取指定交易对的订单簿信息，它提供当前市场上买单和卖单的分布情况，是进行市场深度分析的关键数据来源。而 get_trades() 函数则返回指定交易对最近的交易历史记录，包括成交价格、成交数量以及成交时间等信息，这些数据对于追踪市场趋势和进行技术分析至关重要。这些函数都接受交易对代码（ symbol ）作为必要参数。 get_trades() 还可以接受 count 参数，用于控制返回的交易记录数量。这些函数通过 requests.get() 向BitMEX API发送HTTP GET请求，并将API返回的JSON数据解析为Python对象。为了使JSON数据更易于阅读和理解，使用了 .dumps() 函数进行格式化输出，并通过 indent=4 参数设置了缩进量。为了保证程序的健壮性，使用了 try...except 块来捕获在API请求过程中可能出现的异常，例如网络连接错误或API返回错误码。这种错误处理机制能够防止程序因API问题而崩溃，并提供相应的错误提示信息。

错误处理

在与BitMEX API交互时，周全的错误处理至关重要。API通过返回标准的HTTP状态码来明确指示请求的状态，这使得开发者能够迅速诊断和处理各种问题。

200 OK: 明确表示请求已成功执行，服务器已成功处理并返回了期望的结果。
400 Bad Request: 指示客户端发出的请求存在错误，例如缺少必需的参数、参数格式不正确或参数值无效。开发者应仔细检查请求体，确保所有参数均符合API文档的要求。
401 Unauthorized: 表明请求未通过身份验证。这通常意味着API密钥缺失、无效或者与请求的权限不匹配。开发者需要验证API密钥是否正确配置，并拥有执行特定操作的权限。
404 Not Found: 意味着请求的资源在服务器上不存在。这可能是由于URL路径错误、资源已被删除或从未存在。开发者应检查URL是否拼写正确，并确认资源在BitMEX服务器上可用。
429 Too Many Requests: 这是一个速率限制错误，表明客户端在给定的时间内发送了过多的请求。BitMEX实施速率限制以保护其系统免受滥用。开发者应实施重试机制，例如指数退避算法，以优雅地处理此错误，避免在短时间内再次达到速率限制。同时，应合理设计请求频率，避免不必要的请求。

在代码实现中，利用 response.raise_for_status() 方法能有效检测HTTP请求是否成功。此方法会在响应状态码指示错误（例如4xx或5xx）时抛出一个HTTPError异常，从而允许开发者集中处理错误情况，增强代码的健壮性和可维护性。可以捕获 requests.exceptions.RequestException 异常来处理更广泛的网络相关问题，例如连接错误或超时。

API 请求频率限制

BitMEX API 为了保障平台的稳定性和公平性，对请求频率实施了严格的限制机制。当您的应用程序或交易策略发送请求的频率超过了预设的阈值，API 将会返回一个 HTTP 状态码为 429 的错误，表示“请求过多”。为了避免触发此错误，您需要仔细地管理您的请求频率，确保其在允许的范围之内。

具体的请求频率限制细节，例如每个端点允许的请求次数、时间窗口以及其他相关规则，都可以在 BitMEX 官方 API 文档中找到。建议您在开发和部署任何基于 BitMEX API 的应用程序之前，务必查阅最新的 API 文档，了解并遵守这些限制。

除了 API 文档，您还可以通过 API 响应头中的 X-RateLimit-Limit , X-RateLimit-Remaining , 和 X-RateLimit-Reset 等字段来动态地监控您的请求频率使用情况。 X-RateLimit-Limit 表示在当前时间窗口内的请求总数限制， X-RateLimit-Remaining 表示剩余的可用请求次数， X-RateLimit-Reset 表示下一个时间窗口重置的时间戳。利用这些信息，您可以构建更加智能的请求调度机制，避免超过频率限制，并优化您的应用程序的性能。

如果您的应用场景确实需要更高的请求频率，可以考虑联系 BitMEX 官方，申请提高您的 API 请求频率限制。通常，这需要您提供充分的理由，并证明您有能力安全地使用更高的请求频率，而不会对平台造成任何负面影响。

WebSocket API (深入解析)

WebSocket API 为 Web 应用程序提供了一个持久化的双向通信管道，彻底改变了传统 HTTP 的请求-响应模式。它摆脱了轮询和长轮询等低效方法，实现了客户端和服务器之间的实时数据交换，极大地提升了用户体验。

其核心优势在于建立连接后，服务器可以主动向客户端推送数据，而无需客户端发起请求。这种特性非常适合对实时性要求极高的应用场景，例如：

实时交易平台： 金融市场的价格波动、订单执行状态等信息可以即时推送给用户，确保用户掌握最新的市场动态。
在线游戏： 玩家之间的互动、游戏状态的更新可以实时同步，打造流畅的游戏体验。
即时通讯应用： 消息的发送和接收可以立即完成，保证通讯的实时性。
协同编辑工具： 多用户可以同时编辑同一份文档，修改内容实时同步，提升协作效率。
物联网 (IoT) 应用： 传感器数据可以实时上传至服务器，服务器也可以实时控制设备，实现智能化的管理和控制。

WebSocket 协议基于 TCP 协议，提供了可靠的数据传输保障。同时，它通过握手协议建立连接，并在连接建立后保持长连接状态，避免了频繁的连接建立和断开，降低了服务器的资源消耗。WebSocket 支持二进制数据的传输，可以高效地传输图像、音频、视频等复杂数据类型。为了增强安全性，WebSocket 还可以通过 WSS (WebSocket Secure) 协议进行加密传输，防止数据被窃取或篡改。在开发过程中，开发者可以使用各种编程语言提供的 WebSocket 库，简化开发流程，例如 JavaScript 的 WebSocket API，以及 Python 的 `websockets` 库等。

连接到WebSocket

要连接到BitMEX WebSocket API，你需要建立一个持久的WebSocket连接。WebSocket协议允许客户端和服务器之间进行全双工通信，这对于实时数据流至关重要，例如加密货币交易平台的实时行情和交易数据。

为了实现WebSocket连接，可以使用多种编程语言和库。这里以Python为例，使用流行的 websocket-client 库来连接到BitMEX的实时数据流。确保已安装该库： pip install websocket-client 。接下来，导入必要的模块：

import websocket
import threading

定义处理接收到的消息的回调函数。当从BitMEX服务器接收到数据时， on_message 函数会被调用。该函数接收两个参数：WebSocket实例 ws 和接收到的消息 message 。通常，你需要解析JSON格式的消息并根据数据执行相应的操作。例如，将数据存储到数据库，更新UI，或触发交易信号。

def on_message(ws, message):
    print(message)
    # 在这里处理接收到的消息，例如解析JSON并更新数据

定义错误处理函数。如果在WebSocket连接过程中发生错误，例如网络中断或服务器错误， on_error 函数会被调用。该函数接收两个参数：WebSocket实例 ws 和错误对象 error 。你应该在 on_error 函数中记录错误信息，并尝试重新连接。

def on_error(ws, error):
    print(error)
    # 在这里处理错误，例如记录错误信息并尝试重新连接

定义连接关闭处理函数。当WebSocket连接关闭时， on_close 函数会被调用。这可能是由于客户端主动关闭连接，或服务器关闭连接。你应该在 on_close 函数中执行清理操作，并尝试重新连接。

def on_close(ws):
    print("### closed ###")
    # 在这里执行清理操作并尝试重新连接

定义连接建立成功时的处理函数。一旦WebSocket连接成功建立， on_open 函数会被调用。在该函数中，你可以向BitMEX服务器发送订阅请求，以接收特定的数据流。BitMEX使用JSON格式的消息来订阅频道。例如，要订阅 XBTUSD 的交易和报价数据，你需要发送以下JSON消息：

def on_open(ws):
    ws.send('{"op": "subscribe", "args": ["trade:XBTUSD", "quote:XBTUSD"]}')
    # 可以添加更多订阅，例如 "orderBookL2:XBTUSD"

主程序入口。在 if __name__ == "__main__": 块中，创建WebSocketApp实例，并设置回调函数。 websocket.enableTrace(True) 可以开启WebSocket调试模式，方便查看WebSocket通信过程中的详细信息。

if __name__ == "__main__":
    websocket.enableTrace(True)
    ws = websocket.WebSocketApp("wss://www.bitmex.com/realtime",
                                   on_message = on_message,
                                   on_error = on_error,
                                   on_close = on_close)
    ws.on_open = on_open
    ws.run_forever()

这段代码使用 websocket-client 库连接到BitMEX WebSocket API，并订阅了 trade:XBTUSD 和 quote:XBTUSD 频道。 trade:XBTUSD 频道提供 XBTUSD 合约的实时交易数据，包括成交价格、成交数量和成交时间。 quote:XBTUSD 频道提供 XBTUSD 合约的实时报价数据，包括买一价、卖一价、买一量和卖一量。当有新的交易或报价数据时， on_message 函数会被调用，并将数据打印到控制台。在实际应用中，你需要解析JSON格式的数据，并根据数据执行相应的操作，例如更新UI，计算指标，或触发交易信号。

为了保证连接的稳定性和可靠性，可以考虑添加以下增强功能：

自动重连机制：当连接断开时，自动尝试重新连接。
心跳检测：定期向服务器发送心跳消息，以检测连接是否仍然有效。
错误处理和日志记录：详细记录错误信息，方便排查问题。
多线程或异步处理：使用多线程或异步方式处理接收到的消息，避免阻塞主线程。

订阅频道

为了获取特定类型的市场数据或交易信息，您需要订阅相应的频道。通过订阅，您可以实时接收感兴趣的数据流，从而进行高效的交易决策和市场分析。例如：

trade:XBTUSD: 订阅XBTUSD永续合约的实时成交数据。这将提供关于每笔交易的价格、数量和方向的即时更新，帮助您掌握市场动态。
quote:XBTUSD: 订阅XBTUSD永续合约的实时报价数据。此频道提供当前最佳买入价(Bid)和最佳卖出价(Ask)，是衡量市场供需关系和预测短期价格变动的重要指标。
orderBookL2:XBTUSD: 订阅XBTUSD永续合约的实时Level 2深度数据。这将提供订单簿的详细视图，包括不同价格水平的买单和卖单数量，有助于您了解市场的支撑和阻力位，以及潜在的大额交易活动。

订阅频道的方法是通过WebSocket连接发送一个符合JSON格式的消息。该消息应包含指示所需频道的必要参数。具体消息格式和参数要求，请参考交易所的API文档，以便正确订阅所需数据。

# 上一篇：Bybit信用卡充值攻略：快速搞定，新手必看！

# 下一篇：Mexc比特币交易创新：抓住财富机遇还是高风险游戏？