1. 主页
  2. 文档
  3. 帮助文档
  4. 基础数据
  5. 连接

连接

系统默认提供一个免费的连接服务器,如果发现无法连接可以切换服务器地址。

连接成功后方可操作各种业务接口。

连接方式

  • 同步连接 (默认)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)
这篇文章对您有用吗?

我们要如何帮助您?