rpyc-stream

A simple (130 loc), one-file Python RPC System that is based on Streams allowing for cross-language/SSH usage.

This is a port of the nodejs RPC system by @dominictarr.

Examples using SSH

Local Code

Python (local.py):

# -*- coding: utf-8 -*-
from rpycstream import RPC
from subprocess import Popen, PIPE, STDOUT

def main():
    # python
    worker = Popen(['ssh', 're.mo.te.ip', 'python', 'remote.py'], stdout=PIPE, stdin=PIPE, stderr=STDOUT)
    # nodejs
    # worker = Popen(['ssh', 're.mo.te.ip', 'node', 'remote.js'], stdout=PIPE, stdin=PIPE, stderr=STDOUT)
    # pipe into each other
    rpc = RPC(stdin=worker.stdout, stdout=worker.stdin)
    # remote call
    remote = rpc.wrap(['hello'])
    remote.hello('Carlo', cb)
    # which is equivalent to
    rpc.rpc('hello', ['John'], cb)

def cb(err, msg=None):
    if err:
        raise err
    print "msg:", msg

if __name__ == '__main__':
    main()

NodeJs (local.js):

var cp  = require('child_process');
var rpc = require('rpc-stream');

// nodejs
var worker = cp.exec('ssh re.mo.te.ip node remote.js');
// python
// var worker = cp.exec('ssh re.mo.te.ip python remote.py');

var client = rpc();
client.pipe(worker.stdin);
worker.stdout.pipe(client);

client.rpc('hello', ['John'], function(err, msg) {
    if(err) throw err;
    console.log("msg:", msg);
});

Remote Code

Python (remote.py):

# -*- coding: utf-8 -*-
from rpycstream import RPC

class MyClass:
    def hello(self, name):
        return '%s was bitten by a python' % name

if __name__ == '__main__':
    rpc = RPC(target=MyClass())

NodeJs (remote.js):

// see https://github.com/dominictarr/rpc-stream
var rpc = require('rpc-stream');

var server = rpc({
    hello: function(name, cb) {
        cb(null, 'Hello, ' + name);
    }
});

server.pipe(process.stdout);
process.stdin.pipe(server);

Development

• Source hosted at GitHub
• Report issues, questions, feature requests on GitHub Issues

Authors

Marcel R. (riga)