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('divide')
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.divide(5, 2) == 2.5
with pytest.raises(ZeroDivisionError):
client.divide(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.15.tar.gz
(4.0 kB
view hashes)
Built Distribution
Close
Hashes for mause_rpc-0.0.15-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | ad49734f3ad6cd0170bfaaa4ad6cd4bd851294852d7e66e2d7b717dbf88bf84f |
|
MD5 | e4072d1a5692aafa54536237a8279ddc |
|
BLAKE2b-256 | 4f393baffbdc29d54eb02bb8ec5c8b158ccf13d70174340dfc56a94800d3793d |