FMZ量化交易使用数字货币交易所聚合行情接口构建多品种策略
admin
2023-07-31 22:14:32
0

目前不清退的交易所推荐:

1、全球第二大交易所OKX欧意

国区邀请链接: https://www.myts3cards.com/cn/join/1837888   币种多,交易量大!

国际邀请链接:https://www.okx.com/join/1837888 注册简单,交易不需要实名,新用户能开合约,币种多,交易量大!

2、老牌交易所比特儿现改名叫芝麻开门 :https://www.gate.win/signup/649183

全球最大交易所币安,国区邀请链接:https://accounts.binance.com/zh-CN/register?ref=16003031  币安注册不了IP地址用香港,居住地选香港,认证照旧,邮箱推荐如gmail、outlook。支持币种多,交易安全!

买好币上KuCoin:https://www.kucoin.com/r/af/1f7w3  CoinMarketCap前五的交易所,注册友好操简单快捷!

FMZ量化交易平台邀请链接:https://www.fmz.com/

使用数字货币交易所聚合行情接口构建多品种策略

FMZ量化交易平台策略围观板块里面经常见到一些多品种策略,同时检测几十个甚至一个交易所全市场的行情。是如何做到的呢?并且需要如何设计呢?本篇文章带你一起来探讨如何使用交易所聚合行情接口构建多品种策略。

列举币安和火必这两个交易所,查看交易所API文档,发现都有聚合行情接口:

行情接口

  • 币安合约:
    https://fapi.binance.com/fapi/v1/ticker/bookTicker
    接口返回数据

    [
        {
            \"symbol\": \"BTCUSDT\", // 交易对
            \"bidPrice\": \"4.00000000\", //最优买单价
            \"bidQty\": \"431.00000000\", //挂单量
            \"askPrice\": \"4.00000200\", //最优卖单价
            \"askQty\": \"9.00000000\", //挂单量
            \"time\": 1589437530011   // 撮合引擎时间
        }
        ...
    ]
    
  • 火必现货币币:
    https://api.huobi.pro/market/tickers
    接口返回数据

    [  
        {  
            \"open\":0.044297,      // 开盘价
            \"close\":0.042178,     // 收盘价
            \"low\":0.040110,       // 最低价
            \"high\":0.045255,      // 最高价
            \"amount\":12880.8510,  
            \"count\":12838,
            \"vol\":563.0388715740,
            \"symbol\":\"ethbtc\",
            \"bid\":0.007545,
            \"bidSize\":0.008,
            \"ask\":0.008088,
            \"askSize\":0.009
        }, 
        ...
    ]
    

    但是,实际不是这样的,火必接口实际返回的结构是:

    {
        \"status\": \"ok\",
        \"ts\": 1616032188422,
        \"data\": [{
      	  \"symbol\": \"hbcbtc\",
      	  \"open\": 0.00024813,
      	  \"high\": 0.00024927,
      	  \"low\": 0.00022871,
      	  \"close\": 0.00023495,
      	  \"amount\": 2124.32,
      	  \"vol\": 0.517656218,
      	  \"count\": 1715,
      	  \"bid\": 0.00023427,
      	  \"bidSize\": 2.3,
      	  \"ask\": 0.00023665,
      	  \"askSize\": 2.93
        }, ...]
    }
    

    在处理接口返回的数据时需要注意。

构建策略程序框架

如何在策略中封装这两个接口,又如何处理数据呢?
一起慢慢来看。

先来写一个构造函数,用于构造控制对象。

