使用 Python 结合 OKX 交易所 API 构建加密货币量化交易系统的方法。内容涵盖账户资金查询、订单状态追踪、WebSocket 实时行情监控、衍生品杠杆设置、多子账户管理以及网格策略自动化部署。通过示例代码展示了如何正确配置 API 密钥、处理签名错误及实现自动重连机制。文章还提供了常见错误代码排查与性能优化建议，帮助开发者建立稳定的交易系统和风险管理体系。
新手在查询账户余额时经常遇到签名错误或权限不足的问题。配置 API 密钥时需注意 flag 参数设置。
import okx.Funding as Funding
# 配置 API 密钥
api_key =
secret_key =
passphrase =
flag =
fundingAPI = Funding.FundingAPI(api_key, secret_key, passphrase, , flag)
result = fundingAPI.get_balances(ccy=)
result[] == :
()
:
()
注意：
下单后需实时监控订单状态，避免盲目等待。
import okx.Trade as Trade
import time
tradeAPI = Trade.TradeAPI(api_key, secret_key, passphrase, False, flag)
# 限价买入 BTC
order_result = tradeAPI.place_order(
instId="BTC-USDT",
tdMode="cash", # 现货模式
side="buy",
ordType="limit",
px="30000",
sz="0.01"
)
if order_result["code"] == "0":
ordId = order_result["data"][0]["ordId"]
print(f"下单成功，订单 ID: {ordId}")
# 实时监控订单状态
for i in range(10):
status_result = tradeAPI.get_order(instId="BTC-USDT", ordId=ordId)
state = status_result["data"][0]["state"]
print(f"第{i+1}次查询，订单状态：{state}")
if state == "filled":
print("订单已成交！")
break
elif state == "canceled":
print("订单已取消")
break
time.sleep(1) # 每秒查询一次
传统的轮询方式效率低下，WebSocket 是量化交易的标配。
import asyncio
from okx.websocket.WsPublicAsync import WsPublicAsync
class RealTimeMonitor:
def __init__(self):
self.ws = None
async def on_ticker_update(self, message):
"""处理实时行情数据"""
if "data" in message:
ticker = message["data"][0]
print(f"最新价格：{ticker['last']}, 24 小时涨幅：{ticker['sodUtc8']}%")
async def start_monitoring(self, symbols):
"""启动实时监控"""
self.ws = WsPublicAsync(url="wss://ws.okx.com:8443/ws/v5/public")
channels = [{"channel": "tickers", "instId": symbol} for symbol in symbols]
await self.ws.start()
await self.ws.subscribe(channels, self.on_ticker_update)
print("实时行情监控已启动...")
async def main():
monitor = RealTimeMonitor()
await monitor.start_monitoring(["BTC-USDT", "ETH-USDT"])
await asyncio.sleep(60) # 监控 1 分钟
# 运行监控
asyncio.run(main())
合约交易与现货有很大不同，python-okx 提供了专门的接口。
import okx.Account as Account
import okx.Trade as Trade
# 设置杠杆前先检查当前杠杆
accountAPI = Account.AccountAPI(api_key, secret_key, passphrase, False, flag)
leverage_info = accountAPI.get_leverage_info(instId="BTC-USD-SWAP")
print(f"当前杠杆：{leverage_info['data'][0]['lever']}")
# 设置 10 倍杠杆
result = accountAPI.set_leverage(
instId="BTC-USD-SWAP",
lever="10",
mgnMode="cross", # 全仓模式
posSide="long" # 多头持仓
)
if result["code"] == "0":
print("杠杆设置成功")
else:
print(f"杠杆设置失败：{result['msg']}")
如果你管理多个交易账户，子账户功能能帮你省去大量重复操作。
import okx.SubAccount as SubAccount
subAccountAPI = SubAccount.SubAccountAPI(api_key, secret_key, passphrase, False, flag)
# 获取所有子账户列表
subaccounts = subAccountAPI.get_subaccount_list()
print(f"共管理 {len(subaccounts['data'])} 个子账户")
# 批量转账到交易账户
for account in subaccounts["data"]:
if account["type"] == "1": # 标准子账户
transfer_result = subAccountAPI.subAccount_transfer(
ccy="USDT",
amt="1000",
froms="6", # 资金账户
to="5", # 交易账户
fromSubAccount=account["subAcct"]
)
print(f"已向 {account['subAcct']} 转账 1000 USDT")
网格交易是震荡行情中的利器，python-okx 让策略部署变得简单。
import okx.Grid as Grid
gridAPI = Grid.GridAPI(api_key, secret_key, passphrase, False, flag)
def create_grid_strategy(symbol, lower_price, upper_price, grid_count, amount_per_grid):
"""创建网格交易策略"""
result = gridAPI.grid_order_algo(
instId=symbol,
algoOrdType="grid",
maxPx=str(upper_price),
minPx=str(lower_price),
gridNum=str(grid_count),
runType="1", # 现货网格
sz=str(amount_per_grid),
tpTriggerPx="32000", # 止盈触发价
slTriggerPx="27000" # 止损触发价
)
if result["code"] == "0":
algo_id = result["data"][0]["algoId"]
print(f"网格策略创建成功！策略 ID: {algo_id}")
return algo_id
else:
print(f"策略创建失败：{result['msg']}")
return None
# 在 28000-32000 区间创建 20 格网格
strategy_id = create_grid_strategy(
symbol="BTC-USDT",
lower_price=28000,
upper_price=32000,
grid_count=20,
amount_per_grid=0.001
)
避免频繁创建和销毁 API 客户端，复用连接能显著提升性能。
对于需要同时处理多个订单的场景，使用批量接口减少网络开销。
def safe_api_call(api_func, *args, **kwargs):
"""安全的 API 调用包装器"""
try:
result = api_func(*args, **kwargs)
if result["code"] == "0":
return result["data"]
else:
print(f"API 调用失败：{result['msg']}")
return None
except Exception as e:
print(f"网络异常：{str(e)}")
return None
本文介绍了使用 Python 结合 OKX 交易所 API 构建加密货币量化交易系统的方法。内容涵盖账户资金查询、订单状态追踪、WebSocket 实时行情监控、衍生品杠杆设置、多子账户管理以及网格策略自动化部署。通过示例代码展示了如何正确配置 API 密钥、处理签名错误及实现自动重连机制。文章还提供了常见错误代码排查与性能优化建议，帮助开发者建立稳定的交易系统和风险管理体系。
微信公众号「极客日志」，在微信中扫描左侧二维码关注。展示文案：极客日志 zeeklog
使用加密算法（如AES、TripleDES、Rabbit或RC4）加密和解密文本明文。 在线工具，加密/解密文本在线工具，online
解析常见 curl 参数并生成 fetch、axios、PHP curl 或 Python requests 示例代码。 在线工具，curl 转代码在线工具，online
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具，Base64 字符串编码/解码在线工具，online
将字符串、文件或图像转换为其 Base64 表示形式。 在线工具，Base64 文件转换器在线工具，online
将 Markdown（GFM）转为 HTML 片段，浏览器内 marked 解析；与 HTML转Markdown 互为补充。 在线工具，Markdown转HTML在线工具，online
将 HTML 片段转为 GitHub Flavored Markdown，支持标题、列表、链接、代码块与表格等；浏览器内处理，可链接预填。 在线工具，HTML转Markdown在线工具，online