code: def websocket_query(self, path, params={}):
          
  
          url = "http://docker/v" + self._api_version + "/" + path
          connection = yield from self._session.ws_connect(url,
                                                           origin="http://docker",
                                                           autoping=True)
          return connection
docs: Open a websocket connection
  
          :param path: Endpoint in API
          :param params: Parameters added as a query arg
          :returns: Websocket