Các nhà phát minh định lượng tài liệu API

void main() {
    Mail("smtp.163.com", "asdf@163.com", "password", "111@163.com", "title", "body");
}

• MailPhiên bản không đồng bộ của hàmMail_GoChức năng: Cách sử dụng vàexchange.GoChức năng tương tự.

  function main() {
      var r1 = Mail_Go("smtp.163.com", "asdf@163.com", "password", "111@163.com", "title", "body")
      var r2 = Mail_Go("smtp.163.com", "asdf@163.com", "password", "111@163.com", "title", "body")
      
      var ret1 = r1.wait()
      var ret2 = r2.wait()
      
      Log("ret1:", ret1)
      Log("ret2:", ret2)
  }
  

  # 不支持
  

  // 不支持
  

Lưu ý: Máy chủ Ali Cloud có thể đóng một số cổng, khiến thư không thể được gửi đi. Nếu cần thay đổi cổng, bạn có thể thêm mã cổng trực tiếp trong tham số đầu tiên, ví dụ:smtp.qq.com:587, Các thử nghiệm cổng có sẵn. Nếu báo cáo sai:unencryped connectionNhững điều cần sửa đổiMailCác hàmsmtpServerCác tham số được định dạng như sau:ssl://xxx.com:xxxVí dụ như trong thư điện tử QQ.SMTPCách sử dụng SSL:ssl://smtp.qq.com:465Hoặcsmtp://xxx.com:xxx。

SetErrorFilter(...)

SetErrorFilter(RegEx), Lưu mục lỗi lọc. Parameter value: type string. Các nhật ký lỗi được khớp với biểu thức chính thức này sẽ không được tải lên hệ thống nhật ký, và nhiều điều kiện lọc có thể được đặt ra nhiều lần (những nhật ký được lọc không được ghi vào các tập tin cơ sở dữ liệu tương ứng với ID đĩa thực trong thư mục chủ, ngăn chặn các lỗi thường xuyên gây ra sự bùng nổ của tập tin cơ sở dữ liệu).

function main() {
    SetErrorFilter("502:|503:|tcp|character|unexpected|network|timeout|WSARecv|Connect|GetAddr|no such|reset|http|received|EOF|reused")
}

def main():
    SetErrorFilter("502:|503:|tcp|character|unexpected|network|timeout|WSARecv|Connect|GetAddr|no such|reset|http|received|EOF|reused")

void main() {
    SetErrorFilter("502:|503:|tcp|character|unexpected|network|timeout|WSARecv|Connect|GetAddr|no such|reset|http|received|EOF|reused");
}

Một số người dùng đang sử dụng các công cụ này để kiểm tra thông tin lỗi trên giao diện:

function main() {
    // 随便查询一个不存在的订单，id为123，故意让接口报错
    var order = exchange.GetOrder("123")
    Log(order)
    // 过滤http502错误、GetOrder接口错误，设置错误过滤之后，第二次调用GetOrder不再报错
    SetErrorFilter("502:|GetOrder")
    order = exchange.GetOrder("123")
    Log(order)
}

def main():
    order = exchange.GetOrder("123")
    Log(order)
    SetErrorFilter("502:|GetOrder")
    order = exchange.GetOrder("123")
    Log(order)

void main() {
    TId orderId;
    Order order = exchange.GetOrder(orderId);
    Log(order);
    SetErrorFilter("502:|GetOrder");
    order = exchange.GetOrder(orderId);
    Log(order);
}

