check_rabbitmq.py 文件源码

def _build_url(self, vhost, queues=False):
        """Build the management api url for the requested entities"""

        url = self.base_url
        if queues:
            url += '/queues'

            if vhost:
                url += '/{}'.format(quote(vhost, safe=''))
        else:
            url += '/vhosts'

        samples = []
        for metric in ['lengths', 'data_rates', 'msg_rates', 'node_stats']:
            samples.append('{}_age={}'.format(metric, self.length))
            samples.append('{}_incr={}'.format(metric, self.length))

        url += '?{}'.format('&'.join(samples))

        return url