2025 Python Packaging Survey is now live!  Take the survey now

RPC between distributed workers

Navigation

Verified details

These details have been verified by PyPI
Maintainers
Avatar for sublee from gravatar.com sublee

Unverified details

These details have not been verified by PyPI
Project links
Meta
Classifiers
Report project as malware

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

Supported by

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