pika credentials from uri

amqp_uri.py

import pika

amqp_re = re.compile(r'^amqp://'\
                '((?P<username>[^:]*)[:](?P<password>[^@]*)[@])?' \
                '((?P<host>[^/:]*)([:](?P<port>[^/]*))?)' \
                '(?P<virtual_host>/[^/]*)/?' \
                '([?](?P<query>[^/]*))?$')

def pika_credentials_from_url(amqp_url = None):
    if not amqp_url:
        amqp_url = '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