procedere-mq-sdk 0.2.0

Python SDK para LiteMQ/ProcedereMQ

ProcedereMQ

Broker de filas leve com transporte HTTP/TCP e SDKs para Go e Python.

SDK Go

Import:

import "github.com/jeffersontadeuleite/procedereMQ/pkg/sdk"

Exemplo de Producer:

ctx := context.Background()
producer, err := sdk.NewProducer("http://127.0.0.1:65090", "emails")
if err != nil {
    return err
}

job, err := producer.Publish(ctx, map[string]any{
    "to": "[e-mail]",
    "template": "welcome",
}, sdk.PublishOptions{MaxRetry: 3})
if err != nil {
    return err
}
fmt.Println("job criado:", job.ID)

Exemplo de Consumer:

ctx := context.Background()
consumer, err := sdk.NewConsumer("http://127.0.0.1:65090", "emails")
if err != nil {
    return err
}

job, err := consumer.Receive(ctx)
if err != nil {
    if errors.Is(err, sdk.ErrQueueEmpty) {
        return nil
    }
    return err
}

if err := consumer.AckJob(ctx, job); err != nil {
    return err
}

SDK Python

Instalação:

pip install procedere-mq-sdk==0.2.0

Exemplo de Producer:

from python_sdk import LiteMQClient

client = LiteMQClient("http://127.0.0.1:65090")
producer = client.producer("emails")

job = producer.publish(
    {"to": "[e-mail]", "template": "welcome"},
    max_retry=3,
)
print("job criado:", job["id"])

Exemplo de Consumer:

from python_sdk import LiteMQClient, QueueEmptyError

client = LiteMQClient("http://127.0.0.1:65090")
consumer = client.consumer("emails")

try:
    job = consumer.receive()
    consumer.ack(job)
except QueueEmptyError:
    pass

Publicação

Go SDK

make publish-go-sdk VERSION=0.2.0

Python SDK (PyPI)

make check-python-sdk
make publish-python-sdk TWINE_REPOSITORY=pypi