Skip to main content

Libreria para crear Workers que responden a eventos desde kafka/Nats

Project description


Libreria la implementacion de workes basados en kafka y Nats.


from Workerpy import Manager, Worker, Options

        'DemoWorker', # Nombre del worker
        'gitlab_push', # Topico/evento que escucha
        ['broker:123'] # Kafka/Nats Hosts
class demo(Worker):
    def process(self, data):

Los workes solo escuchan, no tienen posibilidad de responder

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

Workerpy-1.1.0.tar.gz (5.2 kB view hashes)

Uploaded source

Built Distribution

Workerpy-1.1.0-py3-none-any.whl (7.4 kB view hashes)

Uploaded py3

Supported by

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