rabbitmq-tutorials/python
2023-07-27 09:40:03 -04:00
..
emit_log_direct.py Update emit_log_direct.py 2023-07-27 09:40:03 -04:00
emit_log_topic.py Update for Pika 1.0.0, yapf formatting 2019-02-11 09:56:04 -08:00
emit_log.py Update emit_log.py to use f strings 2023-07-26 15:35:28 -04:00
new_task.py Use named constant instead of 2 in new_task.py 2021-12-06 22:13:21 +03:00
README.md Closes #285 2021-04-07 22:48:15 +03:00
receive_logs_direct.py Apply #275, #276 to more Python tutorials 2020-08-27 16:07:34 +03:00
receive_logs_topic.py Apply #275, #276 to more Python tutorials 2020-08-27 16:07:34 +03:00
receive_logs.py Apply #275, #276 to more Python tutorials 2020-08-27 16:07:34 +03:00
receive.py Apply #275, #276 to more Python tutorials 2020-08-27 16:07:34 +03:00
rpc_client.py remove while self.response is None loop 2022-06-20 11:31:26 +04:30
rpc_server.py Update for Pika 1.0.0, yapf formatting 2019-02-11 09:56:04 -08:00
send.py Update for Pika 1.0.0, yapf formatting 2019-02-11 09:56:04 -08:00
worker.py Decode body 2020-08-27 11:50:59 +02:00

Python code for RabbitMQ tutorials

Here you can find Python code examples from RabbitMQ tutorials.

To successfully use the examples you will need a running RabbitMQ server.

Requirements

To run this code you need to install the pika package version 1.0.0 or later. To install it, run

python -m pip install pika

You may first need to run

easy_install pip

Code

Tutorial one: "Hello World!":

python send.py
python receive.py

Tutorial two: Work Queues:

python new_task.py "A very hard task which takes two seconds.."
python worker.py

Tutorial three: Publish/Subscribe:

python receive_logs.py
python emit_log.py "info: This is the log message"

Tutorial four: Routing:

python receive_logs_direct.py info
python emit_log_direct.py info "The message"

Tutorial five: Topics:

python receive_logs_topic.py "*.rabbit"
python emit_log_topic.py red.rabbit Hello

Tutorial six: RPC:

python rpc_server.py
python rpc_client.py