semvec/pypi-packages huggingface dataset:
sanic-amqp-extension 0.2.0
AMQP support for Sanic framework
License: BSD

sanic-amqp-extension
####################
AMQP support for Sanic framework

Features
========
- Based on the aioamqp_ library
- Provides an opportunity to implement workers that works in background

Installation
============
This package should be installed using pip: ::

    pip install sanic-amqp-extension

Example
=======
.. code-block:: python

    from sanic import Sanic, response
    from sanic_amqp_ext import AmqpExtension, AmqpWorker


    app = Sanic(__name__)
    # Configuration for RabbitMQ
    app.config.update({
        "AMQP_USERNAME": "guest",
        "AMQP_PASSWORD": "guest",
        "AMQP_HOST": "localhost",
        "AMQP_PORT": 5672,
        "AMQP_VIRTUAL_HOST": "vhost",
        "AMQP_USING_SSL": False,
    })
    AmqpExtension(app) # AMQP is available as `app.amqp` or `app.extensions['amqp']`


    class CustomWorker(AmqpWorker):

        async def run(self, *args, **kwargs):
            transport, protocol = await self.connect()  # create a new connection
            # and do some stuff here ...

    # Register workers after initializing the extension
    app.amqp.register_worker(CustomWorker(app))


    @app.route("/")
    async def handle(request):
        transport, protocol = await request.app.amqp.connect()  # create a new connection
        # do some stuff here ...
        # P.S. but don't forget to close the connection after using
        return response.text("It's works!")

License
=======
The sanic-amqp-extension is published under BSD license. For more details read LICENSE_ file.

.. _links:
.. _aioamqp: http://aioamqp.readthedocs.io/
.. _LICENSE: https://github.com/Relrin/sanic-amqp-extension/blob/master/LICENSE

Real project examples
=====================
Open Matchmaking project:  

- `Auth/Auth microservice <https://github.com/OpenMatchmaking/microservice-auth/>`_
- `Game servers pool microservice <https://github.com/OpenMatchmaking/microservice-game-servers-pool/>`_
- `Player statistics microservice <https://github.com/OpenMatchmaking/microservice-player-statistics/>`_