Python interface for simple usage of AMQP middleware applications.
Project description
PyAMQP
Python interface for simple usage of AMQP middleware applications.
This interface is made to ease the process of using AMQP software.
The applications supported so far:
- RabbitMQ: This is a popular open-source message-broker that implemented the Advanced Message Queuing Protocol (AMQP) written in the Erlang programming language
How to get it
pip install pyamqp
Dependencies
Pika: 0.13 or higher
pytest: 4.0.2 or higher
Usage example
RabbitMQ - Receiver
from pyamqp.rabbit.receiver import Receiver
# Initializing and creating the connection with the Rabbit server
receiver_instance = Receiver(host='18.222.222.222',
port=5672,
user='guest',
password='1245554221')
# Declares the queue with the specified parameters,
# binds it to an exchange using the routing_keys list.
receiver_instance.connect_queue(queue_name='test',
exchange='test_exchange',
routing_keys=['A', 'B'],
is_durable=True,
auto_delete=False)
# callback function
# Not necesary if inheritance is used
def get_message(message, details):
some_value = message.get('some_key', None)
print(some_value)
receiver_instance.consume(callback_function=get_message,
no_ack=True,
consumer_tag='AAAAKKK_2232')
Rabbit-Dispatcher
from pyamqp.rabbit.dispatcher import Dispatcher
dispatcher_instance = Dispatcher(host='18.222.222.222',
port=5672,
user='guest',
password='1245554221')
# Declaring exchanges that are going to be used for sending messages
# exchanges parameter can be an string or a list of strings
dispatcher_instance.connect_exchanges(exchanges=['test_exch', 'test_exch_2],
exchange_type='topic',
auto_delete=True)
# There can be only two types of passed messages, string or dicts.
message_1 = 'Hello'
message_2 = {'Ciao': 'Hola'}
dispatcher.send_message(message_1, 'THIS.IS.A.KEY', 'test_exch')
dispatcher.send_message(message_2, 'KEY.SOMETHING', 'test_exch_2')
Current limitations
- There's only support for BlockingConnection adapter since this is the main adapter used in production.
- Threaded Receiver class is not thread-safe, will be added using an internal instance of Queue() to address that issue.
- This packages does not support the inheritance of Receiver and Dispatcher in the same child class.
License
GNU GPLv3
Permissions of this strong copyleft license are conditioned on making available complete source code of licensed works and modifications, which include larger works using a licensed work, under the same license. Copyright and license notices must be preserved. Contributors provide an express grant of patent rights.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
PyAMQP-0.1.0.1.tar.gz
(7.0 kB
view hashes)
Built Distribution
Close
Hashes for PyAMQP-0.1.0.1-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 55e60876bee8bb29ca76dec0e46f5f05f27e8c8ac6aaa7ac469b47db99cab814 |
|
MD5 | c75f79dad3450f49fba64d5ea7c0d05f |
|
BLAKE2b-256 | f50a996c54d15b477e3b22bd17b0a289ac78969eab2839df775bc724d576f1da |