GetPid ((()

GetPid(), Trả về ID quá trình đĩa thực. Trả về giá trị: kiểu chuỗi.

function main(){
    var id = GetPid()
    Log(id)
}

def main():
    id = GetPid()
    Log(id)

void main() {
    auto id = GetPid();
    Log(id);
}

GetLastError()

GetLastError(), lấy thông tin lỗi gần đây. Thông thường không cần sử dụng vì chương trình sẽ tự động tải thông tin lỗi lên hệ thống nhật ký. Trả về giá trị: kiểu chuỗi.GetLastError()Chức năng sau đó sẽ xóa bộ nhớ cache lỗi này và không trả lại thông tin sai trong lần ghi trước khi gọi lại.

function main(){
    // 因为不存在编号为123的订单，所以会出错
    exchange.GetOrder("123")
    var error = GetLastError()
    Log(error)
}

def main():
    exchange.GetOrder("123")
    error = GetLastError()
    Log(error)

void main() {
    // 订单ID类型：TId，所以不能传入字符串，我们下一个不符合交易所规范的订单来触发
    exchange.GetOrder(exchange.Buy(1, 1));
    auto error = GetLastError();
    Log(error);
}

GetCommand()

GetCommand(), lấy chuỗi lệnh tương tác ((utf-8)); lấy lệnh từ giao diện tương tác chính sách và xóa bộ nhớ cache, không có lệnh trả về chuỗi trống; định dạng lệnh trả về là按钮名称:参数Nếu điều khiển tương tác không có tham số (ví dụ như điều khiển nút không có hộp đầu vào), lệnh là tên nút.

function main(){
    while(true) { 
        var cmd = GetCommand()
        if (cmd) { 
            Log(cmd)
        }
        Sleep(1000) 
    }
}

def main():
    while True:
        cmd = GetCommand()
        if cmd:
            Log(cmd)
        Sleep(1000)

void main() {
    while(true) {
        auto cmd = GetCommand();
        if(cmd != "") {
            Log(cmd);
        }
        Sleep(1000);
    }
}

Hệ thống dưới cùng có một cấu trúc hàng rào ghi lại các lệnh tương tác khiGetCommand()Khi một hàm được gọi, nó lấy lệnh tương tác đầu tiên trong hàng (trở lại một chuỗi trống nếu không có lệnh tương tác).

Ví dụ về việc sử dụng điều khiển tương tác, giao diện chỉnh sửa chính sách thiết lập điều khiển tương tác.

Trong chiến lược, thiết kế mã tương tác:

function main() {
    while (true) {
        LogStatus(_D())
        var cmd = GetCommand()
        if (cmd) {
            Log("cmd:", cmd)    
            var arr = cmd.split(":")
            if (arr[0] == "buy") {
                Log("买入，该控件不带数量")
            } else if (arr[0] == "sell") {
                Log("卖出，该控件带数量：", arr[1])
            } else {
                Log("其它控件触发：", arr)
            }
        }
        Sleep(1000)
    } 
}

def main():
    while True:
        LogStatus(_D())
        cmd = GetCommand()
        if cmd:
            Log("cmd:", cmd)
            arr = cmd.split(":")
            if arr[0] == "buy":
                Log("买入，该控件不带数量")
            elif arr[0] == "sell":
                Log("卖出，该控件带数量：", arr[1])
            else:
                Log("其它控件触发：", arr)
        Sleep(1000)

#include <iostream>
#include <sstream>
#include <string>
#include <vector>
using namespace std;
void split(const string& s,vector<string>& sv,const char flag = ' ') {
    sv.clear();
    istringstream iss(s);
    string temp;

    while (getline(iss, temp, flag)) {
        sv.push_back(temp);
    }
    return;
}

void main() {
    while(true) {
        LogStatus(_D());
        auto cmd = GetCommand();
        if (cmd != "") {
            vector<string> arr;
            split(cmd, arr, ':');
            if(arr[0] == "buy") {
                Log("买入，该控件不带数量");
            } else if (arr[0] == "sell") {
                Log("卖出，该控件带数量：", arr[1]);
            } else {
                Log("其它控件触发：", arr);
            }
        }
        Sleep(1000);
    }
}

GetMeta()

GetMeta()Chức năng trả về mã đăng ký chính sách được viết khi tạoMetaCác giá trị của hàm này được trả về với kiểu chuỗi. Các tình huống áp dụng, ví dụ như chiến lược yêu cầu giới hạn tài chính cho các người thuê khác nhau. Lưu ý: Khi tạo mã đăng kýMetaKhông được dài hơn 190 ký tự, chỉ áp dụng cho ổ đĩa thực và cần sử dụng trình quản lý mới nhất. Nếu không thiết lập metadata khi tạo mã đăng ký chính sáchGetMeta()Trả về giá trị trống.

Thông tin liên quan đến việc sử dụng mô hình cảnh

function main() {
    // 策略允许的计价币最大资产数值
    var maxBaseCurrency = null
    
    // 获取创建注册码时的元数据
    var level = GetMeta()
    
    // 检测Meta对应的条件
    if (level == "level1") {
        // -1为不限制
        maxBaseCurrency = -1       
    } else if (level == "level2") {
        maxBaseCurrency = 10     
    } else if (level == "level3") {
        maxBaseCurrency = 1
    } else {
        maxBaseCurrency = 0.5
    }
    
    while(1) {
        Sleep(1000)
        var ticker = exchange.GetTicker()
        
        // 检测资产数值
        var acc = exchange.GetAccount()
        if (maxBaseCurrency != -1 && maxBaseCurrency < acc.Stocks + acc.FrozenStocks) {
            // 停止执行策略交易逻辑
            LogStatus(_D(), "level:", level, "持仓超过注册码的使用限定，不再执行策略交易逻辑！")
            continue
        }
        
        // 其它交易逻辑
        
        // 正常输出状态栏信息
        LogStatus(_D(), "level:", level, "策略正常运行！ticker数据：\n", ticker)
    }
}

def main():
    maxBaseCurrency = null
    level = GetMeta()
    
    if level == "level1":
        maxBaseCurrency = -1       
    elif level == "level2":
        maxBaseCurrency = 10     
    elif level == "level3":
        maxBaseCurrency = 1
    else:
        maxBaseCurrency = 0.5
    
    while True:
        Sleep(1000)
        ticker = exchange.GetTicker()        
        acc = exchange.GetAccount()
        if maxBaseCurrency != -1 and maxBaseCurrency < acc["Stocks"] + acc["FrozenStocks"]:
            LogStatus(_D(), "level:", level, "持仓超过注册码的使用限定，不再执行策略交易逻辑！")
            continue        
        
        # 其它交易逻辑
        
        # 正常输出状态栏信息
        LogStatus(_D(), "level:", level, "策略正常运行！ticker数据：\n", ticker)

void main() {
    auto maxBaseCurrency = 0.0;
    auto level = GetMeta();
    
    if (level == "level1") {
        maxBaseCurrency = -1;  
    } else if (level == "level2") {
        maxBaseCurrency = 10;
    } else if (level == "level3") {
        maxBaseCurrency = 1;
    } else {
        maxBaseCurrency = 0.5;
    }
    
    while(1) {
        Sleep(1000);
        auto ticker = exchange.GetTicker();  
        auto acc = exchange.GetAccount();
        if (maxBaseCurrency != -1 && maxBaseCurrency < acc.Stocks + acc.FrozenStocks) {
            // 停止执行策略交易逻辑
            LogStatus(_D(), "level:", level, "持仓超过注册码的使用限定，不再执行策略交易逻辑！");
            continue;
        }
        
        // 其它交易逻辑
        
        // 正常输出状态栏信息
        LogStatus(_D(), "level:", level, "策略正常运行！ticker数据：\n", ticker);
    }
}

Nhập số...

Dial(Address, Timeout), nguyên bảnSocketTruy cập, hỗ trợtcp，udp，tls，unixCác thông tin về giao thức.AddressBạn có thể sử dụng các loại hình khác nhau.TimeOutLoại giá trị, đơn vị giá trị là giây, nếu quá giờDial(...)Chức năng trả về giá trị trống.

AddressCác thông số chi tiết:

function main(){
    // Dial支持tcp://，udp://，tls://，unix://协议，可加一个参数指定超时的秒数
    var client = Dial("tls://www.baidu.com:443")  
    if (client) {
        // write可再跟一个数字参数指定超时,write返回成功发送的字节数
        client.write("GET / HTTP/1.1\nConnection: Closed\n\n")
        while (true) {
            // read可再跟一个数字参数指定超时，单位：毫秒。返回null指出错或者超时或者socket已经关闭
            var buf = client.read()
            if (!buf) {
                 break
            }
            Log(buf)
        }
        client.close()
    }
}

def main():
    client = Dial("tls://www.baidu.com:443")
    if client:
        client.write("GET / HTTP/1.1\nConnection: Closed\n\n")
        while True:
            buf = client.read()
            if not buf:
                break
            Log(buf)
        client.close()

void main() {
    auto client = Dial("tls://www.baidu.com:443");
    if(client.Valid) {
        client.write("GET / HTTP/1.1\nConnection: Closed\n\n");
        while(true) {
            auto buf = client.read();
            if(buf == "") {
                break;
            }
            Log(buf);
        }
        client.close();
    }
}

readChức năng hỗ trợ các tham số sau:

• Khi không truyền tham số, chặn cho đến khi có tin nhắn; ví dụ:ws.read()。
• Khi nhập tham số, đơn vị là millisecond, chỉ định thời gian chờ quá giờ của tin nhắn; ví dụ:ws.read(2000)Đặt thời gian trễ là hai giây ((2000 milliseconds) ).
• Và sau đây là 2 tham số chỉ đúngwebsocketCó hiệu quả: Đưa vào tham số-1Một hàm trả về ngay lập tức cho dù có hoặc không có tin nhắn, ví dụ:ws.read(-1)❖ Đưa vào tham số-2Điều này có nghĩa là các hàm sẽ trả về ngay lập tức, dù không có tin nhắn, nhưng chỉ trả về tin nhắn mới nhất, và các tin nhắn trong vùng đệm sẽ bị loại bỏ; ví dụ:ws.read(-2)。

read()Các vùng đệm hàm: Ws protocol đẩy dữ liệu đến nếu trong chính sáchread()Khoảng thời gian quá dài giữa các cuộc gọi hàm có thể gây ra sự tích lũy dữ liệu. Dữ liệu này được lưu trữ trong vùng đệm, cấu trúc dữ liệu vùng đệm là hàng, giới hạn là 2000. Sau khi vượt quá 2000, dữ liệu mới nhất được đưa vào vùng đệm, dữ liệu cũ nhất được xóa.

• Hỗ trợ giao thức wss ((WebSocket) Các công ty khác cũng có thể truy cập vào Binance.

  function main() {
      LogStatus("正在连接...")
      // 访问币安的websocket接口
      var client = Dial("wss://stream.binance.com:9443/ws/!ticker@arr")
      if (!client) {
          Log("连接失败, 程序退出")
          return
      }
      
      while (true) {
          // read只返回调用read之后获取的数据
          var buf = client.read()      
          if (!buf) {
              break
          }
          var table = {
              type: 'table',
              title: '行情图表',
              cols: ['币种', '最高', '最低', '买一', '卖一', '最后成交价', '成交量', '更新时间'],
              rows: []
          }
          var obj = JSON.parse(buf)
          _.each(obj, function(ticker) {
              table.rows.push([ticker.s, ticker.h, ticker.l, ticker.b, ticker.a, ticker.c, ticker.q, _D(ticker.E)])
          })
          LogStatus('`' + JSON.stringify(table) + '`')
      }
      client.close()
  }
  

  import json
  def main():
      LogStatus("正在连接...")
      client = Dial("wss://stream.binance.com:9443/ws/!ticker@arr")
      if not client:
          Log("连接失败, 程序退出")
          return 
      
      while True:
          buf = client.read()
          if not buf:
              break
          table = {
              "type" : "table", 
              "title" : "行情图表", 
              "cols" : ["币种", "最高", "最低", "买一", "卖一", "最后成交价", "成交量", "更新时间"], 
              "rows" : [] 
          }
          obj = json.loads(buf)
          for i in range(len(obj)):
              table["rows"].append([obj[i]["s"], obj[i]["h"], obj[i]["l"], obj[i]["b"], obj[i]["a"], obj[i]["c"], obj[i]["q"], _D(int(obj[i]["E"]))])
          LogStatus('`' + json.dumps(table) + '`')
      client.close()
  

  void main() {
      LogStatus("正在连接...");
      auto client = Dial("wss://stream.binance.com:9443/ws/!ticker@arr");
      if(!client.Valid) {
          Log("连接失败, 程序退出");
          return;
      }
      
      while(true) {
          auto buf = client.read();
          if(buf == "") {
              break;
          }
          json table = R"({
              "type" : "table", 
              "title" : "行情图表", 
              "cols" : ["币种", "最高", "最低", "买一", "卖一", "最后成交价", "成交量", "更新时间"], 
              "rows" : []
          })"_json;
          json obj = json::parse(buf);
          for(auto& ele : obj.items()) {
              table["rows"].push_back({ele.value()["s"], ele.value()["h"], ele.value()["l"], ele.value()["b"], ele.value()["a"], ele.value()["c"], 
                  ele.value()["q"], _D(ele.value()["E"])});
          }
          LogStatus("`" + table.dump() + "`");
      }
      client.close();
  }
  

  Để truy cập vào giao diện websocket của OKX:

  var ws = null 
  function main(){
      var param = {
          "op": "subscribe",
          "args": [{
              "channel": "tickers",
              "instId": "BTC-USDT"
          }]
      }
      // 在调用Dial函数时，指定reconnect=true即设置为重连模式，指定payload即为重连时发送的消息。在websocket连接断开后，会自动重连，自动发送消息
      ws = Dial("wss://ws.okx.com:8443/ws/v5/public|compress=gzip_raw&mode=recv&reconnect=true&payload="+ JSON.stringify(param))
      if(ws){
          var pingCyc = 1000 * 20
          var lastPingTime = new Date().getTime()
          while(true){
              var nowTime = new Date().getTime()
              var ret = ws.read()
              Log("ret:", ret)
              if(nowTime - lastPingTime > pingCyc){
                  var retPing = ws.write("ping")
                  lastPingTime = nowTime
                  Log("发送 ：ping", "#FF0000")
              }
              LogStatus("当前时间：", _D())
              Sleep(1000)
          }
      }
  }  
  
  function onexit() {
      ws.close() 
      Log("退出")
  }
  

  import json
  import time  
  
  ws = None
  def main():
      global ws 
      param = {
          "op": "subscribe",
          "args": [{
              "channel": "tickers",
              "instId": "BTC-USDT"
          }]
      }
      ws = Dial("wss://ws.okx.com:8443/ws/v5/public|compress=gzip_raw&mode=recv&reconnect=true&payload=" + json.dumps(param))
      if ws:
          pingCyc = 1000 * 20
          lastPingTime = time.time() * 1000
          while True:
              nowTime = time.time() * 1000
              ret = ws.read()
              Log("ret:", ret)
              if nowTime - lastPingTime > pingCyc:
                  retPing = ws.write("ping")
                  lastPingTime = nowTime
                  Log("发送：ping", "#FF0000")
              LogStatus("当前时间：", _D())
              Sleep(1000)  
  
  def onexit():
      ws.close()
      Log("退出")
  

  auto objWS = Dial("wss://ws.okx.com:8443/ws/v5/public|compress=gzip_raw&mode=recv&reconnect=true");  
  
  void main() {
      json param = R"({
          "op": "subscribe",
          "args": [{
              "channel": "tickers",
              "instId": "BTC-USDT"
          }]
      })"_json;
      
      objWS.write(param.dump());
      if(objWS.Valid) {
          uint64_t pingCyc = 1000 * 20;
          uint64_t lastPingTime = Unix() * 1000;
          while(true) {
              uint64_t nowTime = Unix() * 1000;
              auto ret = objWS.read();
              Log("ret:", ret);
              if(nowTime - lastPingTime > pingCyc) {
                  auto retPing = objWS.write("ping");
                  lastPingTime = nowTime;
                  Log("发送：ping", "#FF0000");
              }
              LogStatus("当前时间：", _D());
              Sleep(1000);
          }
      }
  }  
  
  void onexit() {
      objWS.close();
      Log("退出");
  }
  

  Các giao diện thị trường websocket để truy cập các token:

  var ws = null   
  
  function main(){
      var param = {"sub": "market.btcusdt.detail", "id": "id1"}
      ws = Dial("wss://api.huobi.pro/ws|compress=gzip&mode=recv&reconnect=true&payload="+ JSON.stringify(param))
      if(ws){
          while(1){
              var ret = ws.read()
              Log("ret:", ret)
              // 响应心跳包操作
              try {
                  var jsonRet = JSON.parse(ret)
                  if(typeof(jsonRet.ping) == "number") {
                      var strPong = JSON.stringify({"pong" : jsonRet.ping})
                      ws.write(strPong)
                      Log("响应ping，发送pong:", strPong, "#FF0000")
                  }
              } catch(e) {
                  Log("e.name:", e.name, "e.stack:", e.stack, "e.message:", e.message)
              }
              
              LogStatus("当前时间：", _D())
              Sleep(1000)
          }
      }
  }  
  
  function onexit() {
      ws.close() 
      Log("执行ws.close()函数")
  }
  

  import json
  ws = None  
  
  def main():
      global ws
      param = {"sub" : "market.btcusdt.detail", "id" : "id1"}
      ws = Dial("wss://api.huobi.pro/ws|compress=gzip&mode=recv&reconnect=true&payload=" + json.dumps(param))
      if ws:
          while True:
              ret = ws.read()
              Log("ret:", ret)              
              # 响应心跳包操作
              try:
                  jsonRet = json.loads(ret)
                  if "ping" in jsonRet and type(jsonRet["ping"]) == int:
                      strPong = json.dumps({"pong" : jsonRet["ping"]})
                      ws.write(strPong)
                      Log("响应ping，发送pong:", strPong, "#FF0000")
              except Exception as e:
                  Log("e:", e)
                  
              LogStatus("当前时间：", _D())
              Sleep(1000)
      
  def onexit():
      ws.close()
      Log("执行ws.close()函数")  
  

  using namespace std;
  void main() {
      json param = R"({"sub" : "market.btcusdt.detail", "id" : "id1"})"_json;
      auto ws = Dial("wss://api.huobi.pro/ws|compress=gzip&mode=recv&reconnect=true&payload=" + param.dump());
      if(ws.Valid) {
          while(true) {
              auto ret = ws.read();
              Log("ret:", ret);              
              // 响应心跳包操作
              try 
              {
                  auto jsonRet = json::parse(ret);
                  if(jsonRet["ping"].is_number()) {
                      json pong = R"({"pong" : 0})"_json;
                      pong["pong"] = jsonRet["ping"];
                      auto strPong = pong.dump();
                      ws.write(strPong);
                      Log("响应ping，发送pong:", strPong, "#FF0000");
                  }
              } catch(exception &e) 
              {
                  Log("e:", e.what());
              }
              
              LogStatus("当前时间：", _D());
              Sleep(1000);
          }
      }
  }  
  
  void onexit() {
      // ws.close();
      Log("执行ws.close()函数");
  }
  

  Truy cập vào OKX websocket authentication interface:

  function getLogin(pAccessKey, pSecretKey, pPassphrase) {
      // 签名函数，用于登录
      var ts = (new Date().getTime() / 1000).toString()
      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 accessKey = "xxx"
      var secretKey = "xxx"
      var passphrase = "xxx"
  
      client_private = Dial("wss://ws.okx.com:8443/ws/v5/private")
      client_private.write(JSON.stringify(getLogin(accessKey, secretKey, passphrase)))
      Sleep(3000)  // 登录时，不能立即订阅私有频道，需要等待服务器反应
      client_private.write(JSON.stringify(posSubscribe))
      if (client_private) {
          var lastPingTS = new Date().getTime()
          while (true) {
              var buf = client_private.read(-1)
              if (buf) {
                  Log(buf)
              }
              
              // 检测断开，重连
              if (buf == "" && client_private.write(JSON.stringify(posSubscribe)) == 0) {
                  Log("检测到断开，关闭连接，重连")
                  client_private.close()
                  client_private = Dial("wss://ws.okx.com:8443/ws/v5/private")
                  client_private.write(JSON.stringify(getLogin(accessKey, secretKey, passphrase)))
                  Sleep(3000)
                  client_private.write(JSON.stringify(posSubscribe))
              }
              
              // 发送心跳包
              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)
  }
  

  import json
  import time
    
  def getLogin(pAccessKey, pSecretKey, pPassphrase):
      ts = str(time.time())
      login = {
          "op": "login",
          "args":[{
              "apiKey"    : pAccessKey,
              "passphrase" : pPassphrase,
              "timestamp" : ts,
              "sign" : exchange.HMAC("sha256", "base64", ts + "GET" + "/users/self/verify", pSecretKey)
          }]
      }
      return login     
  
  client_private = None 
  def main():
      global client_private
      SetErrorFilter("timeout")
      
      posSubscribe = {
          "op": "subscribe",
          "args": [{
              "channel": "positions",
              "instType": "ANY"
          }]
      }      
  
      accessKey = "xxx"
      secretKey = "xxx"
      passphrase = "xxx"
      
      client_private = Dial("wss://ws.okx.com:8443/ws/v5/private")
      client_private.write(json.dumps(getLogin(accessKey, secretKey, passphrase)))
      Sleep(3000)
      client_private.write(json.dumps(posSubscribe))
      if client_private:
          lastPingTS = time.time() * 1000
          while True:
              buf = client_private.read(-1)
              if buf:
                  Log(buf)
              
              if buf == "" and client_private.write(json.dumps(posSubscribe)) == 0:
                  Log("检测到断开，关闭连接，重连")
                  ret = client_private.close()
                  client_private = Dial("wss://ws.okx.com:8443/ws/v5/private")
                  client_private.write(json.dumps(getLogin(accessKey, secretKey, passphrase)))
                  Sleep(3000)
                  client_private.write(json.dumps(posSubscribe))
              
              nowPingTS = time.time() * 1000
              if nowPingTS - lastPingTS > 10 * 1000:
                  client_private.write("ping")
                  lastPingTS = nowPingTS    
  
  def onexit():
      ret = client_private.close()
      Log("关闭连接！", ret)
  

  auto client_private = Dial("wss://ws.okx.com:8443/ws/v5/private");      
  
  json getLogin(string pAccessKey, string pSecretKey, string pPassphrase) {
      auto ts = std::to_string(Unix());
      json login = R"({
          "op": "login",
          "args": [{
              "apiKey": "",
              "passphrase": "",
              "timestamp": "",
              "sign": ""
          }]
      })"_json;
      login["args"][0]["apiKey"] = pAccessKey;
      login["args"][0]["passphrase"] = pPassphrase;
      login["args"][0]["timestamp"] = ts;
      login["args"][0]["sign"] = exchange.HMAC("sha256", "base64", ts + "GET" + "/users/self/verify", pSecretKey);
      return login;
  }      
  
  void main() {
      SetErrorFilter("timeout");
      json posSubscribe = R"({
          "op": "subscribe",
          "args": [{
              "channel": "positions",
              "instType": "ANY"
          }]
      })"_json;
      
      auto accessKey = "xxx";
      auto secretKey = "xxx";
      auto passphrase = "xxx";
      
      client_private.write(getLogin(accessKey, secretKey, passphrase).dump());
      Sleep(3000);
      client_private.write(posSubscribe.dump());    
  
      if (client_private.Valid) {
          uint64_t lastPingTS = Unix() * 1000;      
  
          while (true) {
              auto buf = client_private.read(-1);
              if (buf != "") {
                  Log(buf);
              }
              if (buf == "") {
                  if (client_private.write(posSubscribe.dump()) == 0) {
                      Log("检测到断开，关闭连接，重连");
                      client_private.close();
                      client_private = Dial("wss://ws.okx.com:8443/ws/v5/private");
                      client_private.write(getLogin(accessKey, secretKey, passphrase).dump());
                      Sleep(3000);
                      client_private.write(posSubscribe.dump());
                  }
              }
              
              uint64_t nowPingTS = Unix() * 1000;
              if (nowPingTS - lastPingTS > 10 * 1000) {
                  client_private.write("ping");
                  lastPingTS = nowPingTS;
              }
          }
      }
  }      
  
  void onexit() {
      client_private.close();
      Log("退出");
  }
  

