如何使用CCXT交易数字货币现货

发布时间 2023-07-19 21:14:47作者: 数量技术宅

更多精彩内容,欢迎关注公众号:数量技术宅,也可添加技术宅个人微信号:sljsz01,与我交流。

数字货币现货标准化接口

数字货币市场与股票、期货市场最大的不同点在于数字货币主流交易所数量很多。举个例子,如果我们需要交易螺纹钢期货(RB),我们只能选择上海期货交易所。然而,如果我们想交易比特币,有币安、欧易、火币、Coinbase、Bitmex、Bitfinix、FTX等等很多主流的数字货币交易所可供选择。

对于量化交易或程序交易者来说,数字货币市场最大的痛点在于,每一个数字货币交易所都有自己的API接口,尽管接口大致范式相似,但是细节上有很多不同点,如果交易10家交易所,我们就需要搞懂10个不同的API,并将其接入,这无疑是一件费时费力的事。那么,是否有一个统一的、通用的、标准化的接口,能让我们轻松接入几乎所有主流币圈交易所?

这时候,就需要引入一个 数字货币三方接口CCXT了,这个接口是一个支持多家主流数字货币交易所的标准化接口,CCXT在底层封装了支持主流交易所的现货API,并在表层用让用户可以同样的外接接口访问不同交易所的API,为我们开发多市场尤其是跨市场策略提供了极大的便利。

CCXT接口除了支持几乎所有主流交易所现货API的统一封装外,还支持部分交易所合约(如币安合约)交易的隐式封装,关于隐式封装的使用,大家可以参考我们的历史文章:(链接)。本文将重点介绍CCXT现货API的使用。

如何安装CCXT,如何查询帮助文档

安装CCXT

对于Python语言,安装CCXT与其他Python三分库的方式是一样的。使用语句pip install ccxt即可安装。

安装完成后,我们可以尝试使用import ccxt导入CCXT库,如果运行该语句没有报错,说明CCXT已经成功导入

CCXT Manual (帮助文档)

CCXT提供了详细的帮助文档,可以通过网址https://docs.ccxt.com/en/latest/manual.html#markets进行访问。帮助文档的侧边栏提供了不同API接口的分类,包括MarketAPI、Implicit API、Unified API、Public API、Private API等类别,方便用户根据自己的需要进行分类查询。

而对于每个API,CCXT不仅给出了调用函数名、参数、示例的说明,也给出了调用后的返回结构数据。图例是Market分类中Currency Structure的返回结构。

CCXT初始化

介绍完CCXT的安装以及如何查找帮助文档,接下来我们开始使用CCXT。CCXT的初始化可以分为三步,其中第三步可选,前两步必做。

第一步,加载ccxt模块

第二步,初始化,调用ccxt.交易所名称,其中交易所名称可以替换为任何想要的交易所

第三步,获取初始化交易所的交易市场及交易货币对(测试交易所是否加载成功)

# 加载ccxt模块
import ccxt
print(ccxt.exchanges)

# market API
exchange = ccxt.binance()
markets = exchange.load_markets()
print(exchange.fetch_markets())
print(exchange.fetchCurrencies())

运行结果:先打印CCXT支持的所有交易所,可以看到,CCXT支持的交易所数量很多,足以满足大部分量化交易员的日常开发。

然后我们以币安交易所现货为例,获取币安交易所现货支持的市场和币对。通过markets变量的总数我们可以看到,币安交易所的现货币对一共有2098个,并且这些币对的详细交易信息也由CCXT通过dict的数据格式反馈给我们了。

如何调用CCXT行情API

初始化CCXT后,接下来我们再尝试调用CCXT的现货行情API,获取各种各样的行情数据。CCXT帮我们封装好了从订单簿、ticker、到成交、K线的几乎所有能够在策略中用得到的行情数据,都可以用标准方法,一键调用。

我们通过一个循环,实现对所有币种行情数据调用查询,包括:

获取订单簿、获取公开成交数据、获取ticker数据、获取k线数据

