এই কৌশলটি একাধিক ফিউচার প্ল্যাটফর্মগুলিতে (যেমন, ওকেকয়েন, বাইনান্স, বিটজেট) তহবিলের হারগুলি পুনরুদ্ধার করে এবং পর্যবেক্ষণ করে। এটি বিভিন্ন এক্সচেঞ্জের চিরস্থায়ী চুক্তি বাজারগুলি জরিপ করতে এবং অনুরোধের ফ্রিকোয়েন্সি অপ্টিমাইজ করার জন্য একটি বিলম্ব প্রক্রিয়া সহ তহবিলের হার ডেটা পুনরুদ্ধার করতে সমান্তরাল থ্রেড ব্যবহার করে।
আপনি আপনার নির্দিষ্ট ট্রেডিং প্রয়োজনীয়তা অনুসারে প্ল্যাটফর্ম তালিকা, প্রতীক তালিকা এবং পোলিং ব্যবধান সামঞ্জস্য করতে পারেন।
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)
}
}