HttpQuery(...)

HttpQuery(Url, PostData, Cookies, Headers, IsReturnHeader), truy cập URL mạng. Các giá trị tham số: tất cả là loại chuỗi.

Lưu ý:

• HttpQuery(...)Chức năng chỉ hỗ trợJavaScriptNgôn ngữ.
• PythonNgôn ngữ có thể được sử dụngurllibBạn có thể gửi yêu cầu http trực tiếp.

HttpQuery(...)Chủ yếu được sử dụng để truy cập các giao diện không cần chữ ký, chẳng hạn như giao diện công cộng như thông tin thị trường.

Ví dụ về giao diện API không cần chữ ký để truy cập OKX, trả về giá trịJSONDưới đây là một số hình ảnh.JavaScriptCác chiến lược ngôn ngữ được sử dụngJSON.parse()Phân tích hàm.

function main(){
    // 一个GET访问不带参数的例子
    var info = JSON.parse(HttpQuery("https://www.okx.com/api/v5/public/time"))
    Log(info)
    // 一个GET访问带参数的例子
    var ticker = JSON.parse(HttpQuery("https://www.okx.com/api/v5/market/books?instId=BTC-USDT"))
    Log(ticker)
}

import json
import urllib.request
def main():
    # HttpQuery不支持Python，可以使用urllib/urllib2库代替
    info = json.loads(urllib.request.urlopen("https://www.okx.com/api/v5/public/time").read().decode('utf-8'))
    Log(info)
    ticker = json.loads(urllib.request.urlopen("https://www.okx.com/api/v5/market/books?instId=BTC-USDT").read().decode('utf-8'))
    Log(ticker)

