Extends sprockets.mixins.amqp to publish RabbitMQ messages as Avro datum
Find a file
2022-03-08 12:14:19 -05:00
.github/workflows Dont ignore setup.* 2020-03-18 11:48:55 -04:00
docs Release 3.0.1 2022-03-08 12:14:19 -05:00
requires Add support for fastavro<2 2022-02-08 11:40:36 -05:00
sprockets Release 3.0.1 2022-03-08 12:14:19 -05:00
tests Flake8: fixes after running flake8 2020-03-17 15:15:13 +05:30
.gitignore Refactor to reflect changes to sprockets.mixins.amqp 2017-05-03 22:44:37 -04:00
LICENSE Changes to travis, Liscense and readme.rst file 2020-03-16 16:42:35 +05:30
MANIFEST.in Replace Avro publisher internals with latest internal version 2017-04-25 13:32:46 -04:00
README.rst Add support for fastavro<2 2022-02-08 11:40:36 -05:00
setup.cfg Changes to the setup files 2020-03-16 16:41:49 +05:30
setup.py Release 3.0.1 2022-03-08 12:14:19 -05:00

sprockets.mixins.avro-publisher
===============================
AMQP Publishing Mixin for publishing a message as an Avro datum.

|Version| |Downloads|

Installation
------------
``sprockets.mixins.avro-publisher`` is available on the
`Python Package Index <https://pypi.python.org/pypi/sprockets.mixins.avro-publisher>`_
and can be installed via ``pip`` or ``easy_install``:

.. code-block:: bash

   pip install sprockets.mixins.avro-publisher

Requirements
------------
- sprockets.mixins.amqp>=3.0.0
- fastavro>=0.10.1,<2.0.0
- tornado>=6,<7

Example
-------
This examples demonstrates the most basic usage of ``sprockets.mixins.avro-publisher``

.. code:: bash

   export AMQP_URL="amqp://user:password@rabbitmq_host:5672/%2f"
   python my-example-app.py


.. code:: python

   from tornado import gen
   from tornado import web
   from sprockets.mixins import avro_publisher

   def make_app(**settings):
       settings = {'avro_schema_uri_format': 'http://my-schema-repository/%(name)s.avsc'}
       application = web.Application(
           [
               web.url(r'/', RequestHandler),
           ], **settings)

       avro_publisher.install(application)
       return application

   class RequestHandler(avro_publisher.PublishingMixin, web.RequestHandler):

       async def get(self, *args, **kwargs):
           body = {'request': self.request.path, 'args': args, 'kwargs': kwargs}
           await self.avro_amqp_publish(
               'exchange',
               'routing.key',
               'avro-schema-name'
               body)

   if __name__ == "__main__":
       application = make_app()
       application.listen(8888)
       logging.basicConfig(level=logging.INFO)
       ioloop.IOLoop.current().start()


Source
------
``sprockets.mixins.avro-publisher`` source is available on Github at `https://github.com/sprockets/sprockets.mixins.avro-publisher <https://github.com/sprockets/sprockets.mixins.avro_publisher>`_

License
-------
``sprockets.mixins.avro-publisher`` is released under the `3-Clause BSD license <https://github.com/sprockets/sprockets.mixins.avro-publisher/blob/master/LICENSE>`_.

.. |Version| image:: https://badge.fury.io/py/sprockets.mixins.avro-publisher.svg?
   :target: http://badge.fury.io/py/sprockets.mixins.avro-publisher

.. |Downloads| image:: https://pypip.in/d/sprockets.mixins.avro-publisher/badge.svg?
   :target: https://pypi.python.org/pypi/sprockets.mixins.avro-publisher