A dumb as hell rpc implementation built on rabbitmq
Project description
Mause RPC
A dumb as hell rpc implementation built on rabbitmq
Need to write a server?
from mause_rpc.server import Server
rpc_queue = 'rpc.queue'
server = Server(rpc_queue, 'rabbitmq://...')
@server.register
def hello(name: str) -> str:
return 'hello ' + name
@server.register
def div(a: int, b: int) -> float:
if b == 0:
raise ZeroDivisionError()
return a / b
if __name__ == '__main__':
server.serve()
Need a client?
from mause_rpc.client import get_client
rpc_queue = 'rpc.queue'
client = get_client(rpc_queue, 'rabbitmq://...')
def test_basic_functionality():
assert client.hello('mark') == 'hello mark'
assert client.div(5, 2) == 2.5
with pytest.raises(ZeroDivisionError):
client.div(5, 0)
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
mause_rpc-0.0.9.tar.gz
(3.8 kB
view hashes)
Built Distribution
Close
Hashes for mause_rpc-0.0.9-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | c3706b55f431dd613bd65c6a3b5d273d4fb3aa828cb9ba3528d497c6fd02666c |
|
MD5 | 73e9e253348a87f6bd68d785172fc340 |
|
BLAKE2b-256 | 4ff88e8e4fa554079a62b322620b8212555fc3c878680fddb58dcce7a1bdc5f6 |