void main() {
    auto info = json::parse(HttpQuery("https://www.okx.com/api/v5/public/time"));
    Log(info);
    auto ticker = json::parse(HttpQuery("https://www.okx.com/api/v5/market/books?instId=BTC-USDT"));
    Log(ticker);
}

Lấy nội dung trả về của một URL nếu tham số thứ haiPostDataDùng cho một chuỗia=1&b=2&c=abcHình thức làPOSTCách gửi.PUTNhững người tham gia vào cuộc họp nàyPostDataCác tham số là{method:'PUT', data:'a=1&b=2&c=abc'}。 PostDataVà các tham số có thể làJSONDòng chữ.

CookiesCác đối số này có hình thức:a=10; b=20Các tham số được đánh dấu bằng dấu chấm;Các bạn có thể đọc bài viết này.HeadersCác đối số này có hình thức:User-Agent: Mobile\nContent-Type: text/htmlCác tham số được thay thế bằng ký tự\nCác bạn có thể đọc bài viết này.

Điểm thứ haiPostDataCác phương pháp có thể được tùy chỉnh như:HttpQuery("http://www.abc.com", {method:'PUT', data:'a=1&b=2&c=abc'})Xin lưu ý:HttpQueryCác chức năng đặt thời gian trễ, có thể được sử dụng trong{method:'PUT', data:'a=1&b=2&c=abc'}Tham giatimeoutTham khảo thêm:

