订阅
接口说明
注意
订阅接口必须建立MQTT长连接后,才能使用。长连接建立可参照行情推送。
功能说明:
实时行情订阅接口, 根据symbol和数据类型订阅实时行情推送。
每个AppId最多1个推送连接, 订阅topic数限制为100个, 一个symbol的一个sub_type为1个topic;
如下参数发起订阅, 则产生4个topic:
symbol: AAPL,TSLA
sub_types: QUOTE,SNAPSHOT,TICK
请求URL:/market-data/streaming/subscribe
请求方式:通过Webull SDK建立gRPC长连接,然后调用接口获取。
频次限制:每个AppId调用频次限制为10次每分钟。
请求参数
参数 | 类型 | 必填 | 说明 |
---|---|---|---|
token | String | 是 | 订阅预请求返回的token,且token需要是已经创建过连接的token;如:2d29ea02-8a35-11ec-8356-020017000b7b |
symbols | []String | 是 | 证券代码,例如: [00700,00981],单次最多50个symbol |
category | String | 是 | 证券类型,枚举,参考: 证券类型 |
sub_types | []String | 是 | 订阅数据类型,多个用逗号","分隔,枚举,参考: 订阅数据类型,如: [SNAPSHOT] |
请求示例
- Python
- Java
from webullsdktrade.grpc_api import API
from webullsdkquotescore.grpc.grpc_client import GrpcApiClient
from webullsdkcore.common.region import Region
grpc_client = GrpcApiClient(your_app_key, your_app_secret, Region.HK.value)
api = API(grpc_client)
response = api.market_data.create_subscription_rel(token, symbols, category, sub_types)
if response.status_code == 200:
print('subscribe successful')
try (QuotesApiClient quotesApiClient = QuotesApiClient.builder()
.appKey(Env.APP_KEY)
.appSecret(Env.APP_SECRET)
.regionId(Region.hk.name())
.build()) {
quotesApiClient.subscribe(token, symbols, category, subTypes);
}
响应示例
无返回值