- Notifications
You must be signed in to change notification settings - Fork11
Pythonic bi-directional RPC API built on top of ØMQ.
License
NotificationsYou must be signed in to change notification settings
ticosax/pseud
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
Pythonic bidirectional-rpc API built on top of ØMQ with pluggableencryption, authentication and heartbeating support.
- ØMQ transport layer.
- All native python types supported (msgpack).
- First citizen exceptions.
- Bi-bidirectional (server can initiate calls to connected clients).
- Encryption based on CURVE.
- Pluggable Authentication.
- Pluggable Heartbeating.
- Pluggable Remote Call Routing.
- Built-in proxy support. A server can delegate the work to another one.
- SyncClient (using zmq.REQ) to use within non event based processes.(Heartbeating, Authentication and job execution are not supported withthe SyncClient.)
$pip install pseudfrompseudimportServerserver=Server('service')server.bind('tcp://127.0.0.1:5555')@server.register_rpcdefhello(name):return'Hello {0}'.format(name)awaitserver.start()# this will block forever
frompseudimportClientclient=Client('service',io_loop=loop)client.connect('tcp://127.0.0.1:5555')# Assume we are inside a coroutineasyncwithclient:response=awaitclient.hello('Charly')assertresponse=='Hello Charly'
# to use within a non-asynchronous process or in a command interpreterfrompseudimportSyncClientclient=SyncClient()client.connect('tcp://127.0.0.1:5555')assertclient.hello('Charly')=='Hello Charly'
It is important to note that the server needs to know whichpeers are connected to it.This is why the security_plugintrusted_peer comes handy.It will register all peer id and be able to route messages to each of them.
frompseudimportServerserver=Server('service',security_plugin='trusted_peer')server.bind('tcp://127.0.0.1:5555')@server.register_rpcdefhello(name):return'Hello {0}'.format(name)awaitserver.start()# this will block forever
The client needs to send its identity to the server. This is whyplainsecurity plugin is used. The server will not check the password, he will justtake into consideration the user_id to perform the routing.
frompseudimportClientclient=Client('service',security_plugin='plain',user_id='alice',password='')client.connect('tcp://127.0.0.1:5555')# Action that the client will perform when# requested by the server.@client.register_rpc(name='draw.me.a.sheep')defsheep():return'beeeh'
Back on server side, we can send to it any commands the client is able to do.
# assume we are inside a coroutinesheep=awaitserver.send_to('alice').draw.me.a.sheep()assertsheep=='beeeh'
About
Pythonic bi-directional RPC API built on top of ØMQ.
Topics
Resources
License
Stars
Watchers
Forks
Packages0
No packages published