抹茶交易所(MEXC)与Bitfinex实时成交数据查询

1. 下载并安装 MEXC App： 从官方渠道下载并安装 MEXC App。
2. 登录账户： 使用你的 MEXC 账户登录。
3. 选择交易对： 在 App 中选择你想要查看的交易对。
4. 查看实时成交： 在交易界面，你可以找到实时成交记录，并根据自己的需要进行筛选和分析。

1. 获取 API 密钥： 在 MEXC 账户设置中，申请并获取 API 密钥（包括 API Key 和 Secret Key）。
2. 选择 API 端点： MEXC API 提供了多个与成交数据相关的端点，例如 GET /api/v3/trades，可以获取指定交易对的最新成交记录。
3. 编写代码： 使用编程语言（如 Python）编写代码，通过 API 接口请求数据。你需要使用你的 API 密钥进行身份验证。
4. 解析数据： 从 API 响应中解析出成交时间、成交价格和成交数量等信息，并进行进一步的处理和分析。

示例 (Python):

使用 Python 获取 MEXC 交易所的交易历史记录。

导入必要的 Python 库： requests 用于发送 HTTP 请求， hashlib 和 hmac 用于生成数字签名， time 用于获取当前时间戳。

import requests
import hashlib
import hmac
import time

然后，定义 API 密钥 ( api_key )，私钥 ( secret_key ) 和交易对 ( symbol )。请务必替换 YOUR_API_KEY 和 YOUR_SECRET_KEY 为您在 MEXC 交易所获得的实际密钥。 symbol 代表您要查询的交易对，例如 'BTCUSDT' 代表比特币兑 USDT。

api_key = 'YOUR_API_KEY'
secret_key = 'YOUR_SECRET_KEY'
symbol = 'BTCUSDT'

接下来，定义一个函数 get_trades 来获取交易记录。此函数接受交易对 ( symbol ) 和返回的交易记录数量限制 ( limit ) 作为参数。默认的 limit 值为 10。

该函数首先获取当前时间戳，并将其转换为毫秒。时间戳是构建 API 请求参数的一部分。

然后，构建请求参数字典 params ，包含 symbol , limit 和 timestamp 。这些参数将通过 HTTP GET 请求发送到 MEXC API。

def get_trades(symbol, limit=10):
    timestamp = int(time.time() * 1000)
    params = {
        'symbol': symbol,
        'limit': limit,
        'timestamp': timestamp
    }

为了保证 API 请求的安全性，需要对请求进行签名。将参数字典转换为查询字符串。然后，使用私钥 ( secret_key ) 和 SHA256 算法生成 HMAC 签名。签名是对查询字符串进行哈希运算的结果，用于验证请求的真实性。

    query_string = '&'.join([f'{k}={v}' for k, v in params.items()])
    signature = hmac.new(secret_key.encode('utf-8'), query_string.encode('utf-8'), hashlib.sha256).hexdigest()

接着，定义 HTTP 请求头 headers ，其中包含 X-MEXC-APIKEY 字段，用于指定 API 密钥。MEXC 交易所使用此密钥来识别您的身份。

    headers = {
        'X-MEXC-APIKEY': api_key
    }

