base.py 文件源码

def query(self, query, requesterUsername=None, requesterPassword=None):
        headers = {
            'accept': 'application/json',
        }
        self.addBasicAuthHeader(headers, requesterUsername, requesterPassword)
        d = http.getPage(
            '%s/%s?query=%s' % (self.endpoint,
                                defaults.httpObjectCategoryName,
                                urllib.quote(query.encode('utf-8'))),
            headers=headers, method='GET')
        d.addCallback(self.checkStatus, txHttp.OK)
        d.addCallback(self.checkPayloadHas, dict.fromkeys(['ids']))
        result = yield d
        payload = result[2]
        dictionary = json.loads(payload)
        defer.returnValue(dictionary['ids'])