Get Hexun Futures Data Python Version
Shukuang wrote a js version of third-party data acquisition a long time ago. I followed his example and rewrote a python version. You can download it and introduce your own package on the cloud server, so that it can…
Shukuang wrote a js version of third-party data acquisition a long time ago. I followed his example and rewrote a python version. You can download it and introduce your own package on the cloud server, so that it can also be used during research. update 12.01 The Hexun interface has changed to include 60-minute and weekly line information. In the original version, selecting 1440 will get the 60-minute candlestick. This is fixed.
Source Python
#coding: utf-8
import urllib2 as url
import json
import time
def hxRecords(instrument,timeFrame=1,size=1,includeLastBar=True,to_df=True):
##Get real-time futures data from Hexun
pInst=instrument.lower()
if pInst[-4]!='1':
pInst=pInst[:-3]+'1'+pInst[-3:]
xchg=None
for i in instList:
if pInst[:-4] in i['inst']:
xchg=i['xchg']
if xchg is None:
print ("Error occurred when fetching candlestick: contract not found")
return None
tfs=[1,5,15,30,60,'D','W']
tf=None
for i in range(len(tfs)):
if timeFrame==tfs[i]:
tf=i
if tf is None:
print("An error occurred when obtaining the candlestick: The candlestick period is incorrect")
return None
now=time.localtime()
timestr=str(now.tm_year+1)+str(12)+str(31)+'000000'
resp='http://webftcn.hermes.hexun.com/shf/kline?code=' + xchg + pInst + '&start=' + timestr + '&number=-' + str(size) + '&type=' + str(tf)
try:
resp=url.urlopen(resp)
resp=resp.read()[1:-2]
resp=json.loads(resp)['Data']
except:
print 'Error occurred when fetching candlestick: incomplete JSON data'
return None
re=[]
pw=float(resp[4])
for i in resp[0]:
res=dict(Time=time.mktime(time.strptime(str(i[0]),'%Y%m%d%H%M%S'))*1000,Open=i[2]/pw,High=i[4]/pw
,Low=i[5]/pw,Close=i[3]/pw,Volume=i[6])
re.append(res)
if to_df:
re=pd.DataFrame(re)
col=[]
for i in re.columns:
if i is 'Time':
i='Date'
col.append(i.lower())
re.columns=col
re['date']=re['date'].map(ts_dt64)
return re
instList = [{
"xchg": "SHFE",
"inst": ["fu", "ru", "wr"]
}, {
"xchg": "SHFE2",
"inst": ["ag", "au"]
}, {
"xchg": "SHFE3",
"inst": ["al", "bu", "cu", "hc", "ni", "pb", "rb", "sn", "zn"]
}, {
"xchg": "CZCE",
"inst": ["cf", "fg", "lr", "ma", "oi", "pm", "ri", "rm", "rs", "sf", "sm", "sr", "ta", "wh", "zc"]
}, {
"xchg": "DCE",
"inst": ["a", "b", "bb", "c", "cs", "fb", "i", "j", "jd", "jm", "l", "m", "p", "pp", "v", "y"]
}]
def main():
Log(exchange.GetAccount())
Published by edwardgyw on the FMZ strategy square · last modified 2016-12-01. Collected in the Quant Trading Vault. Unvalidated research: re-test with your own data and costs before trusting it.
Build this with AgenKit
A spec is not a trading system. Paste this into your coding agent and AgenKit runs a specialist team — architecture, test-first build, risk gates, review — with paper trading on by default.
/agenkit build a production-grade trading bot with a backtest engine, risk controls and paper trading by default from strategies/Get-Hexun-Futures-Data-Python-Version.md- npx agenkit install engineering-kit in your project
- Paste the command into your agent and approve each phase
- Get tests, backtest, risk controls and a paper-trading switch
Understand it first
Before you run this, read the lesson behind the idea and how to backtest it honestly. Specs like this one are the survivors of an unknown number of trials; deflate their results accordingly.
Related specs
- Dynamic Balancing Strategy Python VersionPython · Other
- Exchange Wash Trading and Mutual BrushingPython · Other
- Leek Protection Program Tang Anqi Channel Position Balancing StrategyPython · Other
- Paul The Gambler Lévy Gold EditionPython · Other
- Porting OKCoin Leek Harvester Multi Variety Version Annotated Python VersionPython · Other
- Python Example Using asyncio http to Obtain Market DataPython · Other