Đặt 1 giây trễ:HttpQuery("http://www.abc.com", {method:'PUT', data:'a=1&b=2&c=abc', timeout:1000})

Giao thôngCookieDữ liệu này cần một đối số thứ ba, nhưng không cầnPOSTVui lòng đặt tham số thứ hai là không. Khi thử nghiệm mô phỏng, hàm sẽ trả về một chuỗi cố định vì không thể mô phỏng truy cập URL.Dummy DataBạn có thể sử dụng giao diện này để gửi tin nhắn văn bản hoặc tương tác với các giao diện API khác.

GETVí dụ về phương thức gọi:HttpQuery("http://www.baidu.com")。 POSTVí dụ về phương thức gọi:HttpQuery("http://www.163.com", "a=1&b=2&c=abc")。

Trở lạiHeaderVí dụ:

HttpQuery("http://www.baidu.com", null, "a=10; b=20", "User-Agent: Mobile\nContent-Type: text/html", true)  // will return {Header: HTTP Header, Body: HTML}

• HttpQueryCác chức năng sử dụng cài đặt đại diện:

  function main() {
      // 本次设置代理并发送http请求，无用户名，无密码，此次http请求会通过代理发送
      HttpQuery("socks5://127.0.0.1:8889/http://www.baidu.com/")
  
      // 本次设置代理并发送http请求，输入用户名和密码，仅HttpQuery当前调用生效，之后再次调用HttpQuery("http://www.baidu.com")这样不会使用代理
      HttpQuery("socks5://username:password@127.0.0.1:8889/http://www.baidu.com/")
  }
  

  # HttpQuery不支持Python，可以使用Python的urllib2库
  

  void main() {
      HttpQuery("socks5://127.0.0.1:8889/http://www.baidu.com/");
      HttpQuery("socks5://username:password@127.0.0.1:8889/http://www.baidu.com/");
  }
  

• HttpQueryPhiên bản không đồng bộ của hàmHttpQuery_GoĐịa điểm: Cách sử dụng vàexchange.GoCác chức năng tương tự, ví dụ như truy cập không đồng bộ giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch giao dịch.

  function main() {
      // 创建第一个异步线程
      var r1 = HttpQuery_Go("https://www.okx.com/api/v5/market/tickers?instType=SPOT")
      // 创建第二个异步线程
      var r2 = HttpQuery_Go("https://api.huobi.pro/market/tickers")
      
      // 获取第一个异步线程调用的返回值
      var tickers1 = r1.wait()
      // 获取第二个异步线程调用的返回值
      var tickers2 = r2.wait()
      
      // 打印结果
      Log("tickers1:", tickers1)
      Log("tickers2:", tickers2)
  }
  

  # 不支持
  

  // 不支持
  

