系统默认提供一个免费的连接服务器,如果发现无法连接可以切换服务器地址。
连接成功后方可操作各种业务接口。
连接方式:
- 同步连接 (默认)connect()
- 异步连接 syncconnect()
示例:
# 默认采用同步连接
dd = dsxquant.dataser()
if dd.connect():
# 读取行业分类
result = dd.get_hangye().series()
print(result)
框架支持with语法
# with语法框架设计了自动连接,如果连接不成功会返回None,所以这里判断一下即可
with dsxquant.dataser() as dd:
# 连接成功可调用
if dd:
result = dd.get_quotes("sh000001").datas()
print(result.data)
异步订阅模式
# 异步订阅模式,订阅模式请求是异步进行的,订阅成功后服务器会主动推送信息到您的回调函数中,注意请不要手动调用关闭连接方法
dd_async = dsxquant.dataser.asyncconnect()
if dd_async:
# 异步请求实时行情接口,服务器会主动推送实时行情
def quotes_callback(response:dsxquant.parser):
# logger.debug(response.get("msg"))
result = response.dataframe()
logger.debug(result)
pass
result = dd_async.sub_quotes("sh000001,sh600000,sz000001,bj430047,bj430090",quotes_callback)
logger.debug(result)