简述
这是对 RabbitMQ 的 Pika 库进行封装的，一套简易 RPC 客户端/服务端库。
安装说明
pip install rabbit-rpc
使用事例
服务端
# project/consumers.py
from rabbit_rpc.consumer import consumer
@consumer(name='add')
def add(a, b):
return a + b
# project shell
rabbit_rpc worker --amqp 'amqp://guest:guest@localhost:5672/'
# with django
rabbit_rpc worker --amqp 'amqp://guest:guest@localhost:5672/' --django
客户端
from rabbit_rpc.client import RPCClient client = RPCClient(amqp_url='amqp://guest:guest@localhost:5672/') ret = client.call_add(1, 1, timeout=1) # or ignore result client.call_add(1, 1, ignore_result=True) # specify routing_key client.call_add(1, 1, routing_key='default')
1 maintainer
Metadata
1 maintainer
Release files for rabbit-rpc 0.0.2
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| rabbit_rpc-0.0.2-py2-none-any.whl | Python 2 | none | any | Details |
Release files / rabbit_rpc-0.0.2-py2-none-any.whl
| Download URL | rabbit_rpc-0.0.2-py2-none-any.whl |
|---|---|
| Size | 11.6 kB |
| Tags | Python 2 |
|
SHA-256 checksum How to use checksums |
9d4a70ec4144f0e6a19865f31d0912131d8fb79dfadfdfe3adfd9bc81e61835a
|
|
BLAKE2b-256 checksum How to use checksums |
7983786bf036288e349329577dc40c316f52eda416e83e0229e1e17f71bc2460
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
