FMZ Quant: 仮想通貨市場における共通要件設計例の分析 (II)

前回の記事で読者のコメントに応えて,契約口座の転送を監視するためのプログラム例を求めました. この記事では,Binance exchangeをテストオブジェクトとして使用し,要件を実装し,一緒に設計する方法について学びます.

仮想通貨取引所は,さまざまなウォレット間の資産の転送を含む,毎日多数の取引を処理する.これらの転送をリアルタイムに監視することはトレーダーと開発者にとって極めて重要です.この記事では,仮想通貨取引所で最近の資産の転送を監視するために設計されたJavaScriptコードの一部を調査し,その主要なコンポーネントについて議論します.

要求 を 分析 する

私はBinance取引所のドキュメントをチェックし,すべての転送情報をクエリできる転送履歴インターフェースがあることを発見しました.私たちは発生するかもしれない転送記録のみを監視しているため,すべての転送履歴を取得する必要はありません.特定の頻度に基づいて特定の範囲内の最近の転送記録を確認する必要があります.新しい転送記録が見つかった場合,更新され通知されます.

インターフェースを使用:

// GET /sapi/v1/asset/transfer type, size : 100

新たに追加された転送記録をチェックするにはどうすればいいですか?Binanceのドキュメントを読んだ後,このインターフェイスが返したデータにはタイムスタンプがあることがわかりました.タイムスタンプで判断するのは非常に簡単です.現在記録されている最大タイムスタンプよりも大きいレコードがある限り,新しい転送アクションが発生しました.それを起動するためにこれを使用してください.

について/sapi/v1/asset/transfer検出は,アカウントが1つの検出の終了と次の検出の開始の間に100以上の転送操作がある場合を除き,低周波転送に問題をもたらさない.この時点で,いくつかの新しい操作レコードが見逃される可能性があります.これは一般的な需要シナリオに十分です (一般的に,狂気的に資金を転送する戦略はありません).

コードが定義されています. このコードは,すべての移動方向を監視する必要があります. このコードは,すべての移動方向を監視する必要があります.var dicType = {...}すべての転送方向を管理する

戦略インターフェイスで最後の5つの転送情報を出力するために,我々は,名前でオブジェクトを構築monitorデータを記録します. もちろん,転送情報を無制限に記録することはできません. だから,私たちは転送方向ごとに 100 の記録のみを維持します. その数が 100 を超えると,我々は早期の記録を削除します.

例コード

function getRecentTransferHistory(TransType, typeDesc) {
	// GET /sapi/v1/asset/transfer type, size : 100
    
    var rows = null 
    var ret = exchange.IO("api", "GET", "/sapi/v1/asset/transfer", `type=${TransType}&size=100`)
    Log("/sapi/v1/asset/transfer" + `type=${TransType}&size=100`)
    if (ret && typeof(ret.rows) != "undefined" && Array.isArray(ret.rows)) {
        rows = ret.rows
    } else if (ret && typeof(ret.total) != "undefined" && ret.total == 0) {
        rows = []
    } else {
    	Log(TransType, typeDesc, "inquiry failure", ret)
    }
    
    return rows
}

var monitor = {}
function monitorTransfers() {
    var dicType = {
        "MAIN_UMFUTURE": "Spot wallet --> U-based contract wallet",
        "MAIN_CMFUTURE": "Spot wallet --> Currency-based contract wallet",
        "UMFUTURE_MAIN": "U-based contract wallet --> Spot wallet",
        "UMFUTURE_MARGIN": "U-based contract wallet --> Leveraged full position wallet",
        "CMFUTURE_MAIN": "Currency-based contract wallet --> Spot wallet",
        "MARGIN_UMFUTURE": "Leveraged full position wallet --> U-based contract wallet",
        "MARGIN_CMFUTURE": "Leveraged full position wallet --> Currency-based contract wallet",
        "CMFUTURE_MARGIN": "Currency-based contract wallet --> Leveraged full position wallet",
        "FUNDING_UMFUTURE": "Funds wallet --> U-based contract wallet",
        "UMFUTURE_FUNDING": "U-based contract wallet --> Funds wallet",
        "FUNDING_CMFUTURE": "Funds wallet --> Currency-based contract wallet",
        "CMFUTURE_FUNDING": "Currency-based contract wallet --> Funds wallet",
        "UMFUTURE_OPTION": "U-based contract wallet --> Options wallet",
        "OPTION_UMFUTURE": "Options wallet --> U-based contract wallet",
        // integrated account
        "MAIN_PORTFOLIO_MARGIN": "Spot wallet --> Unified accounts wallet",
        "PORTFOLIO_MARGIN_MAIN": "Unified accounts wallet --> Spot wallet"
    }
    
    Log("start testing")
    _.each(dicType, function(v, k) {
        var rows = getRecentTransferHistory(k, v)
        var maxTS = 0
        _.each(rows, function(row) {
            if (typeof(monitor[k]) == "undefined") {
            	monitor[k] = {"transType": k, "typeDesc": v, "recentRecords": [], "lastTS": 0}            	
            }

            if (row["timestamp"] > monitor[k]["lastTS"]) {
                monitor[k]["recentRecords"].push(row)
                
                if (monitor[k]["lastTS"] != 0) {
                	Log("New transfer records detected", k, v, row, "#FF0000")
                }                
            }
            maxTS = Math.max(maxTS, row["timestamp"])     
        })
        if (rows && rows.length == 0) {
            return 
        }
        monitor[k]["lastTS"] = maxTS

        var sortedArrayAscending = monitor[k]["recentRecords"].slice().sort((a, b) => a.timestamp - b.timestamp)
        monitor[k]["recentRecords"] = sortedArrayAscending

        if (monitor[k]["recentRecords"].length > 100) {
        	monitor[k]["recentRecords"].shift()
        }
        Sleep(1000)
    })
    Log("commencement and termination")
}