• Sử dụng trong hệ thống kiểm tra lạiHttpQuery(...)Chức năng: Có thể sử dụng trong hệ thống kiểm tra lạiHttpQuery(...)Gửi yêu cầu ((chỉ hỗ trợ)GETyêu cầu) thu thập dữ liệu; hạn chế sử dụng 20 lần truy cập URL khác nhau khi truy cập lại; vàHttpQuery(...)truy cập sẽ lưu dữ liệu, cùng một URL lần truy cập thứ haiHttpQuery(...)Chức năng trả về dữ liệu cache (không còn yêu cầu mạng thực tế nữa).

  Chúng ta có thể chạy một chương trình dịch vụ trên một máy chủ hoặc thiết bị để đáp ứng các chương trình chính sách.HttpQuery(...)Các ứng dụng dịch vụ ngôn ngữ Go được sử dụng để thử nghiệm các yêu cầu được gửi như sau:

  package main
  import (
      "fmt"
      "net/http"
      "encoding/json"
  )
  
  func Handle (w http.ResponseWriter, r *http.Request) {
      defer func() {
          fmt.Println("req:", *r)
          ret := map[string]interface{}{
              "schema" : []string{"time","open","high","low","close","vol"},
              "data" : []interface{}{
                  []int64{1564315200000,9531300,9531300,9497060,9497060,787},
                  []int64{1564316100000,9495160,9495160,9474260,9489460,338},
              },
          }
          b, _ := json.Marshal(ret)
          w.Write(b)
      }()
  }
  
  func main () {
      fmt.Println("listen http://localhost:9090")
      http.HandleFunc("/data", Handle)
      http.ListenAndServe(":9090", nil)
  }
  

  Sử dụng khi kiểm tra lại chiến lượcHttpQuery(...)Đơn xin gửi hàm:

  function main() {
      // 可以写自己运行服务程序所在设备的IP地址
      Log(HttpQuery("http://xxx.xx.x.xxx:9090/data?msg=hello"));
      Log(exchange.GetAccount());
  }
  

  # HttpQuery不支持Python，可以使用Python的urllib2库
  

  void main() {
      // 可以写自己运行服务程序所在设备的IP地址
      Log(HttpQuery("http://xxx.xx.x.xxx:9090/data?msg=hello"));
      Log(exchange.GetAccount());
  }
  

  

• Hỗ trợ chuyển mã dữ liệu trả lời yêu cầu, hỗ trợ mã hóa thông thường. ĐặtPostDataCác thông số:{method: "GET",charset:"GB18030"}, có thể thực hiện mã chuyển đổi dữ liệu đáp ứng ((GB18030)).

Mã hóa...

Encode(algo, inputFormat, outputFormat, data, keyFormat, key string), hàm này mã hóa dữ liệu dựa trên các tham số được truyền. Trả về giá trị: kiểu chuỗi.

Các tham sốalgoCác thuật toán được sử dụng để tính toán mã hóa, hỗ trợ cài đặt là: raw (không sử dụng thuật toán), sign, signTx, md4, md5, sha256, sha512, sha1, keccak256, sha3.224, sha3.256, sha3.384, sha3.512, sha3.keccak256, sha3.keccak512, sha512.384, sha512.256, sha512.224, ripemd160, blake2b.256, blake2b.512, blake2s.128, blake2s.256.Các tham số.dataNhững dữ liệu cần được xử lý.inputFormat/outputFormat/keyFormatHỗ trợ tham sốraw，hex，base64，stringCó cách mã hóa. NếukeyFormatNếu không là không, thì dùng tham sốkeySử dụng mã hóa (HMAC), nếu không sử dụng mặc địnhkeyParameteralgoĐặt thành"sign"Hoặc"signTx"Khi cần các tham sốkey。

function main(){
    Log(Encode("md5", "raw", "hex", "hello"))
    Log(Encode("sha512", "raw", "base64", "hello"))
    Log(Encode("keccak256", "raw", "hex", "unwrapWETH9(uint256,address)"))

    Log(Encode("raw", "string", "hex", "example"))          // 6578616d706c65
    Log(Encode("raw", "hex", "string", "6578616d706c65"))   // example
}

def main():
    Log(Encode("md5", "raw", "hex", "hello", "", ""))
    Log(Encode("sha512", "raw", "base64", "hello", "", ""))
    Log(Encode("keccak256", "raw", "hex", "unwrapWETH9(uint256,address)", "", ""))

    Log(Encode("raw", "string", "hex", "example", "", ""))
    Log(Encode("raw", "hex", "string", "6578616d706c65", "", ""))

void main(){
    Log(Encode("md5", "raw", "hex", "hello"));
    Log(Encode("sha512", "raw", "base64", "hello"));
    Log(Encode("keccak256", "raw", "hex", "unwrapWETH9(uint256,address)"));
    
    Log(Encode("raw", "string", "hex", "example"));          // 6578616d706c65
    Log(Encode("raw", "hex", "string", "6578616d706c65"));   // example
}

Các tham sốalgoVà cũng ủng hộ:text.encoder.utf8，text.decoder.utf8，text.encoder.gbk，text.decoder.gbk, mã hóa, giải mã các chuỗi.

function main(){
    var ret1 = Encode("text.encoder.utf8", "raw", "hex", "你好")     // e4bda0e5a5bd
    Log(ret1)    
    var ret2 = Encode("text.decoder.utf8", "hex", "string", ret1)   
    Log(ret2)

    var ret3 = Encode("text.encoder.gbk", "raw", "hex", "你好")      // c4e3bac3
    Log(ret3)
    var ret4 = Encode("text.decoder.gbk", "hex", "string", ret3)
    Log(ret4)
}

def main():
    ret1 = Encode("text.encoder.utf8", "raw", "hex", "你好", "", "")     # e4bda0e5a5bd
    Log(ret1)    
    ret2 = Encode("text.decoder.utf8", "hex", "string", ret1, "", "")   
    Log(ret2)

    ret3 = Encode("text.encoder.gbk", "raw", "hex", "你好", "", "")      # c4e3bac3
    Log(ret3)
    ret4 = Encode("text.decoder.gbk", "hex", "string", ret3, "", "")
    Log(ret4)

void main(){
    auto ret1 = Encode("text.encoder.utf8", "raw", "hex", "你好");     // e4bda0e5a5bd
    Log(ret1);    
    auto ret2 = Encode("text.decoder.utf8", "hex", "string", ret1);   
    Log(ret2);

    auto ret3 = Encode("text.encoder.gbk", "raw", "hex", "你好");      // c4e3bac3
    Log(ret3);
    auto ret4 = Encode("text.decoder.gbk", "hex", "string", ret3);
    Log(ret4);
}

