huobitrade 0.5.6

火币API的Python版

• websocket封装成HBWebsocket类，用run开启连接线程
• HBWebsocket通过注册Handler的方式来处理数据，消息通过pub_msg来分发到个各topic下的Handler线程来处理
• 火币的鉴权WS是与普通WS独立的，所以同时使用需要开启两个WS
• restful api基本参照火币网的demo封装成HBRestAPI类
• 兼容win，mac，linux，python版本必须3.6或以上，因为使用了大量的f***
• 目前已经稳定使用，后续会基于框架提供如行情持久化，交易数据持久化等handler
• 有疑问或者需要支持和交流的小伙伴可以联系我， QQ：137150224
• 鉴于小伙伴数量也越来越多，所以建个小群：859745469 ， 方便大家交流

Notice

• 该封装的函数命名跟火币本身的请求命名表达不太一致
• 包含open, close, high, low的数据命名是kline（其中部分有ask和bid，都纳入这类命名）
• 当且仅当数据只有一条逐笔tick（没有ohlc），命名是ticker
• 深度数据则命名为depth

Lastest

• 合约与现货已经进行了部分测试，保证可用性
• 优化相关datatype

• HuoBi Trading
  • 1. Installation
  • 2. Usage
    • 2.1 huobitrade CLI Tool
    • 2.2.1 WebSocket API
    • 2.2.2 Auth WebSocket API
    • 2.3 Restful API
    • 2.4 Message Handler
    • 2.5 Latest Message Handler
    • 2.6 HBData
  • 3. Extra

1. Installation

pip install huobitrade

2. Usage

• 实现长连订阅策略最核心的部分是实现handler里面的handle函数
  1. 通过HBWebsocket实例的sub开头的函数订阅需要的topic
  2. 通过继承BaseHandler的实例的初始化或者add_topic来增加对相关topic，实现handle函数来处理相关topic的消息
  3. 通过HBWebsocket实例的register_handler来注册handler
  4. handler初始化中有个latest，建议使用depth或者ticker数据来做处理，且策略性能不高的时候使用它
• 基于websocket的接口都是用异步回调的方式来处理
  1. 首先需要用HBWebsocket的装饰器register_onRsp来绑定实现一个处理相关的topic消息的函数
  2. 再用req开头的函数来请求相关topic数据，回调的数据将会交给回调函数处理
• 交易相关的都是用的restful api（因为火币还没推出websocket的交易接口）
  1. setKey是必要的，如果需要用到交易相关请求的话，只是请求行情的话可以不设。
  2. HBRestAPI是单例类，所以多次初始化也木有啥大问题，如在handler里面初始化
  3. 每个请求都有一个_async参数来提供异步请求，建议尽量使用它，具体用法是先初始化数个请求到一个list，再用async_request一次性向服务器发起请求
  4. 子账户体系没用过，可能会有问题，有bug欢迎pr
• 另外还提供了几个简单易用的封装类
  1. HBMarket, HBAccount, HBMargin分别是行情，账户和借贷账户类，里面提供了大部分属性调用请求，均基于HBRestAPI
  2. 一般情景下应该是可以替代HBRestAPI的使用的
• 最后还提供了数个运营管理的工具
  1. 微信推送handler，可以实现一些交易信息推送之类的，但是建议朋友们慎用，因为鄙人有试过一天推送几千条信息被封禁了半个月微信web端登陆的经历
  2. rpc模块，具体用法就不细说了，懂的应该都懂的，看下源码就知道咋用啦
• 最后的最后，其实基于这个项目，还有附带的另外一个可视化web的项目没有放出来
  1. 基于flask写的一个用于查询当日成交明细和成交分布图，很丑很简陋
  2. 有兴趣的小伙伴可以联系我

2.1 huobitrade CLI Tool

• huobitrade run -f strategy.py -a access-key -s secret-key用于启用一个基本简单的策略，其中strategy里应该可以包含一个init和handle_func用于初始化或处理相关topic.连接和鉴权成功后，会进入交互环境，提供6个命名空间来进行交互，包括restapiwsauth_wsaccountdatamargin,分别都是huobitrade几个主要类的实例huobi
• huobitrade test_conn用于测试是否可以正常连接， huobitrade doc打开huobitrade文档
• huobitrade --help通过该命令获取帮助

