O recurso está a ser carregado... Carregamento...

OKEX V5 WS interface conta de armazenamento exemplo de push

Autora:Inventor quantificado - sonho pequeno, Data: 2021-09-02 17:46:59
Tags:

OKEX V5 WS interface conta de armazenamento exemplo de push

OKEX V5 WS Interface Exemplos de uso de interfaces privadas, parâmetros de políticaaccessKey、secretKey、passphrase❖ Entre eles:passphraseÉ uma senha de chave secreta preenchida quando o APIKEY é criado no site da bolsa. Um exemplo de política é iniciar o login para verificar, e depois subscrever todas as informações de armazenamento. Envia um ping de tempo e o servidor da bolsa responde pong.

function getLogin(pAccessKey, pSecretKey, pPassphrase) {
    // 签名函数，用于登录
    var ts = (new Date().getTime() / 1000) + ""
    var login = {
        "op": "login",
        "args":[{
            "apiKey"    : pAccessKey,
            "passphrase" : pPassphrase,
            "timestamp" : ts,
            "sign" : exchange.HMAC("sha256", "base64", ts + "GET" + "/users/self/verify", pSecretKey)
        }]
    }    
    return login
}

var client_private = null 
function main() {
    // 因为read函数使用了超时设置，过滤超时的报错，否则会有冗余错误输出
    SetErrorFilter("timeout")
    
    // 持仓频道订阅信息
    var posSubscribe = {
        "op": "subscribe",
        "args": [{
            "channel": "positions",
            "instType": "ANY"
        }]
    }

    var payload = JSON.stringify(getLogin(accessKey, secretKey, passphrase))
    client_private = Dial("wss://ws.okex.com:8443/ws/v5/private|reconnect=true&payload=" + payload)
    Sleep(3000)  // 登录时，不能立即订阅私有频道，需要等待服务器反应
    if (client_private) {        
        client_private.write(JSON.stringify(posSubscribe))
        var lastPingTS = new Date().getTime()
        while (true) {
            var buf = client_private.read(2000)
            if (buf) {
                Log(buf)    
            }
            // 发送心跳包
            var nowPingTS = new Date().getTime()
            if (nowPingTS - lastPingTS > 10 * 1000) {
                client_private.write("ping")
                lastPingTS = nowPingTS
            }            
        }        
    }
}

function onexit() {    
    var ret = client_private.close()
    Log("关闭连接！", ret)
}

Mais.