UnixNano ((()

UnixNano(), trả lại các bước thời gian ở cấp độ nanosecond, nếu bạn cần lấy các bước thời gian ở cấp độ millisecond, bạn có thể sử dụng mã sau:

function main() {
    var time = UnixNano() / 1000000
    Log(_N(time, 0))
}

def main():
    time = UnixNano()
    Log(time)

void main() {
    auto time = UnixNano();
    Log(time);
}

Unix()

Unix(), Trở lại các bước thời gian ở cấp độ giây.

function main() {
    var t = Unix()
    Log(t)
}

def main():
    t = Unix()
    Log(t)

void main() {
    auto t = Unix();
    Log(t);
}

GetOS()

GetOS(), trả về thông tin về hệ thống của người quản lý.

function main() {
    Log("GetOS:", GetOS())
}

def main():
    Log("GetOS:", GetOS())

void main() {
    Log("GetOS:", GetOS());
}

Trên máy tính AppleMac OSLưu ý: Lưu ý:

GetOS:darwin/amd64

darwinCó nghĩa làMac OSTên của hệ thống.

MD5 ((String)

MD5(String), giá trị tham số: kiểu chuỗi.

function main() {
    Log("MD5", MD5("hello world"))
}

def main():
    Log("MD5", MD5("hello world"))

void main() {
    Log("MD5", MD5("hello world"));
}

Lưu ý:

MD5 5eb63bbbe01eeed093cb22bb8f5acdc3

DBExec ((...)

DBExec(), giá trị tham số: có thể là kiểu như chuỗi, giá trị số, giá trị boolean, giá trị trống. Giá trị trả về: đối tượng chứa kết quả thực thi của câu lệnh SQLite. Chức năng giao diện cơ sở dữ liệuDBExec()Thông qua các tham số nhập, bạn có thể điều hành cơ sở dữ liệu ổ đĩa (SQLite database) ; thực hiện các thao tác về việc thêm, xóa, kiểm tra, thay đổi dữ liệu trong cơ sở dữ liệu ổ đĩa, hỗ trợSQLiteHình ngữ. Các bảng lưu trữ hệ thống trong cơ sở dữ liệu thực:kvdb、cfg、log、profit、chartBạn có thể sử dụng các biểu đồ này để làm việc trên các trang web của bạn, nhưng đừng sử dụng chúng.DBExec()Chức năng chỉ hỗ trợ ổ đĩa thực.

• Hỗ trợ cơ sở dữ liệu trong bộ nhớ Đối vớiDBExecCác tham số của hàm nếusqlCâu nói là:Khởi đầu, hoạt động trong bộ nhớ cơ sở dữ liệu, không viết tài liệu, nhanh hơn; phù hợp với các hoạt động cơ sở dữ liệu không cần lưu trữ lâu dài, ví dụ:

  function main() {
      var strSql = [
          ":CREATE TABLE TEST_TABLE(", 
          "TS INT PRIMARY KEY NOT NULL,",
          "HIGH REAL NOT NULL,", 
          "OPEN REAL NOT NULL,", 
          "LOW REAL NOT NULL,", 
          "CLOSE REAL NOT NULL,", 
          "VOLUME REAL NOT NULL)"
      ].join("")
      var ret = DBExec(strSql)
      Log(ret)
      
      // 增加一条数据
      Log(DBExec(":INSERT INTO TEST_TABLE (TS, HIGH, OPEN, LOW, CLOSE, VOLUME) VALUES (1518970320000, 100, 99.1, 90, 100, 12345.6);"))
      
      // 查询数据
      Log(DBExec(":SELECT * FROM TEST_TABLE;"))
  }
  

  def main():
      arr = [
          ":CREATE TABLE TEST_TABLE(", 
          "TS INT PRIMARY KEY NOT NULL,",
          "HIGH REAL NOT NULL,", 
          "OPEN REAL NOT NULL,", 
          "LOW REAL NOT NULL,", 
          "CLOSE REAL NOT NULL,", 
          "VOLUME REAL NOT NULL)"
      ]
      strSql = ""
      for i in range(len(arr)):
          strSql += arr[i]
      ret = DBExec(strSql)
      Log(ret)
      
      # 增加一条数据
      Log(DBExec(":INSERT INTO TEST_TABLE (TS, HIGH, OPEN, LOW, CLOSE, VOLUME) VALUES (1518970320000, 100, 99.1, 90, 100, 12345.6);"))
      
      # 查询数据
      Log(DBExec(":SELECT * FROM TEST_TABLE;"))
  

  void main() {
      string strSql = ":CREATE TABLE TEST_TABLE(\
          TS INT PRIMARY KEY NOT NULL,\
          HIGH REAL NOT NULL,\
          OPEN REAL NOT NULL,\
          LOW REAL NOT NULL,\
          CLOSE REAL NOT NULL,\
          VOLUME REAL NOT NULL)";
      auto ret = DBExec(strSql);
      Log(ret);
      
      // 增加一条数据
      Log(DBExec(":INSERT INTO TEST_TABLE (TS, HIGH, OPEN, LOW, CLOSE, VOLUME) VALUES (1518970320000, 100, 99.1, 90, 100, 12345.6);"));
      
      // 查询数据
      Log(DBExec(":SELECT * FROM TEST_TABLE;"));
  }
  

• Tạo bảng

function main() {
    var strSql = [
        "CREATE TABLE TEST_TABLE(", 
        "TS INT PRIMARY KEY NOT NULL,",
        "HIGH REAL NOT NULL,", 
        "OPEN REAL NOT NULL,", 
        "LOW REAL NOT NULL,", 
        "CLOSE REAL NOT NULL,", 
        "VOLUME REAL NOT NULL)"
    ].join("")
    var ret = DBExec(strSql)
    Log(ret)
}

def main():
    arr = [
        "CREATE TABLE TEST_TABLE(", 
        "TS INT PRIMARY KEY NOT NULL,",
        "HIGH REAL NOT NULL,", 
        "OPEN REAL NOT NULL,", 
        "LOW REAL NOT NULL,", 
        "CLOSE REAL NOT NULL,", 
        "VOLUME REAL NOT NULL)"
    ]
    strSql = ""
    for i in range(len(arr)):
        strSql += arr[i]
    ret = DBExec(strSql)
    Log(ret)

void main() {
    string strSql = "CREATE TABLE TEST_TABLE(\
        TS INT PRIMARY KEY NOT NULL,\
        HIGH REAL NOT NULL,\
        OPEN REAL NOT NULL,\
        LOW REAL NOT NULL,\
        CLOSE REAL NOT NULL,\
        VOLUME REAL NOT NULL)";
    auto ret = DBExec(strSql);
    Log(ret);
}

• Hoạt động thêm, xóa, kiểm tra và thay đổi các bản ghi trong bảng

function main() {
    var strSql = [
        "CREATE TABLE TEST_TABLE(", 
        "TS INT PRIMARY KEY NOT NULL,",
        "HIGH REAL NOT NULL,", 
        "OPEN REAL NOT NULL,", 
        "LOW REAL NOT NULL,", 
        "CLOSE REAL NOT NULL,", 
        "VOLUME REAL NOT NULL)"
    ].join("")
    Log(DBExec(strSql))
    
    // 增加一条数据
    Log(DBExec("INSERT INTO TEST_TABLE (TS, HIGH, OPEN, LOW, CLOSE, VOLUME) VALUES (1518970320000, 100, 99.1, 90, 100, 12345.6);"))
    
    // 查询数据
    Log(DBExec("SELECT * FROM TEST_TABLE;"))
    
    // 修改数据
    Log(DBExec("UPDATE TEST_TABLE SET HIGH=? WHERE TS=?", 110, 1518970320000))    
    
    // 删除数据
    Log(DBExec("DELETE FROM TEST_TABLE WHERE HIGH=?", 110))
}

def main():
    arr = [
        "CREATE TABLE TEST_TABLE(", 
        "TS INT PRIMARY KEY NOT NULL,",
        "HIGH REAL NOT NULL,", 
        "OPEN REAL NOT NULL,", 
        "LOW REAL NOT NULL,", 
        "CLOSE REAL NOT NULL,", 
        "VOLUME REAL NOT NULL)"
    ]
    strSql = ""
    for i in range(len(arr)):
        strSql += arr[i]
    Log(DBExec(strSql))
    
    # 增加一条数据
    Log(DBExec("INSERT INTO TEST_TABLE (TS, HIGH, OPEN, LOW, CLOSE, VOLUME) VALUES (1518970320000, 100, 99.1, 90, 100, 12345.6);"))
    
    # 查询数据
    Log(DBExec("SELECT * FROM TEST_TABLE;"))
    
    # 修改数据
    Log(DBExec("UPDATE TEST_TABLE SET HIGH=? WHERE TS=?", 110, 1518970320000))
    
    # 删除数据
    Log(DBExec("DELETE FROM TEST_TABLE WHERE HIGH=?", 110))

void main() {
    string strSql = "CREATE TABLE TEST_TABLE(\
        TS INT PRIMARY KEY NOT NULL,\
        HIGH REAL NOT NULL,\
        OPEN REAL NOT NULL,\
        LOW REAL NOT NULL,\
        CLOSE REAL NOT NULL,\
        VOLUME REAL NOT NULL)";
    Log(DBExec(strSql));

    // 增加一条数据
    Log(DBExec("INSERT INTO TEST_TABLE (TS, HIGH, OPEN, LOW, CLOSE, VOLUME) VALUES (1518970320000, 100, 99.1, 90, 100, 12345.6);"));
    
    // 查询数据
    Log(DBExec("SELECT * FROM TEST_TABLE;"));
    
    // 修改数据
    Log(DBExec("UPDATE TEST_TABLE SET HIGH=? WHERE TS=?", 110, 1518970320000));
    
    // 删除数据
    Log(DBExec("DELETE FROM TEST_TABLE WHERE HIGH=?", 110));
}

UUID (()

UUID(), trả về một UUID duy nhất 32 bit, chỉ áp dụng cho ổ đĩa thực.

function main() {
    var uuid1 = UUID()
    var uuid2 = UUID()
    Log(uuid1, uuid2)
}

def main():
    uuid1 = UUID()
    uuid2 = UUID()
    Log(uuid1, uuid2)

void main() {
    auto uuid1 = UUID();
    auto uuid2 = UUID();
    Log(uuid1, uuid2);
}

EventLoop ((timeout)

EventLoop(timeout)trong bất kỳwebsocketCó thể đọc hoặcexchange.Go、HttpQuery_GoVâng, các nhiệm vụ đồng thời sẽ được trả về sau khi hoàn thành.timeoutTrả về chờ một sự kiện xảy ra nếu được đặt là 0, nếu lớn hơn 0 là đặt sự kiện chờ quá thời gian, và nhỏ hơn 0 ngay lập tức trả về sự kiện gần đây nhất. Trả về tương tự như nếu khôngnull, trả về nội dungEventLoại kích hoạt sự kiện. Chức năng này chỉ áp dụng cho ổ đĩa thực.

Lần gọi đầu tiên trong mãEventLoopCác công cụ nghe lén sẽ được khởi động sau khi một sự kiện được gọi lại, nếu bạn bắt đầu lần đầu tiên.EventLoopGọi, sẽ bỏ qua các sự kiện trước đó. cấu trúc hàng đợi được gói trong hệ thống cơ sở lưu trữ tối đa 500 cuộc gọi lại sự kiện nếu chương trình không được gọi kịp thời trong quá trình thực hiện.EventLoopNếu loại bỏ, sẽ mất 500 bộ nhớ cache và các cuộc gọi lại sự kiện sau đó.EventLoopViệc gọi hàm sẽ không ảnh hưởng đến hệ thốngwebsocketVà cũng không ảnh hưởng đếnexchange.GoCác bộ nhớ cache của các hàm song song như vậy vẫn cần sử dụng các phương pháp riêng để lấy dữ liệu.EventLoopVà nếu bạn không làm được điều đó, thì bạn sẽ không thể làm được điều đó.EventLoopMột hàm sẽ tạo ra một sự kiện trả về.

EventLoopMục đích chính của hàm là thông báo cho layer chính sách, tầng dưới của hệ thống nhận được dữ liệu mạng mới.EventLoopKhi hàm trả về sự kiện, chỉ cần đi qua tất cả các nguồn dữ liệu; ví dụ:websocketCác bạn có thể tham gia vào chương trình này.exchange.GoCác đối tượng được tạo cố gắng lấy dữ liệu.Liên kết thư viện。

Trong hàm chínhmain()Trong khi gọi, nghe lén các sự kiện trên các đường dây chính.JavaScriptTrong chiến lược viết ngôn ngữ, bạn có thể sử dụng một số từ như:__Thread()Các chuỗi được tạo bởi các hàm, cũng có thể được gọi trong các hàm thực thi của các chuỗi để nghe các sự kiện của các chuỗi hiện tại.

function main() {
    var routine_getTicker = exchange.Go("GetTicker")
    var routine_getDepth = exchange.Go("GetDepth")
    var routine_getTrades = exchange.Go("GetTrades")
    
    // Sleep(2000)，如果这里使用Sleep语句，会导致之后的EventLoop函数错过之前的事件，因为等待了2秒，并发的函数