FMZプラットフォームの外部信号受信に関する探究:拡張API vs 戦略内蔵HTTPサービス

前言

プラットフォーム文庫には,プラットフォームの拡張APIインターフェースを使用したJavaScript言語の内蔵HTTPサービス機能がサポートされていないときに,戦略の外部のシステムからの信号駆動取引を可能にする,リンクするTrading View webhookに関するいくつかの記事があります:CommandRobotFMZは,外部信号のhttp/https要求をFMZプラットフォームに送信し,プラットフォームは信号を転送し,戦略インタラクションメッセージ通知として戦略プログラムに通知します.

プラットフォームが進化し,更新され,アップグレードされ,多くの機能が更新され,外部信号を受信する新しいオプションも追加されました. 各種オプションにはそれぞれの利点があります.

FMZプラットフォームでAPIを拡張する

この方法で外部システムを接続する利点としては,比較的シンプルで,セキュリティが高く,プラットフォームに依存する拡張APIインターフェイスが安定している.

外部からの信号を受け取るプロセス:

外部システム (Trading View webhook) >FMZ拡張APIサービス >戦略実盤

1, 外部システム (Trading View webhook):例えば,Trading View上で実行されているPINEスクリプトは,アラームを設定し,起動すると,設定されたwebhook urlアドレスにHTTPリクエストを送信し,信号として送信します. 2. FMZ拡張APIサービス:このインターフェースにアクセスした後に,プラットフォームは情報を転送し,戦略実体盤にインタラクティブメッセージとして送信します. 3. ポリシーリアルディスク: ポリシーリアルディスクでは,GetCommand関数でインタラクションメッセージを盗聴し,メッセージの検出後に既定操作を実行するように設計できます.

サービス受信信号を直接作成する内蔵Httpサービスを使用するよりも,中間 (プラットフォーム間切り) のステップが1つ増えた.

策はHttpサービス内蔵

プラットフォームはJavaScript言語の内蔵Httpサービス機能をサポートしているため,外部信号を傍受する並行サービスが直接作成できます.利点としては,作成されたHttpサービスは単一のスレッドであり,主関数の論理に影響を与えません.GetCommand関数と同様に,メッセージを傍受し,外部信号を直接傍受することができます.拡張APIプログラムを使用するよりも,中間回路を省略します.

外部からの信号を受け取るプロセス:

外部システム (Trading View webhook) >戦略実盤

外部システム (Trading View webhook):例えば,Trading View上で実行されているPINEスクリプトは,アラームを設定し,トリガーされたときに,設定されたwebhook urlアドレスにHTTPリクエストを送信し,信号として送信します. 2, 戦略実用ディスク: 戦略は,直接外部信号を受信するHttpサービスを同時に実行します.

このプログラムはステップを省きますが,安全性を高めるため,httpsサービスを設定するのが良いです. 拡張APIを使用するプログラムよりも少し面倒です.

テストコード

2つのプログラムをテストする.次のポリシーは,各ラウンドをループして,10回のHttp/Httpsリクエストを送信し,外部信号を模倣する.次に,戦略は"インタラクティブメッセージ"と"Httpサービススレッドが送信するメッセージ"を監視する.そして,戦略プログラムは,外部信号メッセージと受信された信号を1つずつマッチし,信号損失がないかどうかを検知し,計算時間を消費します.

var httpUrl = "http://123.123.123.123:8088/CommandRobot"
var accessKey = ""
var secretKey = ""

function serverFunc(ctx) {
    var path = ctx.path()
    if (path == "/CommandRobot") {
        var body = ctx.body()
        threading.mainThread().postMessage(body)
        ctx.write("OK")
        // 200
    } else {
        ctx.setStatus(404)
    }
}

function createMsgTester(accessKey, secretKey, httpUrl) {
    var tester = {}
    
    tester.currentRobotId = _G()
    tester.arrSendMsgByAPI = []
    tester.arrSendMsgByHttp = []
    tester.arrEchoMsgByAPI = []
    tester.arrEchoMsgByHttp = []
    tester.idByAPI = 0
    tester.idByHttp = 0

    var sendMsgByAPI = function(msgByAPI, robotId, accessKey, secretKey) {
        var headers = {
            "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_9_3) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/35.0.1916.153 Safari/537.36",
            "Content-Type": "application/json"
        }
        HttpQuery(`https://www.fmz.com/api/v1?access_key=${accessKey}&secret_key=${secretKey}&method=CommandRobot&args=[${robotId},+""]`, {"method": "POST", "body": JSON.stringify(msgByAPI), "headers": headers})
    }

    var sendMsgByHttp = function(msgByHttp, httpUrl) {
        HttpQuery(httpUrl, {"method": "POST", "body": JSON.stringify(msgByHttp)})
    }

    tester.run = function() {
        var robotId = tester.currentRobotId

        for (var i = 0; i < 10; i++) {
            var msgByAPI = {"ts": new Date().getTime(), "id": tester.idByAPI, "way": "ByAPI"}            
            tester.arrSendMsgByAPI.push(msgByAPI)
            tester.idByAPI++
            threading.Thread(sendMsgByAPI, msgByAPI, robotId, accessKey, secretKey)

            var msgByHttp = {"ts": new Date().getTime(), "id": tester.idByHttp, "way": "ByHttp"}
            tester.arrSendMsgByHttp.push(msgByHttp)
            tester.idByHttp++
            threading.Thread(sendMsgByHttp, msgByHttp, httpUrl)
        }
    }

    tester.getEcho =function(msg) {
        if (msg["way"] == "ByAPI") {
            tester.arrEchoMsgByAPI.push(msg)
        } else {
            tester.arrEchoMsgByHttp.push(msg)
        }
    }

    tester.deal = function() {
        var tbls = []
        for (var pair of [[tester.arrEchoMsgByHttp, tester.arrSendMsgByHttp, "ByHttp"], [tester.arrEchoMsgByAPI, tester.arrSendMsgByAPI, "ByAPI"]]) {
            var receivedMessages = pair[0]
            var sentMessages = pair[1]
            var testType = pair[2]

            var receivedMap = new Map()
            receivedMessages.forEach(message => {
                receivedMap.set(message["id"], message)
            })
            
            var matchedPairs = []
            var timeDifferences = []
            for (var sentMessage of sentMessages) {
                var receivedMessage = receivedMap.get(sentMessage["id"])
                if (receivedMessage) {
                    matchedPairs.push([JSON.stringify(sentMessage), JSON.stringify(receivedMessage), receivedMessage["ts"] - sentMessage["ts"]])
                    timeDifferences.push(receivedMessage["ts"] - sentMessage["ts"])
                } else {
                    Log("no matched sentMessage:", sentMessage, "#FF0000")
                }
            }
            
            var averageTimeDifference = timeDifferences.reduce((sum, diff) => sum + diff, 0) / timeDifferences.length
            
            var tbl = {
                "type": "table",
                "title": testType + " / averageTimeDifference:" + averageTimeDifference,
                "cols": ["send", "received", "ts diff"],
                "rows": []
            }

            for (var pair of matchedPairs) {
                tbl["rows"].push(pair)
            }

            tbls.push(tbl)
            Log(testType, ", averageTimeDifference:", averageTimeDifference, "ms")
        }

        tester.arrSendMsgByAPI = []
        tester.arrSendMsgByHttp = []
        tester.arrEchoMsgByAPI = []
        tester.arrEchoMsgByHttp = []

        return tbls
    }

    return tester
}

function main() {
    __Serve("http://0.0.0.0:8088", serverFunc)

    var t = createMsgTester(accessKey, secretKey, httpUrl)
    while (true) {
        Log("测试开始...", "#FF0000")
        t.run()

        var beginTS = new Date().getTime()
        while (new Date().getTime() - beginTS < 60 * 1000) {
            var cmd = GetCommand()
            if (cmd) {
                try {
                    var obj = JSON.parse(cmd)
                    obj["ts"] = new Date().getTime()
                    t.getEcho(obj)
                } catch (e) {
                    Log(e)
                }
            }
            
            var msg = threading.mainThread().peekMessage(-1)
            if (msg) {
                try {
                    var obj = JSON.parse(msg)
                    obj["ts"] = new Date().getTime()
                    t.getEcho(obj)                
                } catch (e) {
                    Log(e)
                }
            }
        }
        Log("等待结束...", "#FF0000")
                
        var tbls = t.deal()
        LogStatus(_D(), "\n`" + JSON.stringify(tbls) + "`")
        Sleep(20000)
    }
}

テストを行う場合,特定のサーバーのIPアドレスを入力する必要があります.

var httpUrl = "http://123.123.123.123:8088/CommandRobot"
var accessKey = "xxx"
var secretKey = "xxx"

1, serverFunc 関数は,外部信号を監視するために,並行 HTTP サービスを作成する.拡張 API インターフェースが受信する外部メッセージについては,GetCommand 関数を使用して監視する.

