def ReqConnect(self, pAddress: str):
        """连接行情前置

        :param pAddress:
        """
        self.q.CreateApi()
        spi = self.q.CreateSpi()
        self.q.RegisterSpi(spi)

        self.q.OnFrontConnected = self._OnFrontConnected
        self.q.OnFrontDisconnected = self._OnFrontDisConnected
        self.q.OnRspUserLogin = self._OnRspUserLogin
        self.q.OnRtnDepthMarketData = self._OnRtnDepthMarketData
        self.q.OnRspSubMarketData = self._OnRspSubMarketData

        self.q.RegCB()

        self.q.RegisterFront(pAddress)
        self.q.Init()
def ReqConnect ( self , pAddress : str ) : self . q . CreateApi ( ) spi = self . q . CreateSpi ( ) self . q . RegisterSpi ( spi ) self . q . OnFrontConnected = self . _OnFrontConnected self . q . OnFrontDisconnected = self . _OnFrontDisConnected self . q . OnRspUserLogin = self . _OnRspUserLogin self . q . OnRtnDepthMarketData = self . _OnRtnDepthMarketData self . q . OnRspSubMarketData = self . _OnRspSubMarketData self . q . RegCB ( ) self . q . RegisterFront ( pAddress ) self . q . Init ( )
连接行情前置

        :param pAddress: