Registry / database / nsj-queue-lib

nsj-queue-lib

JSON →
library1.2.2pypypiunverified

Biblioteca para facilitar a implementação de filas e workers em Python, suportando RabbitMQ e PostgreSQL como backends. Atualmente na versão 1.2.2, requer Python >=3.4. Mantida pela Nasajon, com lançamentos esporádicos.

pip install nsj-queue-lib
INSTALL
IMPORT
SIG · NSJ-QUEUE-LIB
N
nsj-queue-lib
databasepythonv1.2.2
Install
7.4s avg
Import
Disk
107MB
Pass rate
10/ 10
Env Coverage10 / 10
glibc
3.93.13
musl
3.93.13
Install & Compatibility
Where this runs
tested against v1.2.2 · pip install
no network on importno background threads
Install × environment matrix
Each cell = how many times install + import succeeded across repeated harness runs. Partial = flaky.
glibc = Debian/Ubuntu slim · musl = Alpine Linux
musl
py 3.103.95 runs
installs and imports cleanly · install 0.0s · import 0.000s · 73.4MB
glibc
py 3.103.95 runs
installs and imports cleanly · install 7.4s · import 0.000s · 134MB
107MB installed
● package 107MB
Code
Verified usage

Verified import paths — ran on the pinned version, not inferred.

QueueService
from nsj_queue_lib import QueueService
from nsj_queue_lib import QueueService

Exemplo básico de envio de mensagem e execução de worker.

import os from nsj_queue_lib import QueueService, Worker # Exemplo de envio de mensagem queue = QueueService( host=os.environ.get('QUEUE_HOST', 'localhost'), port=os.environ.get('QUEUE_PORT', 5672), username=os.environ.get('QUEUE_USER', 'guest'), password=os.environ.get('QUEUE_PASS', 'guest') ) queue.send('my_queue', {'key': 'value'}) # Exemplo de worker def process_message(msg): print(f"Processed: {msg}") worker = Worker(queue='my_queue', callback=process_message) worker.start()
Debug
Known issues
gotchaO nome do pacote usa hífen (nsj-queue-lib), mas o módulo Python usa underscore (nsj_queue_lib). Isso pode causar confusão na importação.
fix
Use `pip install nsj-queue-lib` para instalar, e `import nsj_queue_lib` no código.
affects: all
breakingNa versão 1.2.0, o parâmetro 'callback' do Worker foi renomeado de 'handler' para 'callback'. Código antigo quebrará.
fix
Atualize para usar `callback` em vez de `handler` ao instanciar Worker.
affects: <1.2.0
deprecatedO suporte a Python 3.4 e 3.5 pode ser removido em versões futuras. Considere atualizar para Python 3.6+.
fix
Use Python 3.6 ou superior.
affects: >=1.2.0
Upgrade
Version history
1.2.2latest on PyPI · released Jul 13, 2025
Audit
Dependencies
celeryrequiredUsado internamente para gerenciamento de filas
redisoptionalOpcional, para uso com Redis como broker
Agent activity
13 hits · last 30 days
node
12
OpenAI (training)
1
Resources
nsj-queue-lib — pip install nsj-queue-lib · libregistry