Hedge-Strategie-Design-Forschung & Beispiel für offene Spot- und Futures-Orders
Schriftsteller:- Ich bin ein Idiot., Erstellt: 2022-04-08 14:16:50, Aktualisiert: 2022-04-08 16:21:48Hedge-Strategie-Design-Forschung & Beispiel für offene Spot- und Futures-Orders
Für eine lange Zeit, Futures und Spot-Hedge ist im Allgemeinen entworfen, um den Preis-Spread zu erkennen, und nehmen Aufträge zur Absicherung, wenn der Preis-Spread erfüllt ist. Kann eine ausstehende Order-Hedge entworfen werden? Die Antwort ist ja. Heute bringe ich den Lesern eine Design-Idee und Code-Prototyp für ausstehende Order-Hedge.
Überlegungen zur Sicherung von ausstehenden Aufträgen
In verschiedenen Märkten derselben oder derselben Art von Gegenständen entstehen Möglichkeiten für die Absicherung, wenn es einen großen Unterschied zwischen den Kauf- und Verkaufsaufträgen zwischen den beiden Märkten gibt. Im Allgemeinen nehmen wir die ausstehenden Aufträge, die den Preis-Spread erfüllen, und halten dann Absicherungspositionen. Daher gibt es zwei Zwecke der Absicherung. Die erste ist die Absicherung gegen Auftragspositionen, und die zweite ist es, sicherzustellen, dass der Preis-Spread zwischen Kauf- und Verkaufspositionen unsere Erwartungen maximal erfüllt. Der Vorteil des Handelns mit ausstehenden Aufträgen in dieser Hinsicht ist, dass die Gebühr niedriger ist. Der Nachteil ist, dass es nicht einfach ist, Aufträge auszuführen, und es ist einfacher, einzelne Positionsoptionen auszuführen.
Dann entwerfen wir die Handelsidee, die die gekaufte Bestellung im Kauf-Auftrag des Marktes A-Orderbuch und die verkaufte Bestellung im Verkaufs-Auftrag des Marktes B-Orderbuch abwartet und dann unser Konto ausstehende Aufträge erkennt und zum nächsten Schritt für die erkannten ausstehenden Auftragsausführungen übergeht. Zum Beispiel, wenn eine ausstehende Auftragsänderung erkannt wird, gleichzeitig die aktuellen Hedge-Positionen von Futures und Spot ausgleichen. Für die Überflutung der Futures und Spot-Positionen, offenen Kauf oder Schließen. Gemäß der Erhöhung der Hedging-Positionen, den Abstand zwischen der nächsten ausstehenden Bestellung auf dem Markt und der ersten Ebene des Marktes anpassen, allmählich absichern, um den größten Spread zu erhalten.
Absicherungslogik
Codeentwurf
Die Bemerkungen sind direkt in den Code geschrieben. Dieses Beispiel dient nur zur Designreferenz und wurde nur kurz auf dem OKEX V5 simulierten Bot getestet. Das Beispiel ist keine vollständige Strategie, daher verwenden Sie es nur zur Referenz.
// temporary parameters
var fuContractType = "quarter" // futures contract
var fuSymbol = "ETH_USDT" // futures trading pair
var spSymbol = "ETH_USDT" // spot trading pair
var minAmount = 0.1 // trading amount of each time, minimum trading amount, currency amount
var step = 40 // step length of spread
var buff = 5 // buffer spread
var balanceType = "open" // when the single-position execution is balanced, open buy or close
var depthManager = function(fuEx, spEx, fuCt, fuSymbol, spSymbol) {
var self = {}
self.fuExDepth = null
self.spExDepth = null
self.plusPrice = null
self.minusPrice = null
self.update = function() {
spEx.SetCurrency(spSymbol)
if (!IsVirtual()) {
fuEx.SetCurrency(fuSymbol)
}
fuEx.SetContractType(fuCt)
var fuRoutine = fuEx.Go("GetDepth")
var spRoutine = spEx.Go("GetDepth")
var fuDepth = fuRoutine.wait()
var spDepth = spRoutine.wait()
if (!fuDepth || !spDepth) {
return false
}
self.fuExDepth = fuDepth
self.spExDepth = spDepth
if (fuDepth.Bids.length == 0 || fuDepth.Asks.length == 0 || spDepth.Bids.length == 0 || spDepth.Asks.length == 0) {
return false
}
self.plusPrice = fuDepth.Bids[0].Price - spDepth.Asks[0].Price // futures Bid - spot Ask
self.minusPrice = fuDepth.Asks[0].Price - spDepth.Bids[0].Price // futures Ask - spot Bid
return true
}
self.getData = function() {
return {
"fuExDepth" : self.fuExDepth,
"spExDepth" : self.spExDepth,
"plusPrice" : self.plusPrice,
"minusPrice" : self.minusPrice
}
}
return self
}
var positionManager = function(fuEx, spEx, fuCt, fuSymbol, spSymbol, step, buffDiff, balanceType, initSpAcc) {
var self = {}
self.balanceType = balanceType
self.depth = null
self.level = 1
self.lastUpdateTs = 0
self.fuPos = []
self.spPos = []
self.initSpAcc = initSpAcc
self.spAcc = null
self.hedgePos = null
self.hedgePosPrice = 0
self.minAmount = 0.01
self.offset = ["", 0]
self.update = function() {
spEx.SetCurrency(spSymbol)
if (!IsVirtual()) {
fuEx.SetCurrency(fuSymbol)
}
fuEx.SetContractType(fuCt)
self.offset = ["", 0]
var fuRoutine = fuEx.Go("GetPosition")
var spRoutine = spEx.Go("GetAccount")
var fuPos = fuRoutine.wait()
var spAcc = spRoutine.wait()
if (!fuPos || !spAcc) {
return false
}
self.fuPos = fuPos
self.spAcc = spAcc
if (!self.initSpAcc) {
return false
}
self.spPos = (spAcc.Stocks + spAcc.FrozenStocks) - (self.initSpAcc.Stocks + self.initSpAcc.FrozenStocks) // the current one minus the initial one; if the result is a positive number, make long
// detect fuPos
if (fuPos.length > 1) {
return false
}
fuPosAmount = fuPos.length == 0 ? 0 : (fuPos[0].Type == PD_LONG ? fuPos[0].Amount : -fuPos[0].Amount)
if ((fuPosAmount > 0 && self.spPos > 0) || (fuPosAmount < 0 && self.spPos < 0)) {
return false
}
fuPosAmount = self.piece2Coin(fuPosAmount)
self.hedgePos = (fuPosAmount == 0 || self.spPos == 0) ? 0 : (fuPosAmount < 0 && self.spPos > 0 ? Math.min(Math.abs(fuPosAmount), Math.abs(self.spPos)) : -Math.min(Math.abs(fuPosAmount), Math.abs(self.spPos)))
var diffBalance = (spAcc.Balance + spAcc.FrozenBalance) - (self.initSpAcc.Balance + self.initSpAcc.FrozenBalance)
if (self.hedgePos == 0) {
self.hedgePosPrice = 0
} else {
self.hedgePosPrice = fuPos[0].Price - (Math.abs(diffBalance) / Math.abs(self.spPos))
}
self.offset[1] = fuPosAmount + self.spPos // positive number represents long position overflow; negative number represents short position overflow
if (fuPosAmount > 0 && self.spPos < 0) { // reverse arbitrage
self.offset[0] = "minus"
} else if (fuPosAmount < 0 && self.spPos > 0) {
self.offset[0] = "plus"
} else if (fuPosAmount == 0 && self.spPos < 0) {
self.offset[0] = "minus"
} else if (fuPosAmount > 0 && self.spPos == 0) {
self.offset[0] = "minus"
} else if (fuPosAmount == 0 && self.spPos > 0) {
self.offset[0] = "plus"
} else if (fuPosAmount < 0 && self.spPos == 0) {
self.offset[0] = "plus"
}
return true
}
self.getData = function() {
return {
"fuPos" : self.fuPos,
"spPos" : self.spPos,
"initSpAcc" : self.initSpAcc,
"spAcc" : self.spAcc,
"hedgePos" : self.hedgePos,
"hedgePosPrice" : self.hedgePosPrice,
}
}
self.keepBalance = function(depth) {
var fuDepth = depth.fuExDepth
var spDepth = depth.spExDepth
if (self.offset[0] == "plus") {
if (self.offset[1] >= self.minAmount) {
if (self.balanceType == "close") {
// the spot long position amount is large; close spot long positions
spEx.Sell(-1, self.offset[1])
} else if (self.balanceType == "open") {
// the spot long position amount is large; open futures short positions
fuEx.SetDirection("sell")
fuEx.Sell(-1, self.coin2Piece(Math.abs(self.offset[1])))
}
} else if (self.offset[1] <= -self.minAmount) {
if (self.balanceType == "close") {
// the futures short position amount is large; close futures short positions
fuEx.SetDirection("closesell")
fuEx.Buy(-1, self.coin2Piece(Math.abs(self.offset[1])))
} else if (self.balanceType == "open") {
// the futures short position amount is large; open spot long positions
spEx.Buy(-1, spDepth.Asks[0].Price * Math.abs(self.offset[1]))
}
}
return false
} else if (self.offset[0] == "minus") {
if (self.offset[1] >= self.minAmount) {
if (self.balanceType == "close") {
// the futures long position amount is large; close futures long positions
fuEx.SetDirection("closebuy")
fuEx.Sell(-1, self.coin2Piece(self.offset[1]))
} else if (self.balanceType == "open") {
// the futures long position amount is large; open spot short positions
spEx.Sell(-1, self.offset[1])
}
} else if (self.offset[1] <= -self.minAmount) {
if (self.balanceType == "close") {
// the spot short position amount is large; close spot short positions
spEx.Buy(-1, spDepth.Asks[0].Price * Math.abs(self.offset[1]))
} else if (self.balanceType == "open") {
// the spot short position amount is large; open futures long positions
fuEx.SetDirection("buy")
fuEx.Buy(-1, self.coin2Piece(Math.abs(self.offset[1])))
}
}
return false
}
return true
}
self.process = function(depthManager) {
var ts = new Date().getTime()
var depth = depthManager.getData()
var orders = self.getOrders()
if (!orders) {
return
}
self.depth = depth
var fuOrders = orders[0]
var spOrders = orders[1]
if (fuOrders.length == 0 && spOrders.length == 0) {
// reset level
if (self.hedgePos == 0) {
self.level = 1
} else {
self.level = Math.max(1, _N(self.hedgePos / self.minAmount, 0))
}
// limit the maximum position amount
if (Math.abs(self.hedgePos) > 1) {
return
}
// pend orders
var fuDepth = depth.fuExDepth
var spDepth = depth.spExDepth
self.update()
if (self.hedgePos >= 0 && fuDepth.Bids[0].Price - spDepth.Asks[0].Price > 0) { // positive arbitrage
var distance = (step * self.level - (fuDepth.Asks[0].Price - spDepth.Bids[0].Price)) / 2
fuEx.SetDirection("sell")
fuEx.Sell(fuDepth.Asks[0].Price + distance, self.coin2Piece(self.minAmount), fuDepth.Asks[0].Price, "pending order spread:", fuDepth.Asks[0].Price + distance - (spDepth.Bids[0].Price - distance))
spEx.Buy(spDepth.Bids[0].Price - distance, self.minAmount, spDepth.Bids[0].Price)
} else if (self.hedgePos <= 0 && spDepth.Bids[0].Price - fuDepth.Asks[0].Price > 0) { // reverse arbitrage
var distance = (step * self.level - (spDepth.Asks[0].Price - fuDepth.Bids[0].Price)) / 2
fuEx.SetDirection("buy")
fuEx.Buy(fuDepth.Bids[0].Price - distance, self.coin2Piece(self.minAmount), fuDepth.Bids[0].Price, "pending order spread:", spDepth.Asks[0].Price + distance - (fuDepth.Bids[0].Price - distance))
spEx.Sell(spDepth.Asks[0].Price + distance, self.minAmount, spDepth.Asks[0].Price)
}
} else if (fuOrders.length == 1 && spOrders.length == 1) {
var fuDepth = depth.fuExDepth
var spDepth = depth.spExDepth
// judge location
var isCancelAll = false
if (self.hedgePos >= 0 && fuDepth.Bids[0].Price - spDepth.Asks[0].Price > 0) { // positive arbitrage
var distance = (step * self.level - (fuDepth.Asks[0].Price - spDepth.Bids[0].Price)) / 2
if (Math.abs(fuOrders[0].Price - (fuDepth.Asks[0].Price + distance)) > buffDiff || Math.abs(spOrders[0].Price - (spDepth.Bids[0].Price - distance)) > buffDiff) {
isCancelAll = true
}
} else if (self.hedgePos <= 0 && spDepth.Bids[0].Price - fuDepth.Asks[0].Price > 0) { // reverse arbitrage
var distance = (step * self.level - (spDepth.Asks[0].Price - fuDepth.Bids[0].Price)) / 2
if (Math.abs(spOrders[0].Price - (spDepth.Asks[0].Price + distance)) > buffDiff || Math.abs(fuOrders[0].Price - (fuDepth.Bids[0].Price - distance)) > buffDiff) {
isCancelAll = true
}
} else {
isCancelAll = true
}
if (isCancelAll) {
self.cancelAll(fuEx, fuOrders)
self.cancelAll(spEx, spOrders)
self.lastUpdateTs = 0
}
} else {
self.cancelAll(fuEx, fuOrders)
self.cancelAll(spEx, spOrders)
self.lastUpdateTs = 0
}
if (ts - self.lastUpdateTs > 1000 * 60 * 2) {
self.update()
self.keepBalance(depth)
self.update()
self.lastUpdateTs = ts
}
LogStatus(_D()) // the status bar can be designed to export the data and the information that need to be observed
}
self.getOrders = function() {
spEx.SetCurrency(spSymbol)
if (!IsVirtual()) {
fuEx.SetCurrency(fuSymbol)
}
fuEx.SetContractType(fuCt)
var fuRoutine = fuEx.Go("GetOrders")
var spRoutine = spEx.Go("GetOrders")
var fuOrders = fuRoutine.wait()
var spOrders = spRoutine.wait()
if (!fuOrders || !spOrders) {
return false
}
return [fuOrders, spOrders]
}
// convert currency into contract amount
self.coin2Piece = function(amount) {
if (IsVirtual()) {
if (fuEx.GetName() == "Futures_Binance") {
return amount
} else if (fuEx.GetName() == "Futures_OKCoin") {
var price = (self.depth.fuExDepth.Bids[0].Price + self.depth.fuExDepth.Asks[0].Price) / 2
return _N(amount / (100 / price), 0)
} else {
throw "not support"
}
}
if (fuEx.GetName() == "Futures_OKCoin") {
if (fuEx.GetQuoteCurrency() == "USDT") {
return _N(amount * 10, 0)
} else if (fuEx.GetQuoteCurrency() == "USD") {
var price = (self.depth.fuExDepth.Bids[0].Price + self.depth.fuExDepth.Asks[0].Price) / 2
return _N(amount / (100 / price), 0)
} else {
throw "not support"
}
} else {
throw "not support"
}
}
// convert contract amount to currency
self.piece2Coin = function(amount) {
if (IsVirtual()) {
if (fuEx.GetName() == "Futures_Binance") {
return amount
} else if (fuEx.GetName() == "Futures_OKCoin") {
var price = (self.depth.fuExDepth.Bids[0].Price + self.depth.fuExDepth.Asks[0].Price) / 2
return amount * 100 / price
} else {
throw "not support"
}
}
if (fuEx.GetName() == "Futures_OKCoin") {
if (fuEx.GetQuoteCurrency() == "USDT") {
return amount * 0.1
} else if (fuEx.GetQuoteCurrency() == "USD") {
var price = (self.depth.fuExDepth.Bids[0].Price + self.depth.fuExDepth.Asks[0].Price) / 2
return amount * 100 / price
} else {
throw "not support"
}
} else {
throw "not support"
}
}
self.cancelAll = function(e, orders) {
var isFirst = true
while (true) {
Sleep(500)
if (orders && isFirst) {
isFirst = false
} else {
orders = e.GetOrders()
}
if (!orders) {
continue
} else {
for (var i = 0 ; i < orders.length ; i++) {
e.CancelOrder(orders[i].Id, orders[i])
}
}
if (orders.length == 0) {
break
}
}
}
self.CoverAll = function() {
// close all
// the one-click function of closing positions can be realized here
}
self.setMinAmount = function(minAmount) {
self.minAmount = minAmount
}
self.init = function() {
while(!self.spAcc) {
self.update()
Sleep(1000)
}
if (!self.initSpAcc) {
var positionManager_initSpAcc = _G("positionManager_initSpAcc")
if (!positionManager_initSpAcc) {
self.initSpAcc = self.spAcc
_G("positionManager_initSpAcc", self.initSpAcc)
} else {
self.initSpAcc = positionManager_initSpAcc
}
} else {
_G("positionManager_initSpAcc", self.initSpAcc)
}
// print the initial information
Log("self.initSpAcc:", self.initSpAcc.Balance, self.initSpAcc.FrozenBalance, self.initSpAcc.Stocks, self.initSpAcc.FrozenStocks)
}
self.init()
return self
}
function main() {
_G(null) // vacuum the persistent data
LogReset(1) // rest logs
// use the following code to switch to OKEX simulated bot
// exchanges[0].IO("simulate", true)
// exchanges[1].IO("simulate", true)
var dm = depthManager(exchanges[0], exchanges[1], fuContractType, fuSymbol, spSymbol)
var pm = positionManager(exchanges[0], exchanges[1], fuContractType, fuSymbol, spSymbol, step, buff, balanceType)
pm.setMinAmount(minAmount)
while (true) {
if (!dm.update()) {
Sleep(3000)
continue
}
var cmd = GetCommand()
if (cmd) {
// handle interaction
Log("interactive command:", cmd)
var arr = cmd.split(":")
if (arr[0] == "") {
pm.CoverAll()
}
}
pm.process(dm)
Sleep(5000)
}
}
Rücktestanalyse
Aus den Statistiken des Backtest-Systems geht hervor, dass das Futures-Plattformkonto 0,01666 ETH verlor und die Spotbörse einen Gewinn von 842,23758 USDT erzielte.-0.01666 * 4252 = -70.83832000000001Das Ergebnis plus der Spotgewinn ist insgesamt profitabel.
Dies ist jedoch nur ein Backtest, und detailliertere Probleme werden in einem echten Bot behandelt.
Mehr
- Löschen Sie alle noch ausstehenden Bestellungen in aktuellen Währungen
- Schnelle Einführung der FMZ Quant Trading Platform APP
- Realisieren Sie einen einfachen Auftragsüberwachungsbot von Cryptocurrency Spot
- Eine Plattform, die auf FMZ basiert.
- Kryptowährungs-Kontrakt einfacher Auftragsüberwachungsbot
- Wenn Sie mit getdepth die entsprechende Zeitschrift erhalten möchten
- Ignoriert, gelöst
- Die Frage nach dem Gesichtswert
- dYdX-Strategie-Entwurfsbeispiel
- Erste Erforschung der Anwendung von Python Crawler auf FMZ
Crawling Binance Ankündigungsinhalt - Aktuelle Situation und empfohlene Anwendung der Finanzierungsrate-Strategie
- Strategie für einen doppelten gleitenden Durchschnitts-Brechpunkt von Kryptowährungs-Futures (Teaching)
- Strategie für einen doppelten gleitenden Durchschnitt mit mehreren Symbolen (Teaching)
- Realisierung von Fisher Indicator in JavaScript und Plotting auf FMZ
- Treuhänder
- 2021 Kryptowährungs-TAQ-Überprüfung & Einfachste verpasste Strategie der 10-fachen Erhöhung
- Kryptowährungs-Futures Multi-Symbol ART-Strategie (Lehre)
- Aktualisieren! Kryptowährungs Futures Martingale Strategie
- Die Getrecords-Funktion kann keine K-Stringkarte in Sekunden erhalten
- Konstruktion eines FMZ-basierten Auftragsmanagementsystems (2)