Libreria para crear Workers que responden a eventos desde kafka/Nats
Project description
Worker
Libreria la implementacion de workes basados en kafka y Nats.
Ejemplo
from Workerpy import Manager, Worker, Options
@Manager.Define(
Options(
'DemoWorker', # Nombre del worker
'gitlab_push', # Topico/evento que escucha
['broker:123'] # Kafka/Nats Hosts
)
)
class demo(Worker):
def process(self, data):
print(data)
Los workes solo escuchan, no tienen posibilidad de responder
Project details
Release history Release notifications | RSS feed
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)