2.2.1 WebSocket API

fromhuobitrade.serviceimportHBWebsockethb=HBWebsocket()# 可以填入url参数，默认是api.huobi.br.com@hb.after_open# 使用装饰器注册函数，当ws连接之后会调用函数，可以实现订阅之类的defsub_depth():hb.sub_depth('ethbtc')hb.run()# 开启websocket进程# --------------------------------------------hb.sub_kline('ethbtc','1min')# 订阅数据@hb.register_handle_func('market.ethbtc.kline.1min')# 注册一个处理函数，最好的处理方法应该是实现一个handlerdefhandle(msg):print('handle:',msg)hb.unregister_handle_func(handle,'market.ethbtc.kline.1min')# 释放处理函数# --------------------------------------------# websocket请求数据是异步请求回调，所以先注册一个回调处理函数，再请求@hb.register_onRsp('market.btcusdt.kline.1min')defOnRsp_print(msg):print(msg)hb.req_kline('btcusdt','1min')hb.unregister_onRsp('market.btcusdt.kline.1min')# 注销某topic的请求回调处理

2.2.2 Auth WebSocket API

fromhuobitradeimportsetKeyfromhuobitrade.serviceimportHBWebsocketsetKey('your acess_key','you secret_key')hb=HBWebsocket(auth=True)# 可以填入url参数，默认是api.huobi.br.com@hb.after_auth# 会再鉴权成功通过之后自动调用defsub_accounts():hb.sub_accounts()hb.run()# 开启websocket进程@hb.register_handle_func('accounts')# 注册一个处理函数，最好的处理方法应该是实现一个handlerdefauth_handle(msg):print('auth_handle:',msg)

2.3 Restful API

• restapi需要先用setKey设置密钥
• 默认交易和行情url都是https://api.huobi.br.com （调试用）,实盘要用from huobitrade import setUrl设置url

fromhuobitrade.serviceimportHBRestAPIfromhuobitradeimportsetKey# setUrl('', '')setKey('your acess_key','you secret_key')# setKey很重要，最好在引入其他模块之前先setKey，鉴权ws和restapi的部分函数是基于密钥api=HBRestAPI(get_acc=True)# get_acc参数默认为False,初始化不会取得账户ID，需要ID的函数无法使用.也可用api.set_acc_id('you_account_id')print(api.get_timestamp())api=HBRestAPI(get_acc=True)# 异步请求klines=api.get_kline('omgeth','1min',_async=True)symbols=api.get_symbols(_async=True)results=api.async_request([klines,symbols])forrinresults:print(r)

2.4 Message Handler

• handler是用来处理websocket的原始返回消息的，通过继承basehandler实现handle函数以及注册进HBWebsocket相关的topic来使用

fromhuobitrade.handlerimportBaseHandlerfromhuobitrade.utilsimporthandler_profilerfromhuobitradeimportsetKeyfromhuobitrade.serviceimportHBWebsocketsetKey('your acess_key','you secret_key')hb=HBWebsocket(auth=True)# 可以填入url参数，默认是api.huobi.br.comclassMyHandler(BaseHandler):def__init__(self,topic,*args,**kwargs):BaseHandler.__init__(self,'just Thread name',topic)@handler_profiler('profiler.csv')#  可以加上这个装饰器来测试handle函数的执行性能,加参数会输出到单独文件defhandle(self,topic,msg):# 实现handle来处理websocket推送的msgprint(topic,msg)handler=MyHandler('market.ethbtc.kline.1min')# topic为str或者listhandler.add_topic('market.ethbtc.kline.5min')# 为handler增加处理topic(remove_topic来删除)hb.register_handler(handler)# 通过register来把handler注册到相应的topic

• 内置实现了一个mongodb的DBHandler

fromhuobitrade.handlerimportDBHandlerfromhuobitradeimportsetKeyfromhuobitrade.serviceimportHBWebsocketsetKey('your acess_key','you secret_key')hb=HBWebsocket(auth=True)# 可以填入url参数，默认是api.huobi.br.comhandler=DBHandler()# topic为空的话，会对所有topic的msg做处理hb.register_handler(handler)

