Skip to main content

Pika Python AMQP Client Library

Project description

Version Downloads Status Coverage License

Introduction

Pika is a pure-Python implementation of the AMQP 0-9-1 protocol that tries to stay fairly independent of the underlying network support library.

  • Python 2.6+ and 3.3+ are supported.

  • Since threads aren’t appropriate to every situation, it doesn’t require threads. It takes care not to forbid them, either. The same goes for greenlets, callbacks, continuations and generators. It is not necessarily thread-safe however, and your mileage will vary.

  • People may be using direct sockets, plain old select(), or any of the wide variety of ways of getting network events to and from a python application. Pika tries to stay compatible with all of these, and to make adapting it to a new environment as simple as possible.

Documentation

Pika’s documentation can be found at https://pika.readthedocs.org

Example

Here is the most simple example of use, sending a message with the BlockingConnection adapter:

import pika
connection = pika.BlockingConnection()
channel = connection.channel()
channel.basic_publish(exchange='example',
                      routing_key='test',
                      body='Test Message')
connection.close()

And an example of writing a blocking consumer:

import pika
connection = pika.BlockingConnection()
channel = connection.channel()

for method_frame, properties, body in channel.consume('test'):

    # Display the message parts and ack the message
    print method_frame, properties, body
    channel.basic_ack(method_frame.delivery_tag)

    # Escape out of the loop after 10 messages
    if method_frame.delivery_tag == 10:
        break

# Cancel the consumer and return any pending messages
requeued_messages = channel.cancel()
print 'Requeued %i messages' % requeued_messages
connection.close()

Pika provides the following adapters

  • BlockingConnection - enables blocking, synchronous operation on top of library for simple uses

  • LibevConnection - adapter for use with the libev event loop http://libev.schmorp.de

  • SelectConnection - fast asynchronous adapter

  • TornadoConnection - adapter for use with the Tornado IO Loop http://tornadoweb.org

  • TwistedConnection - adapter for use with the Twisted asynchronous package http://twistedmatrix.com/

Contributing

To contribute to pika, please make sure that any new features or changes to existing functionality include test coverage. Additionally, please format your code using yapf with google style prior to issuing your pull request.

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

pika-0.10.0b2.tar.gz (81.7 kB view details)

Uploaded Source

Built Distribution

pika-0.10.0b2-py2.py3-none-any.whl (92.7 kB view details)

Uploaded Python 2Python 3

File details

Details for the file pika-0.10.0b2.tar.gz.

File metadata

  • Download URL: pika-0.10.0b2.tar.gz
  • Upload date:
  • Size: 81.7 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No

File hashes

Hashes for pika-0.10.0b2.tar.gz
Algorithm Hash digest
SHA256 f54e133dc0130420889e64cf0f2df8d6c7a67647c37a80b4f56350bd3a83d29a
MD5 37de4ad1433ca2e9614e722d17e74de2
BLAKE2b-256 82ccbbf6c8218eb5a4776f10b9f9f2ffb94ce7d4f2767261348ba0ef5323cd3b

See more details on using hashes here.

File details

Details for the file pika-0.10.0b2-py2.py3-none-any.whl.

File metadata

File hashes

Hashes for pika-0.10.0b2-py2.py3-none-any.whl
Algorithm Hash digest
SHA256 4b34fd677aec6d3519e672aa33810badfd94c6c1731f9f36583128285de69340
MD5 6eabc33b3131622171ab54fb22a217a6
BLAKE2b-256 7d3cea655579100254db42ae244333c94de558c146ece4dd709a77c37195f5d5

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page