### Python与欧易交易所API交互实现自动化交易 为了通过Python编写程序来与欧易交易所进行交互并执行自动化交易操作，如自动建仓和平仓（交割），可以遵循以下指南。 #### 安装必要的库 首先安装`requests`库用于发送HTTP请求到欧易交易所的API端点。可以通过pip命令轻松完成此过程[^1]： ```bash pip install requests ``` #### 获取API密钥 访问欧易交易平台网站创建账户，并按照官方文档说明获取个人专属的API Key和Secret Key。这些凭证对于发起安全认证过的调用至关重要[^2]。 #### 初始化配置 定义一个类用来封装所有针对该交易所的操作逻辑，在此类内部设置好基础URL以及加载用户的API密钥信息等参数[^3]: ```python import hashlib import hmac import time import requests class OkexClient: BASE_URL = "https://www.okex.com/api/v5/" def __init__(self, api_key, secret_key, passphrase): self.api_key = api_key self.secret_key = secret_key self.passphrase = passphrase # ...其他方法... ``` #### 构造签名函数 由于大多数敏感接口都需要经过身份验证才能被调用，因此需要构建一个能够生成有效签名字符串的方法以便附加至每次请求头中作为授权证明[^4]: ```python def _sign(self, method, endpoint, params=None): timestamp = str(time.time()) message = f"{timestamp}{method.upper()}/{endpoint}?" if params is not None and isinstance(params, dict): sorted_params = [(k, v) for k, v in sorted(params.items())] query_string = '&'.join(f'{k}={v}' for k, v in sorted_params) message += query_string signature = base64.b64encode( hmac.new( bytes(self.secret_key, 'utf-8'), msg=bytes(message, 'utf-8'), digestmod=hashlib.sha256).digest() ).decode('utf-ACCESS-KEY': self.api_key, 'OK-ACCESS-SIGN': signature, 'OK-ACCESS-TIMESTAMP': timestamp, 'OK-ACCESS-PASSPHRASE': self.passphrase, 'Content-Type': 'application/json' } return headers ``` #### 创建订单(建仓) 当准备就绪之后就可以利用上述工具去尝试下单了。这里展示了一个简单的例子关于如何提交限价买单以建立仓位[^5]: ```python def place_order(self, instrument_id, side, price, size): url = f"{OkexClient.BASE_URL}/trade/order" data = {"instId":instrument_id,"tdMode":"cash","side":side,"ordType":"limit", "px":str(price),"sz":str(size)} response = requests.post(url=url,json=data,headers=self._sign("POST", "/trade/order",data)) result = response.json() if result['code'] != '0': raise Exception(f"Order placement failed: {result}") order_info = result.get('data', [{}])[0] return order_info ``` #### 查询未平仓单据列表 有时可能想要查看当前有哪些尚未完全成交或是已经部分成交但仍需进一步处理的挂单情况，则可通过查询开放中的委托记录来获得相关信息[^6]: ```python def get_open_orders(self,instrument_id): path="/trade/orders-pending" param={"instId":instrument_id} resp=requests.get(url=f"{OkexClient.BASE_URL}{path}",params=param,headers=self._sign("GET",path,param)).json() orders=[{ "order_id":item["ordId"], "price":float(item["px"]), "size":int(item["accFillSz"]) }for item in resp.get("data",[[]])] return orders ``` #### 平掉指定ID下的持仓(交割) 最后一步就是学习怎样关闭特定编号所对应的仓位。这通常涉及到撤销原有指令再重新发出相反方向的新指令直至达到预期效果为止[^7]: ```python def close_position_by_order_id(self, order_id): cancel_url = f"{OkexClient.BASE_URL}/trade/cancel-order/{order_id}" res_cancel = requests.post(cancel_url, headers=self._sign("POST",f"/trade/cancel-order/{order_id}")) if res_cancel.status_code!=200 or res_cancel.json()['code']!='0': print(res_cancel.text) return False position_data=res_cancel.json().get('data',[None]) inst_id=position_data[0]['instId'] open_ords=get_open_orders(inst_id) total_qty=sum([o['size'] for o in open_ords]) opposite_side='sell'if next(iter(open_ords), {}).get('side')=='buy'else'buy' new_ord=place_order(instrument_id=inst_id,side=opposite_side,price=open_ords[-1]["price"],size=str(total_qty)) return True if int(new_ord.get('avgPx'))>0 else False ```