然后，构建完整的 API 请求 URL。该 URL 包含 API 端点 ( https://api.mexc.com/api/v3/trades ), 查询字符串 ( query_string ) 和签名 ( signature )。

使用 requests.get 函数发送 HTTP GET 请求到 MEXC API。 response.raise_for_status() 检查响应状态码，如果状态码表示错误 (4xx 或 5xx)，则会引发 HTTPError 异常。

将响应内容解析为 JSON 格式，并将其作为函数返回值。

    url = f'https://api.mexc.com/api/v3/trades?{query_string}&signature={signature}'
    response = requests.get(url, headers=headers)
    response.raise_for_status()  # Raise HTTPError for bad responses (4xx or 5xx)
    return response.()

调用 get_trades 函数获取交易记录，并遍历结果，打印每条交易记录的时间、价格和数量。时间戳以 Unix 时间戳格式表示，价格和数量都是字符串类型。

trades = get_trades(symbol)
for trade in trades:
    print(f"Time: {trade['time']}, Price: {trade['price']}, Qty: {trade['qty']}")

1. 获取 API 密钥： 在 Bitfinex 账户设置中，创建并获取 API 密钥。
2. 选择 API 端点： Bitfinex API 提供了 WebSocket 和 REST API 两种方式获取实时成交数据。WebSocket 适用于需要实时推送的场景，而 REST API 适用于定期请求数据的场景。
3. 使用 WebSocket API：
   • 连接 WebSocket 服务：连接到 Bitfinex 的 WebSocket API 地址。
   • 订阅交易频道：订阅你感兴趣的交易对的交易频道。
   • 接收数据：实时接收成交数据，包括成交时间、成交价格和成交数量。

示例 (Python):

使用 Python 实现与加密货币交易所 Bitfinex 的 WebSocket 连接，需要安装 websocket-client 库。 可以使用 pip 进行安装： pip install websocket-client 。

导入必要的库： websocket 用于建立 WebSocket 连接，以及 库，虽然在原始代码中没有明确导入，但推荐导入，因为它通常用于序列化和反序列化 JSON 消息，特别是在处理订阅事件时。

import websocket
import 

定义 on_message 函数，此函数在收到 WebSocket 消息时被调用。它接收 WebSocket 连接对象 ws 和消息内容 message 作为参数，并将消息打印到控制台。在实际应用中，您可以根据需要进一步处理这些消息，例如解析 JSON 数据、更新本地数据结构或触发其他操作。

def on_message(ws, message):
    print(message)

定义 on_error 函数，此函数在 WebSocket 连接发生错误时被调用。它接收 WebSocket 连接对象 ws 和错误对象 error 作为参数，并将错误信息打印到控制台。这对于调试和诊断连接问题至关重要。

def on_error(ws, error):
    print(error)

定义 on_close 函数，此函数在 WebSocket 连接关闭时被调用。它接收 WebSocket 连接对象 ws 作为参数，并打印一条消息指示连接已关闭。您可以在此函数中执行清理操作，例如重新连接或记录关闭事件。

def on_close(ws):
    print("### closed ###")

定义 on_open 函数，此函数在 WebSocket 连接成功建立后被调用。它接收 WebSocket 连接对象 ws 作为参数。在此函数中，定义一个内部函数 run ，用于发送订阅消息。 run 函数使用 ws.send() 方法发送 JSON 格式的订阅消息。消息内容包括 event 字段（设置为 "subscribe"）， channel 字段（设置为 "trades"，表示订阅交易信息），以及 symbol 字段（设置为 "tBTCUSD"，表示订阅 BTC/USD 交易对）。 .dumps() 方法用于将 Python 字典转换为 JSON 字符串。使用 threading.Thread 创建一个新的线程来运行 run 函数，以避免阻塞主线程。

def on_open(ws):
    def run(*args):
        ws.send(.dumps({
            "event": "subscribe",
            "channel": "trades",
            "symbol": "tBTCUSD"
        }))
    import threading
    threading.Thread(target=run).start()

在主程序入口 ( if __name__ == "__main__": ) 中，首先使用 websocket.enableTrace(True) 启用 WebSocket 跟踪，以便在控制台输出详细的 WebSocket 通信日志，用于调试。然后，创建一个 websocket.WebSocketApp 对象，指定 WebSocket 服务器的 URL ( "wss://api.bitfinex.com/ws/2" )，以及消息处理函数 ( on_message )、错误处理函数 ( on_error ) 和关闭处理函数 ( on_close )。设置 ws.on_open 为 on_open 函数，以便在连接建立后发送订阅消息。调用 ws.run_forever() 方法启动 WebSocket 客户端，使其保持运行状态并监听服务器消息。

if __name__ == "__main__":
    websocket.enableTrace(True)
    ws = websocket.WebSocketApp("wss://api.bitfinex.com/ws/2",
                                  on_message=on_message,
                                  on_error=on_error,
                                  on_close=on_close)
    ws.on_open = on_open
    ws.run_forever()

4. 使用 REST API： 使用 GET /v2/trades/{symbol}/hist 端点获取历史成交记录。你需要提供交易对的名称。