# 指标异步计算结果推送
- Python
- Proto
- C#
- Java
- C++
- JavaScript
class IndicatorCalcHandlerBase(RspHandlerBase)
介绍
指标异步计算结果推送回调基类。当
request_indicator_calc_async发起的计算任务完成后，服务端会通过该回调主动推送结果。用户继承IndicatorCalcHandlerBase并重写on_recv_rsp方法接收推送，通过calc_id与发起的请求配对。参数
on_recv_rsp 回调返回 (ret_code, content)，content 为 dict：
参数 类型 说明 calc_id str 计算任务 ID，与 request_indicator_calc_async返回的 calc_id 对应outputs list 输出线元数据，每项含 index、name output_rows list 计算结果，按时间顺序，每项含 time 与 values（与 outputs 一一对应） Example
from futu import *
class IndicatorCalcHandler(IndicatorCalcHandlerBase):
def on_recv_rsp(self, rsp_pb):
ret_code, content = super(IndicatorCalcHandler, self).on_recv_rsp(rsp_pb)
if ret_code != RET_OK:
print('IndicatorCalc error:', content)
return RET_ERROR, content
print('收到指标计算结果推送:')
print(' calc_id:', content['calc_id'])
print(' outputs:', content['outputs'])
print(' rows:', len(content['output_rows']))
return RET_OK, content
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
quote_ctx.set_handler(IndicatorCalcHandler())
# 通过 request_indicator_calc_async 发起计算后，结果会异步推送至上述 handler
import time
try:
while True:
time.sleep(1)
except KeyboardInterrupt:
pass
quote_ctx.close()
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
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
# Qot_PushIndicatorCalc.proto
介绍
指标异步计算结果推送（服务端主动推送）。与 Qot_RequestIndicatorCalc(3260) 通过 calcId 配对，无需客户端发送请求。
返回
//一行计算结果，对应一个 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, uint nSerialNo, Qot_PushIndicatorCalc.Response rsp);
介绍
指标异步计算结果推送回调。需通过
RequestIndicatorCalc发起计算后等待推送，使用 calcId 与请求配对。参数
//一行计算结果，对应一个 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
onPush_PushIndicatorCalc(FTAPI_Conn client, int nSerialNo, Qot_PushIndicatorCalc.Response rsp)
介绍
指标异步计算结果推送回调。需通过
requestIndicatorCalc发起计算后等待推送，使用 calcId 与请求配对。参数
//一行计算结果，对应一个 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(const Qot_PushIndicatorCalc::Response &stRsp) = 0;
介绍
指标异步计算结果推送回调。需通过
RequestIndicatorCalc发起计算后被动接收，使用 calcId 与请求配对。参数
//一行计算结果，对应一个 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
- 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) {
// 注册成功后等待推送；实际计算请通过 RequestIndicatorCalc 主动发起
cout << "Init connect success, waiting for indicator calc push..." << endl;
}
// 指标异步计算结果推送回调
virtual void OnPush_PushIndicatorCalc(const Qot_PushIndicatorCalc::Response &stRsp) {
string resp_str;
ProtoBufToBodyData(stRsp, resp_str);
cout << "PushIndicatorCalc: " << 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
37
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
协议 ID
3261
onPush_PushIndicatorCalc(qotPushIndicatorCalc)
介绍
指标异步计算结果推送回调。需通过
RequestIndicatorCalc发起计算后被动接收，使用 calcId 与请求配对。参数
//一行计算结果，对应一个 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
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
说明
- 本接口仅作为推送通道，无对应的主动请求，结果由 Qot_RequestIndicatorCalc(3260) 触发。
- Python
- Proto
- C#
- Java
- C++
- JavaScript
class IndicatorCalcHandlerBase(RspHandlerBase)
介绍
指标异步计算结果推送回调基类。当
request_indicator_calc_async发起的计算任务完成后，服务端会主动推送结果。用户继承IndicatorCalcHandlerBase并重写on_recv_rsp方法接收推送，通过calc_id与请求配对。参数
on_recv_rsp 回调返回 (ret_code, content)，content 为 dict：
参数 类型 说明 calc_id str 计算任务 ID outputs list 输出线元数据 output_rows list 计算结果，按时间顺序 Example
from moomoo import *
class IndicatorCalcHandler(IndicatorCalcHandlerBase):
def on_recv_rsp(self, rsp_pb):
ret_code, content = super(IndicatorCalcHandler, self).on_recv_rsp(rsp_pb)
if ret_code != RET_OK:
print('IndicatorCalc error:', content)
return RET_ERROR, content
print('收到指标计算结果推送:')
print(' calc_id:', content['calc_id'])
return RET_OK, content
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
quote_ctx.set_handler(IndicatorCalcHandler())
import time
try:
while True:
time.sleep(1)
except KeyboardInterrupt:
pass
quote_ctx.close()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
# Qot_PushIndicatorCalc.proto
介绍
指标异步计算结果推送（服务端主动推送）。与 Qot_RequestIndicatorCalc(3260) 通过 calcId 配对，无需客户端发送请求。
返回
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, uint nSerialNo, Qot_PushIndicatorCalc.Response rsp);
介绍
指标异步计算结果推送回调。需通过
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
onPush_PushIndicatorCalc(MMAPI_Conn client, int nSerialNo, Qot_PushIndicatorCalc.Response rsp)
介绍
指标异步计算结果推送回调。需通过
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(const Qot_PushIndicatorCalc::Response &stRsp) = 0;
介绍
指标异步计算结果推送回调。需通过
RequestIndicatorCalc发起计算后被动接收，使用 calcId 与请求配对。参数
//一行计算结果，对应一个 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
- 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) {
// 注册成功后等待推送；实际计算请通过 RequestIndicatorCalc 主动发起
cout << "Init connect success, waiting for indicator calc push..." << endl;
}
// 指标异步计算结果推送回调
virtual void OnPush_PushIndicatorCalc(const Qot_PushIndicatorCalc::Response &stRsp) {
string resp_str;
ProtoBufToBodyData(stRsp, resp_str);
cout << "PushIndicatorCalc: " << 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
37
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
协议 ID
3261
onPush_PushIndicatorCalc(qotPushIndicatorCalc)
介绍
指标异步计算结果推送回调。需通过
RequestIndicatorCalc发起计算后被动接收，使用 calcId 与请求配对。参数
//一行计算结果，对应一个 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
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
说明
- 本接口仅作为推送通道，无对应的主动请求，结果由 Qot_RequestIndicatorCalc(3260) 触发。