En la carga de los recursos... Cargando...

Símbolos de financiación de múltiples hilos

El autor:El inventor de la cuantificación, Fecha: 2024-10-24 17:28:55
Las etiquetas:

Estrategia de recuperación y seguimiento de las tasas de financiación de futuros multiplataforma

Descripción:

Esta estrategia recupera y monitoriza las tasas de financiación en múltiples plataformas de futuros (por ejemplo, OKCoin, Binance, Bitget).

Características:

Apoyo para múltiples plataformas: Sincroniza las tasas de financiación de varias plataformas comerciales, cada una con retrasos de solicitud personalizados.
Recuperación específica del símbolo: Permite recuperar las tasas de financiación para pares comerciales específicos (por ejemplo, BTC/USDT, ETH/USDT).
Optimizado para diferentes plataformas: Distingue entre las plataformas que requieren iteración en mercados individuales (por ejemplo, OKCoin) y las que no lo hacen (por ejemplo, Binance).

El uso:

Puede ajustar la lista de plataformas, la lista de símbolos e intervalos de votación para adaptarse a sus requisitos comerciales específicos.


function startFundingWorker() {
    exchanges.forEach((_, pos) => {
        __Thread(function (pos) {
            let e = exchanges[pos]
            let eName = e.GetName()
            let delaySettings = {
                'Futures_OKCoin': 20,
                'Futures_Binance': 500,
            }
            let needInterate = ['Futures_OKCoin', 'Futures_Bitget','Futures_OKX', 'Futures_KuCoin', 'Futures_MEXC', 'Futures_Crypto', 'Futures_Deribit']
            let delay = function () {
                let n = delaySettings[eName]
                if (n) {
                    Sleep(n)
                }
            }
            let epoch = 60000*2;
            let ts = 0;
            let fundings = {}
            while (true) {
                let now = new Date().getTime()
                if (now - ts < epoch) {
                    Sleep(1000)
                    continue
                }
                let markets = e.GetMarkets()
                if (!markets) {
                    Sleep(1000)
                    continue
                }
                if (needInterate.includes(eName)) {
                    for (let symbol in markets) {
                        if (symbol.includes('.swap')) {
                            let ret = e.GetFundings(symbol)
                            if (ret) {
                                for (let r of ret) {
                                    fundings[r.Symbol] = r
                                }
                            }
                            delay();
                        }
                    }
                } else {
                    let zones = []
                    for (let symbol in markets) {
                        if (symbol.includes('.swap') && !zones.includes(markets[symbol].QuoteAsset)) {
                            zones.push(markets[symbol].QuoteAsset)
                            let ret = e.GetFundings(markets[symbol].QuoteAsset + '.swap')
                            if (ret) {
                                for (let r of ret) {
                                    fundings[r.Symbol] = r
                                }
                            }
                            delay();
                        }
                    }
                }
                ts = now
                __threadSetData(0, eName+"_funding", fundings)
            }
        }, pos)
    })
}

function getFundings(eName, symbols) {
    let fundings = __threadGetData(0, eName+"_funding")
    if (!fundings) {
        return null
    }

    if (typeof(symbols) === 'undefined') {
        return fundings
    }

    let ret = {}
    symbols.forEach((s) => {
        if (fundings[s]) {
            ret[s] = fundings[s]
        }
    })
    return ret
}

function main() {
    startFundingWorker()
    while (true) {
        exchanges.forEach((e) => {
            let eName = e.GetName()
            let fundings = getFundings(eName, ['BTC_USDT.swap', 'ETH_USDT.swap'])
            Log(eName, fundings)
        })
        Sleep(5000)
    }
}

Más.