# quote API
# 设置间隔2秒
delay = 0.5
# 对币安所有交易的数字货币对循环
for symbol in exchange.markets:
   # 打印当前数字货币对
   print(symbol)
   # 获取该数字货币对当前的订单簿,并打印
   print(exchange.fetch_order_book(symbol, 10))
   time.sleep(delay)
   print(exchange.fetch_trades(symbol, limit=5))
   time.sleep(delay)
   print(exchange.fetch_ticker(symbol))
   time.sleep(delay)
   print(exchange.fetch_ohlcv(symbol, '1d'))
   time.sleep(delay)

我们再以BTCUSDT为例,来看获取后返回的数据结构。

订单簿(以获取10档盘口数据为例)

公开成交数据

ticker数据

k线数据(以日线为例)

如何调用CCXT交易API

在熟悉了行情API后,我们再来尝试使用CCTX的交易API。但使用交易API前必须注意的是,由于行情API是公有API,而交易API是私有API,所以我们必须调用CCXT的方法,把key传入刚才创建的交易所变量,才能实现调用私有API的权限,传入方法如下

api_key = ""  # 币安的api key
secret_key = ""  # 币安的secret key
exchange.apiKey = api_key
exchange.secret = secret_key

然后,我们可以开始执行一系列与私有API相关的操作,包括:

a. 资产查询

b. 订单查询(包括所有、未完成、已完成订单)

c. 成交查询

d. 报单(市价、限价、买报单、卖报单)

e. 撤单

# trade API
# 资产查询
exchange.fetch_balance()
# 订单查询(依次是所有、未完成、已完成订单)
exchange.fetchOrders(symbol)
exchange.fetchOpenOrders(symbol)
exchange.fetchClosedOrders(symbol)
# 成交查询
exchange.fetchMyTrades(symbol)
# 报单(依次是市价、限价、买报单、卖报单)
exchange.create_order(symbol, 'market', 'buy', amount)
exchange.createLimitBuyOrder(symbol, amount, orderprice)
exchange.createLimitSellOrder(symbol, amount, orderprice)
exchange.createMarketBuyOrder(symbol, amount)
exchange.createMarketSellOrder(symbol, amount)
# 撤单
exchange.cancel_order(order_id)

我们来看上述调用查询后的结果

资产查询

订单查询(所有,以symbol = BUSD/USDT为例)

成交查询(以symbol = BUSD/USDT为例)

对于报单、撤单,如果报单撤单成功,返回的信息是报单的order_id或撤单的order_id,如果错误,会返回相应错误代码及错误原因,在此不一一举例,详细可查询CCXT或交易所帮助文档错误代码描述部分。

CCXT获取行情数据并交易的小栗子

最后,将我们刚才学习的CCXT初始化、调用行情API、调用交易API结合起来,就可以完成一个简单的从初始化交易所加载Key,到获取最新行情,再到按照该行情价格下单的一个小栗子。栗子虽小,但它打通了整个CCXT的现货API。

# 加载ccxt模块
import ccxt
# 加载Key
exchange = ccxt.binance()
api_key = ""  # 币安的api key
secret_key = ""  # 币安的secret key
exchange.apiKey = api_key
exchange.secret = secret_key
symbol = 'BTC/USDT'
# 获取最新行情
orderbook = exchange.fetch_order_book(symbol)
orderprice = orderbook['asks'][0][0] if len(orderbook['asks']) > 0 else None
# 按照该行情价格下买单
amount = 1
exchange.createLimitBuyOrder(symbol, amount, orderprice)

值得一提的是,CCXT交易现货方便之处就在于,如果上述代码,我们不交易币安而是交易其他任何一个CCXT支持的现货交易所,我们只需要将exchange = ccxt.binance()语句ccxt.后面的交易所名称,换成其他交易所,而不改变其他任何代码,就能实现不同交易所交易的无缝切换了。CCXT交易多交易所现货的小技能,你Get到了吗