Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import pika
- amqp_re = re.compile(
- r'^amqp://'\
- '((?P<username>[^:]*)[:](?P<password>[^@]*)[@])?' \
- '((?P<host>[^/:]*)([:](?P<port>[^/]*))?)' \
- '(?P<virtual_host>/[^/]*)/?' \
- '([?](?P<query>[^/]*))?$')
- def params_from_url(amqp_url = None):
- amqp_url = amqp_url or 'amqp://127.0.0.1/'
- params = amqp_re.match(amqp_url).groupdict()
- credentials = pika.PlainCredentials(
- params['username'] or 'guest',
- params['password'] or 'guest',
- )
- conn_params = pika.ConnectionParameters(
- params['host'] or '127.0.0.1',
- port = int(params['port'] or '5672'),
- virtual_host = params['virtual_host'] or '/',
- credentials = credentials,
- )
- return conn_params
Add Comment
Please, Sign In to add comment