Metadata-Version: 2.1
Name: Workerpy
Version: 1.1.0
Summary: Libreria para crear Workers que responden a eventos desde kafka/Nats
Home-page: UNKNOWN
Author: Enoi Barrera Guzman
Author-email: zafiro3000x@gmail.com
License: UNKNOWN
Platform: UNKNOWN
Classifier: Programming Language :: Python :: 3
Description-Content-Type: text/markdown
Requires-Dist: kafka-python (==1.4.6)
Requires-Dist: Logbook (==1.4.3)
Requires-Dist: asyncio-nats-client (==0.9.2)
Requires-Dist: python-dotenv (==0.10.3)

# Worker

Libreria la implementacion de workes basados en kafka y Nats.


### Ejemplo

```python
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