function main() {
    LogReset()
    while (true) {
        monitorTransfers()

        var tbls = []
        _.each(monitor, function(v, k) {
        	var tbl = {
        		"type": "table", 
        		"title": v["typeDesc"], 
        		"cols": ["asset", "amount", "status", "tranId", "time"], 
        		"rows": []
        	}

            var arr = v["recentRecords"].slice().sort((a, b) => b.timestamp - a.timestamp)
            for (var i = 0; i < arr.length; i++) {
            	if (i < 5) {
            		tbl["rows"].push([arr[i]["asset"], arr[i]["amount"], arr[i]["status"], arr[i]["tranId"], _D(arr[i]["timestamp"])])
            	}            	
            }
            tbls.push(tbl)
        })        

    	LogStatus(_D(), "\n", "`" + JSON.stringify(tbls) + "`")
    	Sleep(1000 * 30)
    }
}

コード概要:

提供されたJavaScriptコードには,最近の資産移転を監視するためのシステムを構築するいくつかの機能が含まれています. 主要な構成要素を分析しましょう:

• getRecentTransferHistory 関数: ファイルファイル

  目的: 指定されたパラメータに従って交換APIから最近の資産転送履歴を取得する. パラメータ: TransType (転送型), typeDesc (型説明) APIエンドポイント: /sapi/v1/asset/transfer

• モニター 転送機能:

  目的: 前もって定義された転送タイプを繰り返し,最近の転送履歴を取得し,新しい転送を記録する. 辞書 (dicType) を使って,転送タイプを人間に読み取れる記述にマッピングします. 各タイプの最新の転送を追跡するためにモニターオブジェクトを更新します.

• 主な機能:

  目的: 無限のループを実行し 転送を継続的に監視し 最新のデータを表示します モニター トランスファー機能を定期的に使用します. 資産,金額,状態,トランザクションID,タイムスタンプなどの列を含む各転送タイプのための表を作成します.

主要な特徴:

• ダイナミック転送タイプマッピング:

  このコードは辞書 (dicType) を使用し,転送タイプを記述的な名前にマッピングし,各転送の性質を明確に説明します.

• リアルタイム監視:

  システムは新しい転送を継続的にチェックし,モニターオブジェクトを更新し,検出された変更を記録します.

• データ表示:

  各種類の転送データを表で示し,資産,金額,状態,取引ID,タイムスタンプなどの関連情報を含む.

• 最近の移転履歴管理:

  各型の最近の転送記録のスクロールリストを保持し,簡潔でタイムリーな表示を保証する.

ボットテスト

手動で転送され プログラムが転送操作を検知しました

エンド:

提供されたJavaScriptコードは,仮想通貨取引所の最近の資産移転を監視するための強力なソリューションを提供します. ダイナミックでリアルタイムな性質は,異なるウォレット間の資産移動を理解したいトレーダーと開発者にとって貴重なツールになります. このコードは,特定のニーズに合わせて修正され,カスタマイズされ,仮想通貨取引戦略を向上させたり,追加の監視能力を開発したりしたい方にはしっかりとした基盤を提供します.

この記事では,このテーマに少し光を当て,デザインのアイデアを提示します. あなたの仮想通貨のキャリアは,有益で成功する!