riak.py 文件源码

def _get_stats_from_node(self):
        agent = Agent(reactor)

        url = self.config.get('url', 'http://%s:8098/stats' % self.hostname)
        ua = self.config.get('useragent', 'Duct Riak stats checker')

        headers = Headers({'User-Agent': [ua]})
        request = yield agent.request('GET'.encode(), url.encode(), headers)

        if (request.length) and (request.code == 200):
            d = defer.Deferred()
            request.deliverBody(BodyReceiver(d))
            b = yield d
            body = b.read()
        else:
            body = "{}"

        defer.returnValue(json.loads(body))