Skip to main content

RPC between distributed workers

Project description

A distributed RPC solution based on ØMQ and gevent. Follow the features:

  • A worker can return, yield, raise any picklable object to the remote customer.

  • A customer can invoke to any remote worker in the worker cluster.

  • A customer can invoke to all remote workers in the worker cluster.

Example

Server-side

The address is 192.168.0.41. The worker will listen at 24600.

import zmq.green as zmq
import zeronimo

class Application(object):

    def rycbar123(self):
        for word in 'run, you clever boy; and remember.'.split():
            yield word

ctx = zmq.Context()

# make worker
worker_sock = ctx.socket(zmq.PULL)
worker_sock.bind('tcp://*:24600')
worker = zeronimo.Worker(Application(), [worker_sock])

# run worker forever
worker.run()

Client-side

The address is 192.168.0.42. The reply collector will listen at 24601.

import zmq.green as zmq
import zeronimo

ctx = zmq.Context()

# make remote result collector
collector_sock = ctx.socket(zmq.PULL)
collector_sock.bind('tcp://*:24601)
collector = zeronimo.Collector(collector_sock, 'tcp://192.168.0.42:24601')

# make customer
customer_sock = ctx.socket(zmq.PUSH)
customer_sock.connect('tcp://192.168.0.41:24600')
customer = zeronimo.Customer(customer_sock, collector)

# rpc
remote_result = customer.emit('rycbar123')
for line in remote_result.get():
    print line

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

zeronimo-0.2.12.tar.gz (19.5 kB view details)

Uploaded Source

File details

Details for the file zeronimo-0.2.12.tar.gz.

File metadata

  • Download URL: zeronimo-0.2.12.tar.gz
  • Upload date:
  • Size: 19.5 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No

File hashes

Hashes for zeronimo-0.2.12.tar.gz
Algorithm Hash digest
SHA256 6c24b269ff73d75cf63ac1c13dd92d03e2aad4a1c5427a36cd0839ee4d89c069
MD5 55e747291d94378558b2d6f7c0a66cb3
BLAKE2b-256 1fdf1bc33458821acdc6ed690309247288256b62d3ad21ed2a83ada298a2fc3f

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page