• ツイッターで投稿されたメッセージは, フォローしているvar msg = threading.mainThread().peekMessage(-1)盗聴する.

• インタラクティブなメッセージは,拡張APIで転送されます. フォローしているvar cmd = GetCommand()盗聴する.

2, 送信信号と受信信号のプロセスは無遮断で,プラットフォームは, 基層のマルチスレッドリソースリサイクルメカニズムを最適化し,Thread可能性はexchange.Go同期関数は,同期作業が完了するまで (例:join関数,wait関数など) 明らかに待たなくても,システム底部が自動的にリソースリクエストを処理します (最新バージョンのホストのみがサポートする必要があります).

    // 摘录代码片段，发送信号
    tester.run = function() {
        var robotId = tester.currentRobotId

        for (var i = 0; i < 10; i++) {
            var msgByAPI = {"ts": new Date().getTime(), "id": tester.idByAPI, "way": "ByAPI"}            
            tester.arrSendMsgByAPI.push(msgByAPI)
            tester.idByAPI++
            threading.Thread(sendMsgByAPI, msgByAPI, robotId, accessKey, secretKey)   // 并发调用，非阻塞

            var msgByHttp = {"ts": new Date().getTime(), "id": tester.idByHttp, "way": "ByHttp"}
            tester.arrSendMsgByHttp.push(msgByHttp)
            tester.idByHttp++
            threading.Thread(sendMsgByHttp, msgByHttp, httpUrl)                       // 并发调用，非阻塞
        }
    }

    // 摘录代码片段，接收信号
    var cmd = GetCommand()                              // 监听来自扩展API的消息，非阻塞
    var msg = threading.mainThread().peekMessage(-1)    // 监听来自自建Http服务的消息，使用了参数-1，非阻塞

このテストの過程を見てみましょう. 情報はコードに直接注記されています.

function main() {
    __Serve("http://0.0.0.0:8088", serverFunc)      // 在当前策略实例中，创建一个并发的http服务

    var t = createMsgTester(accessKey, secretKey, httpUrl)   // 创建一个用于测试管理的对象
    while (true) {                                           // 策略主循环开始
        Log("测试开始...", "#FF0000")
        t.run()                                              // 每次循环开始，调用测试管理对象的run函数，使用两种方式（1、通过扩展API发送信号，2、直接向当前策略创建的Http服务发送信号），每种方式并发发送10个请求

        var beginTS = new Date().getTime()
        while (new Date().getTime() - beginTS < 60 * 1000) {   // 循环检测来自扩展API的交互消息，循环检测来自自建Http服务的消息
            var cmd = GetCommand()
            if (cmd) {
                try {
                    var obj = JSON.parse(cmd)
                    obj["ts"] = new Date().getTime()        // 检测到交互消息，记录消息，更新时间为收到时间
                    t.getEcho(obj)                          // 记录到对应数组
                } catch (e) {
                    Log(e)
                }
            }
            
            var msg = threading.mainThread().peekMessage(-1)
            if (msg) {
                try {
                    var obj = JSON.parse(msg)
                    obj["ts"] = new Date().getTime()        // 检测到自建的Http服务收到的消息，更新时间为收到时间
                    t.getEcho(obj)                          // ...
                } catch (e) {
                    Log(e)
                }
            }
        }
        Log("等待结束...", "#FF0000")
                
        var tbls = t.deal()                                  // 根据记录的消息，配对，检查是否有未配对的消息，如果有说明有信号丢失
        LogStatus(_D(), "\n`" + JSON.stringify(tbls) + "`")
        Sleep(20000)
    }
}

テスト結果

テスト期間を経て,HttpはAPIよりも平均的に少し時間がかかると見られます.

策略内蔵Httpサービス受信信号,このテスト方法は非常に厳格ではない,要求は外部から来る必要があります. 簡単な理解のために,表面的に,この要因を無視することができます. 信号取得の2つの方法のために,策略内蔵Httpサービスは,結局,2つの方法の信号を取得するために,リンクを削減し,応答速度を少し速くする必要があります. 信号安定性については,より重要なことは,信号が失われない,または見逃す. テスト結果は,FMZプラットフォームの拡張APIが同様に安定していることが見えます. テストでは,信号損失が見られていません.

この記事では,テキストコードの内蔵Httpサービスが検証されず,単なるメッセージデータを受け取っていることを引用します. 次の記事では,外部Trading View信号を受信するための内蔵Httpサービスのテンプレートを完全に実現しました.