欧易API自动交易指南：从入门到实战

时间：2025-03-01 阅读数：86人阅读

如何使用欧易的API接口进行自动交易

欧易（OKX）交易所提供强大的API（应用程序编程接口），允许开发者和交易者构建自动化交易策略，实现无需人工干预的程序化交易。本文将详细介绍如何利用欧易的API接口进行自动交易，并提供示例代码片段。

1. 准备工作

在使用欧易API进行交易或数据分析之前，充分的准备工作至关重要。这将确保您能够顺利地与欧易交易所的服务器进行交互，并有效地管理您的账户和数据。以下是需要完成的准备工作：

注册欧易账户并完成身份认证：这是使用欧易所有功能的前提。

创建API密钥：登录欧易账户，在API管理页面创建API密钥。需要注意的是，API密钥需要设置权限，例如交易、提现等。为了安全起见，建议只授予交易权限，避免资金损失风险。同时，强烈建议启用IP白名单，限制只有特定IP地址才能使用该API密钥。

了解欧易API文档：欧易提供了详细的API文档，包含了所有可用的API接口、请求参数、返回数据格式等。熟悉API文档是进行自动交易的基础。可以访问欧易官网的API文档页面进行查阅。

选择编程语言和SDK：欧易API支持多种编程语言，例如Python、Java、Node.js等。根据自己的编程技能选择合适的语言。可以使用官方提供的SDK，也可以自行编写HTTP请求代码。

2. API 认证

欧易 API 采用基于签名的认证机制，以确保所有请求的真实性和完整性。这种认证方式可以有效防止未经授权的访问，保障用户数据的安全。

API 请求的合法性验证通过生成和验证签名来实现。签名过程的具体步骤如下：

准备请求参数：将所有请求参数（包括查询参数和POST数据）按照参数名的字母顺序排序。

拼接字符串：将排序后的参数名和参数值用=连接，然后将所有键值对用&连接起来，形成一个字符串。

添加时间戳和请求方法：在拼接好的字符串前面加上时间戳（Unix时间戳，单位为秒）和请求方法（例如GET、POST、PUT、DELETE），用&连接。

使用密钥进行HMAC-SHA256签名：使用API密钥的secretKey对拼接好的字符串进行HMAC-SHA256签名。

将签名添加到请求头：将签名、API密钥的apiKey和时间戳添加到HTTP请求头中。

以下是一个Python示例代码，用于生成API签名：

import hashlib import hmac import time import urllib.parse

def generatesignature(timestamp, method, requestpath, body, secret_key): """生成欧易API签名."""

message = str(timestamp) + str.upper(method) + request_path + body
mac = hmac.new(bytes(secret_key, encoding='utf8'), bytes(message, encoding='utf-8'), digestmod=hashlib.sha256)
d = mac.digest()
return base64.b64encode(d)

3. 常用API接口

以下是一些常用的欧易API接口，它们允许开发者访问欧易交易所的数据和执行交易操作。请注意，使用API需要进行身份验证，并且不同接口可能有不同的权限要求和频率限制。务必查阅欧易官方API文档获取最新的信息和详细的使用说明。

获取账户信息：用于获取账户余额、持仓信息等。

接口：GET /api/v5/account/balance
参数：ccy (可选，币种)

下单：用于创建买入或卖出订单。

接口：POST /api/v5/trade/order
参数：
- instId: 交易对，例如BTC-USDT
- side: 交易方向，buy 或 sell
- ordType: 订单类型，例如market（市价单）、limit（限价单）
- sz: 数量
- px: 价格（仅限价单需要）

撤单：用于取消未成交的订单。

接口：POST /api/v5/trade/cancel-order
参数：
- instId: 交易对
- ordId: 订单ID

获取订单信息：用于查询订单的状态和成交信息。

接口：GET /api/v5/trade/order
参数：
- instId: 交易对
- ordId: 订单ID

4. 自动交易策略示例

以下是一个简化的自动交易策略示例，采用Python语言，旨在演示当比特币（BTC）价格低于预设阈值时执行自动买入操作，而当价格超过预设阈值时则执行自动卖出操作。此示例仅供参考，实际应用中需要根据具体交易所API和市场情况进行更复杂的逻辑设计和风险控制。

