Стратегия получения и мониторинга ставок финансирования фьючерсов на нескольких платформах
Дата создания:
2024-10-24 17:28:55
Последнее изменение:
2024-10-24 18:36:42
Копировать:
0
Количество просмотров:
887
QCoder
11
Подписаться
607
Подписчики
Стратегия получения и мониторинга ставок финансирования фьючерсов на нескольких платформах
описывать:
Эта стратегия используется для получения и мониторинга ставок финансирования с нескольких фьючерсных платформ, таких как OKCoin, Binance, Bitget и т. д. Опрашивайте рынки бессрочных контрактов различных бирж через параллельные потоки и получайте данные о ставках финансирования, используя при этом механизм задержки для оптимизации частоты запросов.
Функция:
- Поддержка нескольких платформ: Синхронизируйте ставки финансирования на нескольких биржах и установите разные задержки запросов для каждой из них.
- Получение конкретного символа：Поддерживает получение ставок финансирования для определенных торговых пар (например, BTC/USDT, ETH/USDT).
- Оптимизировано для разных платформ: Различайте платформы, которым не нужно опрашивать каждый рынок по отдельности (например, Binance), и платформы, которым необходимо охватить все рынки (например, OKCoin).
Как добраться:
Вы можете настроить список платформ, список символов и интервал опроса по мере необходимости в соответствии с вашими конкретными торговыми потребностями.
Исходный код стратегии
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)
}
}