huobitrade 0.4.3

huobi_api for python

火币API的Python版

• websocket封装成HBWebsocket类，用run开启连接线程
• HBWebsocket通过注册Handler的方式来处理数据，消息通过pub_msg来分发到个各topic下的Handler线程来处理
• restful api基本参照火币网的demo封装成HBRestAPI类
• 兼容win，mac，linux，python版本必须3.6或以上，因为使用了大量的f***
• 目前已经稳定使用，后续会基于框架提供如行情持久化，交易数据持久化等handler
• 暂时先不维护Restful API-Decoration版，所以火币API8月份之后的修改将会导致其失效，有需求的小伙伴可以issues一波，再考虑去维护吧！
• 有疑问或者需要支持和交流的小伙伴可以联系我， QQ：137150224

Notice

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

Lastest

• 增加了母子账户的api（transfer，get_aggregate_balance， get_sub_balance）
• 把private key修改回来，火币暂停推ecdsa加密方案，setKey时候让private_key默认为None就好了

Installation

pip install huobitrade

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. 有兴趣的小伙伴可以联系我

WebSocket API

from huobitrade.service import HBWebsocket

hb = HBWebsocket()  # 可以填入url参数，默认是https://api.huobi.br.com
hb.run()  # 开启websocket进程

# --------------------------------------------
hb.sub_kline('ethbtc', '1min')  # 订阅数据
@hb.register_handle_func('market.ethbtc.kline.1min')  # 注册一个处理函数，最好的处理方法应该是实现一个handler
def handle(msg):
    print('handle:', msg)

hb.unregister_handle_func(handle, 'market.ethbtc.kline.1min')  # 释放处理函数

# --------------------------------------------
# websocket请求数据是异步请求回调，所以先注册一个回调处理函数，再请求
@hb.register_onRsp('market.btcusdt.kline.1min')
def OnRsp_print(msg):
    print(msg)

hb.req_kline('btcusdt', '1min')
hb.unregister_onRsp('market.btcusdt.kline.1min')  # 注销某topic的请求回调处理

Restful API

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

from huobitrade.service import HBRestAPI
from huobitrade import setKey
# private_key = open('privatekey.pem').read()
private_key = '''-----BEGIN EC PRIVATE KEY-----
xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx
xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx
xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx
-----END EC PRIVATE KEY-----'''

setKey('your acess_key', 'you secret_key', private_key)  # setKey很重要，最好在引入其他模块之前先setKey，部分模块要基于密钥,private_key可以用上面两种其中一种
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', _async=True)
symbols = api.get_symbols(_async=True)
results = api.async_request([klines, symbols])
for r in results:
    print(r)

Restful API-Decoration （Experimental）

• 用装饰器来初始化回调处理函数

from huobitrade.service import HBRestAPI_DEC
from huobitrade import setKey

setKey('your acess_key', 'you secret_key')
api_dec = HBRestAPI_DEC()
@api_dec.get_kline('ethbtc', '1min')  # 装饰器初始化处理函数
def handle_func(msg):
    print('handle:', msg)

handle_func()  # __call__调用函数会请求并用handle_func做回调处理

Message Handler

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

from huobitrade.handler import BaseHandler
fromm huobitrade.util import handler_profiler

class MyHandler(BaseHandler):
    def __init__(self, topic, *args, **kwargs):
        BaseHandler.__init__(self, 'just Thread name', topic)

    @handler_profiler('profiler.csv')  #  可以加上这个装饰器来测试handle函数的执行性能,加参数会输出到单独文件
    def handle(self, topic, msg):  # 实现handle来处理websocket推送的msg
        print(topic, msg)


handler = MyHandler('market.ethbtc.kline.1min')  # topic为str或者list
handler.add_topic('market.ethbtc.kline.5min')  # 为handler增加处理topic(remove_topic来删除)
hb.register_handler(handler)  # 通过register来把handler注册到相应的topic

• 内置实现了一个mongodb的DBHandler

from huobitrade.handler import DBHandler
handler = DBHandler()  # topic为空的话，会对所有topic的msg做处理
hb.register_handler(handler)

Latest Message Handler

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

class MyLatestHandler(BaseHandler):
    def __init__(self, topic, *args, **kwargs):
        BaseHandler.__init__(self, 'just Thread name', topic, latest=True)

    @handler_profiler()  #  可以加上这个装饰器来测试handle函数的执行性能
    def handle(self, topic, msg):  # 实现handle来处理websocket推送的msg
        print(topic, msg)

HBData

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

from huobitrade import setKey
from huobitrade.datatype import HBMarket, HBAccount, HBMargin
setKey('acess_key', 'secret_key')
data = 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前面加'_', 后面加数量最大值为2000
data.omgeth.kline.latest
data.omgeth.kline.last_24_hour
data.omgeth.depth.step0  # step0,1,2,3,4,5
data.omgeth.ticker.latest  # 最新的一条tick
data.omgeth.ticker.last_20  # last_1至last_2000
data.all_24h_ohlc  # 当前所有交易对的ticker
account.Detail  # 所有账户明细
account.Pro_XXXXX_balance  # XXXX为account_id,某账户的结余
account.Pro_XXXXX_balance.update()  # 更新账户结余信息
account.Pro_XXXXX_order  # 某账户的订单类
account.Pro_XXXXX_order['order_id']  # 查询某order明细,或者用get方法
account.Pro_XXXXX_order.send(1, 'omgeth', 'buy-limit', 0.001666)  # 发送订单
account.Pro_XXXXX_trade.get_by_id('order_id')  # 某账户的成交类(即火币的matchresults),也可以直接索引
margin.transferIn('ethusdt', 'eth', 1)
ethusdt_margin_info = margin['ethusdt']  # 或者用getBalance
ethusdt_margin_info.balance  # ethusdt交易对的保证金结余信息

Extra

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