hb_hq_api.py

#&#28779;&#24065;&#34892;&#24773;&#21151;&#33021;&#20989;&#25968;
import json,requests,urllib3,datetime;   import pandas as pd;  import numpy as np ; urllib3.disable_warnings()

huobi_domain='api.huobi.de.com'   #API&#22320;&#22336;   'api.huobi.pro'    api.huobi.be&#27809;&#26377;&#34987;&#22681;  api.huobi.de.com

class Context:   #&#26681;&#31867;
    def __init__(self):  
        self.current_dt=datetime.datetime.now()

# #1d:1&#22825;  4h:4&#23567;&#26102;   60m: 60&#20998;&#38047;    15m:15&#20998;&#38047;
def get_price(code, end_date=None, count=1,frequency='1d', fields=['close']):    
    code=code.replace('.','')
    frequency=frequency.replace('d','day').replace('m','min').replace('h','hour')
    url = f'https://{huobi_domain}/market/history/kline?period={frequency}&size={count}&symbol={code}'
    res = requests.get(url,verify=False).text  
    df=pd.DataFrame(json.loads(res)['data']);      df=df.iloc[::-1]     #&#25490;&#24207;&#32763;&#36716;
    df["time"] = pd.to_datetime(df["id"]+8*3600, unit='s')              #&#26102;&#38388;&#25139;&#36716;&#26102;&#38388;&#65292;&#21271;&#20140;&#26102;&#38388;+8&#23567;&#26102;
    df=df[['time','open','close','high','low','vol']]                   #&#26356;&#27491;&#25490;&#24207;
    df.set_index(["time"], inplace=True);     df.index.name=''          #&#22788;&#29702;&#32034;&#24341;   
    return df

def get_last_price(code):        #&#33719;&#21462;&#26576;&#21482;&#32929;&#31080;&#26368;&#26032;&#20215;&#26684;&#20989;&#25968;04-25
    return get_price(code,count=1,frequency='1m', fields=['close']).close[0]

def attribute_history(security, count, unit='1d', fields=['open', 'close', 'high', 'low', 'volume', 'money']):   #&#33719;&#21462;&#21382;&#21490;&#34892;&#24773;     
    return get_price(security = security, end_date = context.current_dt, frequency=unit, fields=fields, fq = fq, count = count)[:-1]            