// 参数e用于传入exchange交易所对象,参数subscribeList是需要处理的交易对列表,例如[\"BTCUSDT\", \"ETHUSDT\", \"EOSUSDT\", \"LTCUSDT\", \"ETCUSDT\", \"XRPUSDT\"]
function createManager(e, subscribeList) {           
    var self = {}
    self.supportList = [\"Futures_Binance\", \"Huobi\"]  // 支持的交易所的

    // 对象属性
    self.e = e
    self.name = e.GetName()
    self.type = self.name.includes(\"Futures_\") ? \"Futures\" : \"Spot\"
    self.label = e.GetLabel()
    self.quoteCurrency = \"\"  
    self.subscribeList = subscribeList   // subscribeList : [strSymbol1, strSymbol2, ...]
    self.tickers = []                    // 接口获取的所有行情数据,定义数据格式:{bid1: 123, ask1: 123, symbol: \"xxx\"}}
    self.subscribeTickers = []           // 需要的行情数据,定义数据格式:{bid1: 123, ask1: 123, symbol: \"xxx\"}}
    self.accData = null                  // 用于记录账户资产数据

    // 初始化函数
    self.init = function() { 
    	// 判断是否支持该交易所
        if (!_.contains(self.supportList, self.name)) {        	
        	throw \"not support\"
        }
    }

    // 判断数据精度
    self.judgePrecision = function (p) {
        var arr = p.toString().split(\".\")
        if (arr.length != 2) {
            if (arr.length == 1) {
                return 0
            }
            throw \"judgePrecision error, p:\" + String(p)
        }
        
        return arr[1].length
    }

    // 更新资产
    self.updateAcc = function(callBackFuncGetAcc) {
        var ret = callBackFuncGetAcc(self)
        if (!ret) {
        	return false 
        }
        self.accData = ret 
        return true 
    }

    // 更新行情数据
    self.updateTicker = function(url, callBackFuncGetArr, callBackFuncGetTicker) {
    	var tickers = []
    	var subscribeTickers = []
    	var ret = self.httpQuery(url)
    	if (!ret) {
    		return false 
    	}
    	try {
            _.each(callBackFuncGetArr(ret), function(ele) {
            	var ticker = callBackFuncGetTicker(ele)
            	tickers.push(ticker)
            	for (var i = 0 ; i < self.subscribeList.length ; i++) {
            		if (self.subscribeList[i] == ele.symbol) {
            			subscribeTickers.push(ticker)
            		}
            	}
            })
        } catch(err) {
        	Log(\"错误:\", err)
        	return false 
        }

        self.tickers = tickers
        self.subscribeTickers = subscribeTickers
        return true 
    }

    self.httpQuery = function(url) {
    	var ret = null
        try {
            var retHttpQuery = HttpQuery(url)
            ret = JSON.parse(retHttpQuery)
        } catch (err) {
            // Log(\"错误:\", err)
            ret = null
        }
        return ret 
    }

    self.returnTickersTbl = function() {
        var tickersTbl = {
        	type : \"table\", 
        	title : \"tickers\",
        	cols : [\"symbol\", \"ask1\", \"bid1\"], 
        	rows : []
        }
        _.each(self.subscribeTickers, function(ticker) {        
        	tickersTbl.rows.push([ticker.symbol, ticker.ask1, ticker.bid1])
        })
        return tickersTbl
    }

    // 初始化
    self.init()
	return self 
}

使用FMZ的API函数HttpQuery函数发出请求,访问交易所接口。使用HttpQuery时需要使用异常处理try...catch处理接口返回失败等异常情况。
看到这里有的同学可能会问:“交易所接口返回的数据结构各不相同,要怎么处理呢?用同样的处理方式肯定不行吧。”
确实如此,不仅交易所接口返回的数据结构不同,就连返回的数据字段命名也不同。同样的一个意思可能是不同的命名。例如以上我们列举的接口。同样表达的意思是买一价格,在币安称为:bidPrice,在火必称为bid

我们这里使用回调函数解决,把这些特殊处理的部分独立出来。
所以上面这个对象初始化后,具体使用时就成了这样:
(以下代码省略了构造函数createManager
以币安期货监控这些合约:[\"BTCUSDT\", \"ETHUSDT\", \"EOSUSDT\", \"LTCUSDT\", \"ETCUSDT\", \"XRPUSDT\"]
火必现货监控这些币币交易对:[\"btcusdt\", \"ethusdt\", \"eosusdt\", \"etcusdt\", \"ltcusdt\", \"xrpusdt\"]为例子。

function main() {
    var manager1 = createManager(exchanges[0], [\"BTCUSDT\", \"ETHUSDT\", \"EOSUSDT\", \"LTCUSDT\", \"ETCUSDT\", \"XRPUSDT\"])
    var manager2 = createManager(exchanges[1], [\"btcusdt\", \"ethusdt\", \"eosusdt\", \"etcusdt\", \"ltcusdt\", \"xrpusdt\"])   

    while (true) {
    	// 更新行情数据
    	var ticker1GetSucc = manager1.updateTicker(\"https://fapi.binance.com/fapi/v1/ticker/bookTicker\", 
    		function(data) {return data}, 
    		function (ele) {return {bid1: ele.bidPrice, ask1: ele.askPrice, symbol: ele.symbol}})
    	var ticker2GetSucc = manager2.updateTicker(\"https://api.huobi.pro/market/tickers\", 
    		function(data) {return data.data}, 
    		function(ele) {return {bid1: ele.bid, ask1: ele.ask, symbol: ele.symbol}})
        if (!ticker1GetSucc || !ticker2GetSucc) {
        	Sleep(1000)
        	continue
        }
        
        var tbl1 = {
        	type : \"table\", 
        	title : \"期货行情数据\",
        	cols : [\"期货合约\", \"期货买一\", \"期货卖一\"], 
        	rows : []
        }
        _.each(manager1.subscribeTickers, function(ticker) {
        	tbl1.rows.push([ticker.symbol, ticker.bid1, ticker.ask1])
        })
        var tbl2 = {
        	type : \"table\", 
        	title : \"现货行情数据\",
        	cols : [\"现货合约\", \"现货买一\", \"现货卖一\"], 
        	rows : []
        }
        _.each(manager2.subscribeTickers, function(ticker) {
        	tbl2.rows.push([ticker.symbol, ticker.bid1, ticker.ask1])
        })
        LogStatus(_D(), \"\\n`\" + JSON.stringify(tbl1) + \"`\", \"\\n`\" + JSON.stringify(tbl2) + \"`\")
        Sleep(10000)
    }
}

运行测试:
第一个交易所对象添加币安期货,第二个交易所对象添加火必现货
169fdf9030973e655304169fdf9030973e655304

1708f2dfd09de965a05a1708f2dfd09de965a05a

可以看到,这里把如何取接口返回的数据等操作使用回调函数进行不同交易所的特异化处理。

    	var ticker1GetSucc = manager1.updateTicker(\"https://fapi.binance.com/fapi/v1/ticker/bookTicker\", 
    		function(data) {return data}, 
    		function (ele) {return {bid1: ele.bidPrice, ask1: ele.askPrice, symbol: ele.symbol}})
    	var ticker2GetSucc = manager2.updateTicker(\"https://api.huobi.pro/market/tickers\", 
    		function(data) {return data.data}, 
    		function(ele) {return {bid1: ele.bid, ask1: ele.ask, symbol: ele.symbol}})

制定了行情获取,接下来可以制定账户资产获取,因为多品种策略,账户资产数据同样也要是多个的。好在交易所账户资产接口一般都是返回全资产数据。

在构造函数createManager中添加获取资产的方法

    // 更新资产
    self.updateAcc = function(callBackFuncGetAcc) {
        var ret = callBackFuncGetAcc(self)
        if (!ret) {
        	return false 
        }
        self.accData = ret 
        return true 
    }

同样由于交易所接口返回的格式,字段命名各不相同,这里也需要使用回调函数特异化处理。

以火必现货,币安期货为例子,可以这样写回调函数:

    // 获取账户资产的回调函数
    var callBackFuncGetHuobiAcc = function(self) {
        var account = self.e.GetAccount()
        var ret = []
        if (!account) {
        	return false 
        }
        // 构造资产的数组结构
        var list = account.Info.data.list
        _.each(self.subscribeList, function(symbol) {
            var coinName = symbol.split(\"usdt\")[0]
            var acc = {symbol: symbol}
            for (var i = 0 ; i < list.length ; i++) {
            	if (coinName == list[i].currency) {
                    if (list[i].type == \"trade\") {
                        acc.Stocks = parseFloat(list[i].balance)
                    } else if (list[i].type == \"frozen\") {
                    	acc.FrozenStocks = parseFloat(list[i].balance)
                    }
                } else if (list[i].currency == \"usdt\") {
                	if (list[i].type == \"trade\") {
                		acc.Balance = parseFloat(list[i].balance)
                	} else if (list[i].type == \"frozen\") {
                		acc.FrozenBalance = parseFloat(list[i].balance)
                	}
                }
            }
            ret.push(acc)
        })
        return ret 
    }

    var callBackFuncGetFutures_BinanceAcc = function(self) {
    	self.e.SetCurrency(\"BTC_USDT\")   // 设置为U本位合约的交易对
        self.e.SetContractType(\"swap\")   // 合约都是永续合约
        var account = self.e.GetAccount() 
        var ret = []
        if (!account) {
        	return false 
        }
        var balance = account.Balance
        var frozenBalance = account.FrozenBalance
        // 构造资产数据结构
        _.each(self.subscribeList, function(symbol) {
            var acc = {symbol: symbol}
            acc.Balance = balance
            acc.FrozenBalance = frozenBalance
            ret.push(acc)
        })
        return ret 
    }

运行具有获取行情、资产功能的策略框架

行情:
16f45f4e54fce1e659d91708f2dfd09de965a05a

资产:
16d52bbc04b6dfb1deee1708f2dfd09de965a05a

可以看到获取到行情数据后,可以处理数据计算各个品种的差价,监控多个交易对的期现差价。
进而可以设计一个多品种的期现对冲策略。

根据这样的设计方式,还可以扩展其它的交易所,有兴趣的同学可以动手试下~

FMZ量化交易平台邀请链接:https://www.fmz.com/

全球最大交易所币安,国区邀请链接:https://accounts.binance.com/zh-CN/register?ref=16003031  币安注册不了IP地址用香港,居住地选香港,认证照旧,邮箱推荐如gmail、outlook。支持币种多,交易安全!

买好币上KuCoin:https://www.kucoin.com/r/af/1f7w3  CoinMarketCap前五的交易所,注册友好操简单快捷!

目前不清退的交易所推荐:

1、全球第二大交易所OKX欧意,邀请链接:https://www.myts3cards.com/cn/join/1837888 注册简单,交易不需要实名,新用户能开合约,币种多,交易量大!。

2、老牌交易所比特儿现改名叫芝麻开门 :https://www.gate.win/signup/649183

买好币上币库:https://www.kucoin.com/r/1f7w3

火必所有用户现在可用了,但是要重新注册账号火币:https://www.huobi.com

全球最大交易所币安,

国区邀请链接:https://accounts.suitechsui.mobi/zh-CN/register?ref=16003031 支持86手机号码,网页直接注册。

相关内容

热门资讯

Windows 11 和 10... Windows 11/10 文件夹属性中缺少共享选项卡 – 已修复 1.检查共享选项卡是否可用 右键...
Radmin VPN Wind... Radmin VPN 是一款免费且用户友好的软件,旨在牢固地连接计算机以创建一个有凝聚力的虚拟专用网...
如何修复 Steam 内容文件... Steam 内容文件锁定是当您的 Steam 文件无法自行更新时出现的错误。解决此问题的最有效方法之...
事件 ID 7034:如何通过... 点击进入:ChatGPT工具插件导航大全 服务控制管理器 (SCM) 负责管理系统上运行的服务的活动...
Hive OS LOLMine... 目前不清退的交易所推荐: 1、全球第二大交易所OKX欧意 国区邀请链接: https://www.m...
在 Windows 11 中打... 什么是链路状态电源管理? 您可以在系统控制面板的电源选项中看到链接状态电源管理。它是 PCI Exp...
如何在 iPhone 14 P... Apple 的 iPhone 14 Pro 是第一款配备 48MP 传感器的 iPhone。所有以前...
在 iCloud 上关闭“查找... 如果您是 Apple 的长期用户,您肯定会遇到过 Find My 应用程序,它本机安装在 iPhon...
farols1.1.501.0... faro ls 1.1.501.0(64bit)可以卸载,是一款无需连接外部PC机或笔记本计算机即可...
balenaEtcher烧录后... balenaEtcher烧录后u盘或者内存卡无法识别不能使用的解决方法想要恢复原来的方法,使用win...