Python 示例：

以下 Python 代码演示了如何使用 requests 库从 Bithumb 交易所的 API 获取指定加密货币交易对的行情数据。 该代码清晰地展示了如何构建 API 请求、处理响应以及进行错误处理，从而为后续的数据分析或交易策略开发奠定基础。

import requests import

def get_bithumb_ticker(currency_pair):

""" 从 Bithumb API 获取指定交易对的行情数据。 Args: currency_pair (str): 交易对，例如 "BTC_KRW"。 Returns: dict: 包含行情数据的字典，如果请求失败则返回 None。 """

url = f"https://api.bithumb.com/public/ticker/{currency_pair}"

try:

response = requests.get(url) response.raise_for_status() # 检查 HTTP 状态码，如果不是 200 则抛出异常

    data = response.()  # 将 JSON 响应解析为 Python 字典
    return data
except requests.exceptions.RequestException as e:
    print(f"请求出错：{e}")
    return None

if __name__ == "__main__":

currency_pair = "BTC_KRW" # 设置要查询的交易对为比特币/韩元 ticker_data = get_bithumb_ticker(currency_pair)

if ticker_data:
    print(.dumps(ticker_data, indent=4, ensure_ascii=False)) # 使用 .dumps 格式化输出，indent=4 增加可读性，ensure_ascii=False 处理中文

这段代码通过向 Bithumb API 发送 GET 请求，获取 BTC/KRW 交易对的最新行情数据。如果成功获取数据，则将结果格式化为 JSON 字符串并打印到控制台。 response.raise_for_status() 方法用于检查 HTTP 响应状态码，如果请求失败 (例如 404 Not Found 或 500 Internal Server Error)，会抛出一个异常，从而方便进行错误处理。 .dumps() 函数的 ensure_ascii=False 参数确保中文字符能够正确显示。

Python 示例：

import asyncio import websockets import

async def subscribe_ticker(currency_pair): """ 使用 WebSocket 连接到交易所并订阅特定交易对的行情数据。 Args: currency_pair (str): 要订阅的交易对，例如 "BTC_KRW"。 """ uri = "wss://ws.bithumb.com/public" # 假设的WebSocket 地址，务必替换为 Bithumb 官方提供的真实地址 print(f"正在连接到 WebSocket 服务器: {uri}") try: async with websockets.connect(uri) as websocket: print("成功连接到 WebSocket 服务器。") subscribe_message = { "type": "ticker", "symbols": [currency_pair], "tickTypes": ["1H"] # 可以根据需要修改 tickTypes，例如 ["1H", "24H"] } subscribe_message_ = .dumps(subscribe_message) print(f"发送订阅消息: {subscribe_message_}") await websocket.send(subscribe_message_) print("已发送订阅请求，等待接收数据...") while True: try: message = await websocket.recv() print(f"收到消息: {message}") data = .loads(message) # 将 JSON 字符串转换为 Python 字典 print(f"解析后的数据: {data}") # 在这里可以对接收到的数据进行处理和分析，例如计算移动平均线、判断交易信号等。 # 例如：print(f"当前价格: {data['content']['closePrice']}") except websockets.exceptions.ConnectionClosedError as e: print(f"WebSocket 连接关闭：{e}") break except Exception as e: print(f"发生错误：{e}") break except websockets.exceptions.InvalidURI as e: print(f"无效的 WebSocket URI: {e}") except websockets.exceptions.WebSocketException as e: print(f"WebSocket 错误: {e}") except Exception as e: print(f"连接服务器时发生错误: {e}")

async with websockets.connect(uri) as websocket:
    subscribe_message = {
        "type": "ticker",
        "symbols": [currency_pair],
        "tickTypes": ["1H"]
    }
    await websocket.send(.dumps(subscribe_message))

    while True:
        try:
            message = await websocket.recv()
            data = .loads(message)
            print(data)

        except websockets.exceptions.ConnectionClosedError as e:
            print(f"WebSocket 连接关闭：{e}")
            break
        except Exception as e:
            print(f"发生错误：{e}")
            break

if __name__ == "__main__": currency_pair = "BTC_KRW" # 指定要订阅的交易对 print(f"开始订阅 {currency_pair} 的行情数据...") asyncio.run(subscribe_ticker(currency_pair)) # 启动异步事件循环并运行 subscribe_ticker 函数 print("程序已结束。")

这段代码演示了如何使用 Python 的 `asyncio` 和 `websockets` 库连接到 Bithumb 的 WebSocket 服务器，并订阅 BTC/KRW 交易对的实时行情数据。服务器会主动推送数据更新，客户端接收并将其打印到控制台。 请务必将 `wss://ws.bithumb.com/public` 替换为 Bithumb 官方提供的真实 WebSocket 地址，并且根据 Bithumb 的 API 文档调整订阅消息的格式。 建议添加错误处理机制，例如检查连接状态、处理无效消息等，以提高程序的健壮性。 实际应用中，可能需要安装 `websockets` 库。 使用 `pip install websockets` 命令进行安装。 该示例代码使用 `.dumps()` 将 Python 字典转换为 JSON 字符串，并使用 `.loads()` 将 JSON 字符串转换为 Python 字典，以便与 WebSocket 服务器进行数据交换。 根据需要可以调整 `tickTypes` 参数，例如使用 `["1H", "24H"]` 同时订阅 1 小时和 24 小时的行情数据。