import logging
from typing import Any
-from urllib import request as rq
+from urllib import request as rq, parse as pr
log = logging.getLogger("rabbitmq_check")
log.addHandler(logging.StreamHandler())
type=str, default='15672',
help='API Port')
parser.add_argument('-V', '--vhost',
- type=str, default='openstack',
+ type=str, default='/openstack',
help='Virtual Host to operate on')
parser.add_argument('-s', '--ssl', action='store_true',
default=False, help='Use SSL (WIP)')
url, method, headers, body)
with rq.urlopen(request) as data:
- out = json.loads(data.read())
+ out = json.loads(data.read().decode('utf-8'))
return out
def __init__(self, opts: argparse.Namespace) -> None:
self.conn = APIConnector(opts)
self.opts = opts
+ self.opts.vhost = pr.quote_plus(self.opts.vhost)
def get_bindings(self):
log.info(