import requests
import time
import hmac
import hashlib
import base64

这段代码片段展示了Python中用于构建一个自动交易策略所需的关键库。 requests 库用于向交易所的API发送HTTP请求，以便获取实时市场数据和提交交易指令。 time 库允许程序暂停执行，从而控制交易频率和避免API调用频率限制。 hmac 、 hashlib 和 base64 库则通常用于生成安全的API签名，以验证交易请求的身份并保护账户安全。具体交易所API调用方法会根据交易所的不同而有所变化，需要在实际使用中查阅对应API文档。

替换为你的API密钥、secretKey和Passphrase

API_KEY = "YOUR_API_KEY"

SECRET_KEY = "YOUR_SECRET_KEY"

PASSPHRASE = "YOUR_PASSPHRASE" ，这是为了增强API安全性的附加验证信息，请妥善保管。

BASE_URL = "https://www.okx.com" ，这是OKX API的根URL，所有请求都将基于此URL构建。

def get_timestamp():

return str(int(time.time())) ，此函数生成一个Unix时间戳，以字符串形式返回，精确到秒。时间戳对于API请求的身份验证至关重要。

def sign(message, secretKey):

message = message.encode('utf-8') ，将消息编码为UTF-8字节串，保证兼容性。

secretKey = secretKey.encode('utf-8') ，同样将密钥编码为UTF-8字节串。

hmac_key = hmac.new(secretKey, message, hashlib.sha256) ，使用HMAC-SHA256算法创建一个HMAC对象，用于生成消息签名，确保请求的完整性和真实性。

signature = base64.b64encode(hmac_key.digest()).decode('utf-8') ，计算HMAC摘要，并使用Base64编码将摘要转换为字符串，以便在HTTP头部中传输。

return signature ，返回生成的签名。

def send_request(method, path, params=None, data=None):

timestamp = get_timestamp() ，获取当前时间戳。

if params:

encoded_params = urllib.parse.urlencode(params) ，如果存在查询参数，使用 urllib.parse.urlencode() 将参数编码为URL查询字符串。

url = f"{BASE_URL}{path}?{encoded_params}" ，构建包含查询参数的完整URL。

else:

url = f"{BASE_URL}{path}" ，构建不带查询参数的URL。

body = .dumps(data) if data else "" ，如果存在请求体数据，使用 .dumps() 将其转换为JSON字符串。

message = timestamp + method + path + body ，构建用于签名的消息，包括时间戳、HTTP方法、请求路径和请求体。

signature = sign(message, SECRET_KEY) ，使用私钥对消息进行签名。

headers = {

'OK-ACCESS-KEY': API_KEY, ，API密钥，用于标识用户。

'OK-ACCESS-SIGN': signature, ，请求签名，用于验证请求的完整性和身份。

'OK-ACCESS-TIMESTAMP': timestamp, ，时间戳，用于防止重放攻击。

'OK-ACCESS-PASSPHRASE': PASSPHRASE, ，Passphrase，增强安全性的附加口令。

'Content-Type': 'application/' ，指定请求体的MIME类型为JSON。

} ，设置HTTP请求头，包括API密钥、签名、时间戳和Passphrase。

try:

if method == "GET":

response = requests.get(url, headers=headers) ，发送GET请求。

elif method == "POST":

response = requests.post(url, headers=headers, data=body) ，发送POST请求，包含JSON格式的请求体。

elif method == "DELETE":

response = requests.delete(url, headers=headers) ，发送DELETE请求。

else:

print("Unsupported method")

return None ，如果使用了不支持的HTTP方法，则打印错误消息并返回 None 。

response.raise_for_status() # Raise HTTPError for bad responses (4xx or 5xx) ，检查HTTP响应状态码，如果状态码表示错误（4xx或5xx），则抛出 HTTPError 异常。

return response.() ，将响应体解析为JSON格式并返回。

except requests.exceptions.RequestException as e:

print(f"Request failed: {e}") ，捕获请求过程中发生的异常，打印错误信息。

return None ，如果请求失败，则返回 None 。

def get_btc_price():

"""获取比特币价格."""

response = send_request("GET","/api/v5/market/ticker",params={"instId": "BTC-USDT"}) ，调用 send_request() 函数发送GET请求，获取BTC-USDT交易对的最新价格。

if response and response.get("code") == "0": ，检查响应是否成功，通过 response.get("code") 避免 KeyError 。

return float(response['data'][0]['last']) ，提取并返回最新价格。

else:

print(f"Error getting BTC price: {response}") ，打印错误信息。

return None ，如果获取价格失败，则返回 None 。

def place_order(side, size, price=None):

"""下单."""

path = "/api/v5/trade/order" ，设置下单API的路径。

data = {

"instId": "BTC-USDT", ，指定交易对为BTC-USDT。

"side": side, ，指定买卖方向（buy或sell）。

"ordType": "limit" if price else "market", ，根据是否提供价格确定订单类型，如果提供了价格，则为限价单，否则为市价单。

"sz": str(size), ，指定下单数量，需要转换为字符串类型。

} ，构建下单数据。

if price:

data["px"] = str(price) ，如果下单类型为限价单，则设置价格，同样需要转换为字符串类型。

response =  send_request("POST",path,data=data)
if response and response.get("code") == "0":
    print(f"Order placed successfully: {response}")
else:
    print(f"Error placing order: {response}")

设定买入和卖出阈值

在构建自动交易策略时，预先设定买入和卖出阈值是至关重要的一步，能够帮助交易者在特定价格区间自动执行交易，提高交易效率并降低人为情绪干扰的风险。以下代码展示了如何设置买入和卖出价格阈值，以及每次交易的比特币数量。

BUY_THRESHOLD = 25000 ：定义买入阈值为 25000 美元。当比特币价格低于或等于此值时，程序将执行买入操作。

SELL_THRESHOLD = 30000 ：定义卖出阈值为 30000 美元。当比特币价格高于或等于此值时，程序将执行卖出操作。

TRADE_SIZE = 0.01 ：定义每次交易的比特币数量为 0.01 BTC。可以根据资金规模和风险承受能力调整此值。较小的交易规模有助于分散风险，而较大的交易规模可能会带来更高的潜在收益，但也伴随着更大的风险。

以下代码展示了如何在循环中监控比特币价格，并根据设定的阈值自动执行买入或卖出操作：

while True:
    price = get_btc_price()
    if price:
        print(f"Current BTC price: {price}")

        if price <= BUY_THRESHOLD:
            print("Buying BTC...")
            place_order("buy", TRADE_SIZE, price=BUY_THRESHOLD)
        elif price >= SELL_THRESHOLD:
            print("Selling BTC...")
            place_order("sell", TRADE_SIZE, price=SELL_THRESHOLD)
        else:
            print("No action needed.")

    time.sleep(60)   # 每隔60秒检查一次价格

代码解释：

while True: ：创建一个无限循环，使程序持续监控比特币价格并执行交易。
price = get_btc_price() ：调用 get_btc_price() 函数获取当前比特币价格。此函数需要根据具体的交易所 API 进行实现。
if price: ：确保成功获取到比特币价格后才执行后续的交易逻辑。
if price <= BUY_THRESHOLD: ：如果当前价格低于或等于买入阈值，则执行买入操作。
elif price >= SELL_THRESHOLD: ：如果当前价格高于或等于卖出阈值，则执行卖出操作。
place_order("buy", TRADE_SIZE, price=BUY_THRESHOLD) 和 place_order("sell", TRADE_SIZE, price=SELL_THRESHOLD) ：调用 place_order() 函数下单。此函数需要根据具体的交易所 API 进行实现，参数包括交易方向（"buy" 或 "sell"）、交易数量 ( TRADE_SIZE ) 和价格 ( BUY_THRESHOLD 或 SELL_THRESHOLD )。
time.sleep(60) ：暂停程序执行 60 秒，然后再次检查价格。可以根据需要调整此时间间隔。