avroconsumer 0.1.0

Installation

avroconsumer is available on the Python package index.

Usage

To use the DatumConsumer, first you need to set the schema_path configuration setting in the rejected configuration file. The following snippet demonstrates an example configuration:

Consumers:
  apns_push:
    consumer: app.Consumer
    connections: [rabbit1]
    qty: 1
    queue: datum
    qos_prefetch: 1
    ack: True
    max_errors: 5
    config:
      schema_path: /etc/avro-schemas/

If messages are published with a AMQP type message property of foo and a content-type property of application/vnd.apache.avro.datum, the DatumConsumer will use the Avro schema file /etc/avro-schemas/foo.avsc to deserialize messages

The following example code shows how implement the DatumConsumer.

import avroconsumer

class MyConsumer(avroconsumer.DatumConsumer):

    def process(self):
        LOGGER.debug('Decoded avro datum data: %r', self.body)

As with any instance of rejected.consumer.Consumer, the avroconsumer.DatumConsumer can automatically rejected messages based upon the type message property. Simply set the MESSAGE_TYPE attribute of your consumer and any messages received that do not match that message type will be rejected. The following example demonstrates setting the message type:

import avroconsumer

class MyConsumer(avroconsumer.DatumConsumer):

    MESSAGE_TYPE = 'foo'

    def process(self):
        LOGGER.debug('Decoded avro datum data: %r', self.body)

Requirements

• avro <https://pypi.python.org/pypi/avro>

• rejected <https://pypi.python.org/pypi/rejected>