2.5 Latest Message Handler

• 基于handler函数根据策略复杂度和性能的的不同造成对message的处理时间不一样，可能造成快生产慢消费的情况，增加lastest参数，每次都是handle最新的message

fromhuobitrade.handlerimportBaseHandlerfromhuobitrade.utilsimporthandler_profilerclassMyLatestHandler(BaseHandler):def__init__(self,topic,*args,**kwargs):BaseHandler.__init__(self,'just Thread name',topic,latest=True)@handler_profiler()#  可以加上这个装饰器来测试handle函数的执行性能defhandle(self,topic,msg):# 实现handle来处理websocket推送的msgprint(topic,msg)

2.6 HBData

• 使用类似topic的方式来取数据,topic的表达方式与火币有不同

fromhuobitradeimportsetKeysetKey('acess_key','secret_key')fromhuobitrade.datatypeimportHBMarket,HBAccount,HBMargindata=HBMarket()# 行情接口类account=HBAccount()# 交易接口类margin=HBMargin()# 借贷接口类data.omgeth# <Symbol:omgeth-{'base-currency': 'omg', 'quote-currency': 'eth', 'price-precision': 6, 'amount-precision': 4, 'symbol-partition': 'main'}>data.omgeth.kline# <<class 'huobitrade.datatype.HBKline'> for omgeth>data.omgeth.depth# <<class 'huobitrade.datatype.HBDepth'> for omgeth>data.omgeth.ticker# <<class 'huobitrade.datatype.HBTicker'> for omgeth>data.omgeth.kline._1min_200# period前面加'_', 后面加数量最大值为2000data.omgeth.kline.lastdata.omgeth.kline.last_24_hourdata.omgeth.depth.step0# step0,1,2,3,4,5data.omgeth.ticker.last# 最新的一条tickdata.omgeth.ticker.last_20# last_1至last_2000data.all_24h_kline# 当前所有交易对的tickeraccount.Detail# 所有账户明细account.balance_XXXX# XXXX为account_id,某账户的结余, 引用结余信息会自动更新account.order# 账户的订单类account.order['order_id']# 查询某order明细,或者用get方法account.order.send('account_id',1,'omgeth','buy-limit',0.001666)# 发送订单account.order.batchcancel(['order_id1','order_id2'])account.order+[1,'omgeth','buy-limit',0.001666]# 发送订单account.order+{'acc_id':'your_account_id','amount':1,'symbol':'omgeth','type':'buy-limit','price':0.001666}account.order-'order_id'# 取消订单account.order-['order_id1','order_id2']# 批量取消订单account.trade.get_by_id('order_id')# 某账户的成交类(即火币的matchresults),也可以直接索引margin.transferIn('ethusdt','eth',1)ethusdt_margin_info=margin['ethusdt']# 或者用getBalanceethusdt_margin_info.balance# ethusdt交易对的保证金结余信息

3. Extra

• 交易策略运营相关的模块，wechat推送，rpc远程订阅调用等 详见extra

标签：

• 项目

欢迎加入QQ群-->： 979659372

推荐PyPI第三方库

• indentutils

  处理缩进文本的包

• django-radio

  此应用程序提供了设置收音机的简单方法

• yerkes

  Altair中的交互式调色板。

• wraptools

  包装和分派功能的实用程序

• neptune-cli

  海王星客户端图书馆

• mac_alias

  从python生成/解析mac os别名记录

• satzreduktion

  使用ner工具进行集合约简

• DyBASE

  嵌入式oo数据库

• syszuxav

  ffmpeg的python绑定

• tensorflow-estimator

  张量流估计器。

• tweebot

  一个简单的twitter bot命令行工具和库

• large-image-source-mapnik

  用于大图像的mapnik/gdal tilesource

• elaphe

  使用barcode.ps和pil/枕头生成各种条形码

• kinto-algolia

  使用algolia索引和搜索记录。

• django-rest-eas

  django rest easy是drf的一个扩展，为序列化程序和视图提供qol改进。