# 指標異步計算結果推送
- Python
- Proto
- C#
- Java
- C++
- JavaScript
IndicatorCalcHandlerBase.on_recv_rsp(rsp_pb)
介紹
指標異步計算結果推送回調。在通過 request_indicator_calc_async 發起指標計算後，OpenD 異步推送計算結果到此回調。回調與請求通過 calc_id 配對。
參數
無。註冊指標計算結果推送回調後被動接收。
返回
參數 類型 說明 ret RET_CODE 接口調用結果 data pd.DataFrame 當 ret == RET_OK，返回指標計算結果 DataFrame 欄位說明：
欄位 類型 說明 calc_id str 計算任務 ID，與發起請求時返回的 calc_id 對應 time str K 線時間（與請求中的 K 線時間一致） output_name str 輸出線名稱 value float 該時刻的輸出值
Example
from futu import *
class IndicatorCalcTest(IndicatorCalcHandlerBase):
def on_recv_rsp(self, rsp_pb):
ret_code, data = super(IndicatorCalcTest, self).on_recv_rsp(rsp_pb)
if ret_code != RET_OK:
print("IndicatorCalcTest: error, msg: %s" % data)
return RET_ERROR, data
print("IndicatorCalcTest", data)
return RET_OK, data
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
handler = IndicatorCalcTest()
quote_ctx.set_handler(handler)
# 之後調用 request_indicator_calc_async 發起計算
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
2
3
4
5
6
7
8
9
10
11
12
13
14
15
# Qot_PushIndicatorCalc.proto
介紹
指標異步計算結果推送，與 Qot_RequestIndicatorCalc 通過 calcId 配對。發起計算後 OpenD 異步推送計算結果。
參數
無 Request。發起 Qot_RequestIndicatorCalc 後被動接收推送。
返回
// 一行計算結果，對應一個 K 線時刻；values 順序與 outputs 一一對應
message IndicatorOutputRow
{
optional string time = 1; // K 線時間（與請求中的 KLine.time 一致）
repeated double values = 2; // 各輸出線在該時刻的值
}
message S2C
{
required string calcId = 1; // 與發起請求時返回的 calcId 對應
repeated Qot_Common.IndicatorOutputParam outputs = 2; // 輸出線元數據
repeated IndicatorOutputRow outputRows = 3; // 計算結果，按時間順序
}
message Response
{
required int32 retType = 1 [default = -400]; //RetType，返回結果
optional string retMsg = 2;
optional int32 errCode = 3;
optional S2C s2c = 4;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
- 指標輸出參數結構參見 IndicatorOutputParam
- 發起指標計算參見 Qot_RequestIndicatorCalc
- 接口調用結果，結構參見 RetType
協議 ID
3261
virtual void OnPush_PushIndicatorCalc(FTAPI_Conn client, QotPushIndicatorCalc.Response rsp);
介紹
指標異步計算結果推送，與 Qot_RequestIndicatorCalc 通過 calcId 配對。
參數
無 Request。發起 Qot_RequestIndicatorCalc 後被動接收推送。
返回
message IndicatorOutputRow
{
optional string time = 1;
repeated double values = 2;
}
message S2C
{
required string calcId = 1;
repeated Qot_Common.IndicatorOutputParam outputs = 2;
repeated IndicatorOutputRow outputRows = 3;
}
message Response
{
required int32 retType = 1 [default = -400];
optional string retMsg = 2;
optional int32 errCode = 3;
optional S2C s2c = 4;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
- 指標輸出參數結構參見 IndicatorOutputParam
- 發起指標計算參見 Qot_RequestIndicatorCalc
- 接口調用結果，結構參見 RetType
- Example
1
- Output
1
void onPush_PushIndicatorCalc(FTAPI_Conn client, QotPushIndicatorCalc.Response rsp);
介紹
指標異步計算結果推送，與 Qot_RequestIndicatorCalc 通過 calcId 配對。
參數
無 Request。發起 Qot_RequestIndicatorCalc 後被動接收推送。
返回
message IndicatorOutputRow
{
optional string time = 1;
repeated double values = 2;
}
message S2C
{
required string calcId = 1;
repeated Qot_Common.IndicatorOutputParam outputs = 2;
repeated IndicatorOutputRow outputRows = 3;
}
message Response
{
required int32 retType = 1 [default = -400];
optional string retMsg = 2;
optional int32 errCode = 3;
optional S2C s2c = 4;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
- 指標輸出參數結構參見 IndicatorOutputParam
- 發起指標計算參見 Qot_RequestIndicatorCalc
- 接口調用結果，結構參見 RetType
- Example
1
- Output
1
virtual void OnPush_PushIndicatorCalc(const Qot_PushIndicatorCalc::Response &stRsp) = 0;
介紹
指標異步計算結果推送，與 Qot_RequestIndicatorCalc 通過 calcId 配對。
參數
無 Request。發起 Qot_RequestIndicatorCalc 後被動接收推送。
返回
message IndicatorOutputRow
{
optional string time = 1;
repeated double values = 2;
}
message S2C
{
required string calcId = 1;
repeated Qot_Common.IndicatorOutputParam outputs = 2;
repeated IndicatorOutputRow outputRows = 3;
}
message Response
{
required int32 retType = 1 [default = -400];
optional string retMsg = 2;
optional int32 errCode = 3;
optional S2C s2c = 4;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
- 指標輸出參數結構參見 IndicatorOutputParam
- 發起指標計算參見 Qot_RequestIndicatorCalc
- 接口調用結果，結構參見 RetType
- Example
class Program : public FTSPI_Qot, public FTSPI_Conn
{
public:
Program() {
m_pQotApi = FTAPI::CreateQotApi();
m_pQotApi->RegisterQotSpi(this);
m_pQotApi->RegisterConnSpi(this);
}
~Program() {
if (m_pQotApi != nullptr) {
m_pQotApi->UnregisterQotSpi();
m_pQotApi->UnregisterConnSpi();
FTAPI::ReleaseQotApi(m_pQotApi);
m_pQotApi = nullptr;
}
}
void Start() {
m_pQotApi->InitConnect("127.0.0.1", 11111, false);
}
virtual void OnInitConnect(FTAPI_Conn* pConn, Futu::i64_t nErrCode, const char* strDesc) {
// 通過 Qot_RegQotPush 註冊推送，或直接發起 Qot_RequestIndicatorCalc 後被動接收
}
// 註冊 Spi 後，當 OpenD 完成指標計算將通過此回調被動推送結果
virtual void OnPush_PushIndicatorCalc(const Qot_PushIndicatorCalc::Response &stRsp) {
string resp_str;
ProtoBufToBodyData(stRsp, resp_str);
cout << UTF8ToLocal(resp_str) << endl;
}
protected:
FTAPI_Qot *m_pQotApi;
};
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
websocket.on("PushIndicatorCalc", (res) => { ... });
介紹
指標異步計算結果推送，與 Qot_RequestIndicatorCalc 通過 calcId 配對。
參數
無 Request。發起 Qot_RequestIndicatorCalc 後被動接收推送。
返回
message IndicatorOutputRow
{
optional string time = 1;
repeated double values = 2;
}
message S2C
{
required string calcId = 1;
repeated Qot_Common.IndicatorOutputParam outputs = 2;
repeated IndicatorOutputRow outputRows = 3;
}
message Response
{
required int32 retType = 1 [default = -400];
optional string retMsg = 2;
optional int32 errCode = 3;
optional S2C s2c = 4;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
- 指標輸出參數結構參見 IndicatorOutputParam
- 發起指標計算參見 Qot_RequestIndicatorCalc
- 接口調用結果，結構參見 RetType
- Example
import ftWebsocket from "futu-api";
import { Common, Qot_Common } from "futu-api/proto";
import beautify from "js-beautify";
function QotPushIndicatorCalc(){
const { RetType } = Common
const { KLType, IndicatorLangType, QotMarket } = Qot_Common
let [addr, port, enable_ssl, key] = ["127.0.0.1", 33333, false, '7522027ccf5a06b1'];
let websocket = new ftWebsocket();
// 註冊指標異步計算結果推送回調，與 RequestIndicatorCalc 返回的 calcId 配對
websocket.onPush_PushIndicatorCalc = (qotPushIndicatorCalc)=>{
let { errCode, retMsg, retType, s2c } = qotPushIndicatorCalc
console.log("PushIndicatorCalc: errCode %d, retMsg %s, retType %d", errCode, retMsg, retType);
if(retType == RetType.RetType_Succeed){
let data = beautify(JSON.stringify(s2c), { indent_size: 2, space_in_empty_paren: true });
console.log(data);
}
};
websocket.onlogin = (ret, msg)=>{
if (ret) {
// 發起一次 MACD 指標計算，結果由上面的回調推送回來
const req = {
c2s: {
shortName: "MACD",
langType: IndicatorLangType.IndicatorLangType_MyLang,
data: {
security: { market: QotMarket.QotMarket_HK_Security, code: "00700" },
klType: KLType.KLType_Day,
kLine: [
{ time: 1700000000, open: 310.0, close: 315.0, high: 318.0, low: 308.0, volume: 10000000, turnover: 3150000000 }
]
},
},
};
websocket.RequestIndicatorCalc(req)
.then((res)=>{ console.log("RequestIndicatorCalc calcId:", res.s2c && res.s2c.calcId); })
.catch((error)=>{ console.log("error:", error); });
} else {
console.log("start error", msg);
}
};
websocket.start(addr, port, enable_ssl, key);
setTimeout(()=>{ websocket.stop(); process.exit(); }, 5000);
}
QotPushIndicatorCalc()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
- Output
RequestIndicatorCalc calcId: 1700000000000-0
PushIndicatorCalc: errCode 0, retMsg , retType 0
{
"calcId": "1700000000000-0",
"outputs": [
{ "index": 0, "name": "DIF", "type": 1 },
{ "index": 1, "name": "DEA", "type": 1 },
{ "index": 2, "name": "MACD", "type": 1 }
],
"outputRows": [
{ "time": "1700000000", "values": [0.5234, 0.4123, 0.2222] }
]
}
1
2
3
4
5
6
7
8
9
10
11
12
13
2
3
4
5
6
7
8
9
10
11
12
13
- Python
- Proto
- C#
- Java
- C++
- JavaScript
IndicatorCalcHandlerBase.on_recv_rsp(rsp_pb)
介紹
指標異步計算結果推送回調。在通過 request_indicator_calc_async 發起指標計算後，OpenD 異步推送計算結果到此回調。回調與請求通過 calc_id 配對。
參數
無。註冊指標計算結果推送回調後被動接收。
返回
參數 類型 說明 ret RET_CODE 接口調用結果 data pd.DataFrame 當 ret == RET_OK，返回指標計算結果 DataFrame 欄位說明：
欄位 類型 說明 calc_id str 計算任務 ID，與發起請求時返回的 calc_id 對應 time str K 線時間（與請求中的 K 線時間一致） output_name str 輸出線名稱 value float 該時刻的輸出值
Example
from moomoo import *
class IndicatorCalcTest(IndicatorCalcHandlerBase):
def on_recv_rsp(self, rsp_pb):
ret_code, data = super(IndicatorCalcTest, self).on_recv_rsp(rsp_pb)
if ret_code != RET_OK:
print("IndicatorCalcTest: error, msg: %s" % data)
return RET_ERROR, data
print("IndicatorCalcTest", data)
return RET_OK, data
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
handler = IndicatorCalcTest()
quote_ctx.set_handler(handler)
# 之後調用 request_indicator_calc_async 發起計算
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
2
3
4
5
6
7
8
9
10
11
12
13
14
15
# Qot_PushIndicatorCalc.proto
介紹
指標異步計算結果推送，與 Qot_RequestIndicatorCalc 通過 calcId 配對。
參數
無 Request。發起 Qot_RequestIndicatorCalc 後被動接收推送。
返回
message IndicatorOutputRow
{
optional string time = 1;
repeated double values = 2;
}
message S2C
{
required string calcId = 1;
repeated Qot_Common.IndicatorOutputParam outputs = 2;
repeated IndicatorOutputRow outputRows = 3;
}
message Response
{
required int32 retType = 1 [default = -400];
optional string retMsg = 2;
optional int32 errCode = 3;
optional S2C s2c = 4;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
- 指標輸出參數結構參見 IndicatorOutputParam
- 發起指標計算參見 Qot_RequestIndicatorCalc
- 接口調用結果，結構參見 RetType
協議 ID
3261
virtual void OnPush_PushIndicatorCalc(MMAPI_Conn client, QotPushIndicatorCalc.Response rsp);
介紹
指標異步計算結果推送，與 Qot_RequestIndicatorCalc 通過 calcId 配對。
參數
無 Request。發起 Qot_RequestIndicatorCalc 後被動接收推送。
返回
message IndicatorOutputRow
{
optional string time = 1;
repeated double values = 2;
}
message S2C
{
required string calcId = 1;
repeated Qot_Common.IndicatorOutputParam outputs = 2;
repeated IndicatorOutputRow outputRows = 3;
}
message Response
{
required int32 retType = 1 [default = -400];
optional string retMsg = 2;
optional int32 errCode = 3;
optional S2C s2c = 4;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
- 指標輸出參數結構參見 IndicatorOutputParam
- 發起指標計算參見 Qot_RequestIndicatorCalc
- 接口調用結果，結構參見 RetType
- Example
1
- Output
1
void onPush_PushIndicatorCalc(MMAPI_Conn client, QotPushIndicatorCalc.Response rsp);
介紹
指標異步計算結果推送，與 Qot_RequestIndicatorCalc 通過 calcId 配對。
參數
無 Request。發起 Qot_RequestIndicatorCalc 後被動接收推送。
返回
message IndicatorOutputRow
{
optional string time = 1;
repeated double values = 2;
}
message S2C
{
required string calcId = 1;
repeated Qot_Common.IndicatorOutputParam outputs = 2;
repeated IndicatorOutputRow outputRows = 3;
}
message Response
{
required int32 retType = 1 [default = -400];
optional string retMsg = 2;
optional int32 errCode = 3;
optional S2C s2c = 4;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
- 指標輸出參數結構參見 IndicatorOutputParam
- 發起指標計算參見 Qot_RequestIndicatorCalc
- 接口調用結果，結構參見 RetType
- Example
1
- Output
1
virtual void OnPush_PushIndicatorCalc(const Qot_PushIndicatorCalc::Response &stRsp) = 0;
介紹
指標異步計算結果推送，與 Qot_RequestIndicatorCalc 通過 calcId 配對。
參數
無 Request。發起 Qot_RequestIndicatorCalc 後被動接收推送。
返回
message IndicatorOutputRow
{
optional string time = 1;
repeated double values = 2;
}
message S2C
{
required string calcId = 1;
repeated Qot_Common.IndicatorOutputParam outputs = 2;
repeated IndicatorOutputRow outputRows = 3;
}
message Response
{
required int32 retType = 1 [default = -400];
optional string retMsg = 2;
optional int32 errCode = 3;
optional S2C s2c = 4;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
- 指標輸出參數結構參見 IndicatorOutputParam
- 發起指標計算參見 Qot_RequestIndicatorCalc
- 接口調用結果，結構參見 RetType
- Example
class Program : public MMSPI_Qot, public MMSPI_Conn
{
public:
Program() {
m_pQotApi = MMAPI::CreateQotApi();
m_pQotApi->RegisterQotSpi(this);
m_pQotApi->RegisterConnSpi(this);
}
~Program() {
if (m_pQotApi != nullptr) {
m_pQotApi->UnregisterQotSpi();
m_pQotApi->UnregisterConnSpi();
MMAPI::ReleaseQotApi(m_pQotApi);
m_pQotApi = nullptr;
}
}
void Start() {
m_pQotApi->InitConnect("127.0.0.1", 11111, false);
}
virtual void OnInitConnect(MMAPI_Conn* pConn, Moomoo::i64_t nErrCode, const char* strDesc) {
// 通過 Qot_RegQotPush 註冊推送，或直接發起 Qot_RequestIndicatorCalc 後被動接收
}
// 註冊 Spi 後，當 OpenD 完成指標計算將通過此回調被動推送結果
virtual void OnPush_PushIndicatorCalc(const Qot_PushIndicatorCalc::Response &stRsp) {
string resp_str;
ProtoBufToBodyData(stRsp, resp_str);
cout << UTF8ToLocal(resp_str) << endl;
}
protected:
MMAPI_Qot *m_pQotApi;
};
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
websocket.on("PushIndicatorCalc", (res) => { ... });
介紹
指標異步計算結果推送，與 Qot_RequestIndicatorCalc 通過 calcId 配對。
參數
無 Request。發起 Qot_RequestIndicatorCalc 後被動接收推送。
返回
message IndicatorOutputRow
{
optional string time = 1;
repeated double values = 2;
}
message S2C
{
required string calcId = 1;
repeated Qot_Common.IndicatorOutputParam outputs = 2;
repeated IndicatorOutputRow outputRows = 3;
}
message Response
{
required int32 retType = 1 [default = -400];
optional string retMsg = 2;
optional int32 errCode = 3;
optional S2C s2c = 4;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
- 指標輸出參數結構參見 IndicatorOutputParam
- 發起指標計算參見 Qot_RequestIndicatorCalc
- 接口調用結果，結構參見 RetType
- Example
import mmWebsocket from "moomoo-api";
import { Common, Qot_Common } from "moomoo-api/proto";
import beautify from "js-beautify";
function QotPushIndicatorCalc(){
const { RetType } = Common
const { KLType, IndicatorLangType, QotMarket } = Qot_Common
let [addr, port, enable_ssl, key] = ["127.0.0.1", 33333, false, '7522027ccf5a06b1'];
let websocket = new mmWebsocket();
// 註冊指標異步計算結果推送回調，與 RequestIndicatorCalc 返回的 calcId 配對
websocket.onPush_PushIndicatorCalc = (qotPushIndicatorCalc)=>{
let { errCode, retMsg, retType, s2c } = qotPushIndicatorCalc
console.log("PushIndicatorCalc: errCode %d, retMsg %s, retType %d", errCode, retMsg, retType);
if(retType == RetType.RetType_Succeed){
let data = beautify(JSON.stringify(s2c), { indent_size: 2, space_in_empty_paren: true });
console.log(data);
}
};
websocket.onlogin = (ret, msg)=>{
if (ret) {
// 發起一次 MACD 指標計算，結果由上面的回調推送回來
const req = {
c2s: {
shortName: "MACD",
langType: IndicatorLangType.IndicatorLangType_MyLang,
data: {
security: { market: QotMarket.QotMarket_HK_Security, code: "00700" },
klType: KLType.KLType_Day,
kLine: [
{ time: 1700000000, open: 310.0, close: 315.0, high: 318.0, low: 308.0, volume: 10000000, turnover: 3150000000 }
]
},
},
};
websocket.RequestIndicatorCalc(req)
.then((res)=>{ console.log("RequestIndicatorCalc calcId:", res.s2c && res.s2c.calcId); })
.catch((error)=>{ console.log("error:", error); });
} else {
console.log("start error", msg);
}
};
websocket.start(addr, port, enable_ssl, key);
setTimeout(()=>{ websocket.stop(); process.exit(); }, 5000);
}
QotPushIndicatorCalc()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
- Output
RequestIndicatorCalc calcId: 1700000000000-0
PushIndicatorCalc: errCode 0, retMsg , retType 0
{
"calcId": "1700000000000-0",
"outputs": [
{ "index": 0, "name": "DIF", "type": 1 },
{ "index": 1, "name": "DEA", "type": 1 },
{ "index": 2, "name": "MACD", "type": 1 }
],
"outputRows": [
{ "time": "1700000000", "values": [0.5234, 0.4123, 0.2222] }
]
}
1
2
3
4
5
6
7
8
9
10
11
12
13
2
3
4
5
6
7
8
9
10
11
12
13