Wrapper não oficial do Rabbit
Project description
Biblioteca para trabalhar com o Rabbit
- Ao instanciar a classe do Rabbit já deve ser passado os parametros de conexão e de reconexão se assim desejar.
- Nesta biblioteca pode ser encontrado os metodos:
- getMessages
- Pegar as mensagens de uma fila e passa a mesma para a função de callback passada para a função getMessages, exemplo:
class example(): def process_message(self, channel, method, properties, body): pass def example(self): self.queue.getMessages('name_queue', 'name_exchange', self.process_message, 1)
- Parametros:
- queue: str
- Nome da fila que ficará escutando para ler as mensagens.
- exchange: str
- Nome da exchange que a fila está vinculada.
- message_handler: typing.Callable
- Função de processamento da mensagem recebida, serve para fazer o processamento da mensagem que está entrando na fila.
- limit_get_messages: int
- Quantidade de mensagens que deseja pegar por vez do rabbit, por padrão se nao informada será atribuido 1.
- queue: str
- postMessage
- Enviar uma mensagem para uma fila do rabbit.
- Parametros:
- queue: str
- Nome da fila que será colocado a mensagem.
- exchange: str
- Nome da exchange que a fila está vinculada.
- message: str
- Conteúdo da mensagem que será colocado na fila.
- queue: str
- close_connection
- Realizar o fechamento da conexão com o rabbit.
- getMessages
Requerimentos(DEV):
- Para poder iniciar é preciso ter instalado as dependências abaixo:
Como montar a biblioteca e fazer uploud para o pypi.org
- Video de auxlilio pode ser encontrado aqui
- O arquivo de LICENCE é necessário para dizer de quem é esta biblioteca, alterar de acordo com as regras e necessidade.
- Necessário instalar o setuptools, já está sendo instalado pelo poetry
pip install setuptools
- Criar/editar o arquivo setup.py e configura-lo de acordo com a necessidade
- Rodar o comando abaixo para ele realizar o empacotamento da nossa biblioteca de acordo com o que está configurado no setup.py:
python3 setup.py sdist
- Necessário instalar o twine para poder fazer uploud desta biblioteca para fazer uploud para o pypi:
pip install twine
- Necessário ter uma conta no pypi criado para poder fazer uploud
- Rodar o comando abaixo para fazer o uploud de tudo que tem na pasta dist que foi criada pelo processo de geração da nossa biblioteca:
twine upload dist/*
Testes
- Todos os testes foram desenvolvidos com o pytest, para executar os mesmos pode ser executado o comando
poetry run coverage run -m pytest
ou se caso tenha instalado o poethepoet pode ser executadopoe cove_tests
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
Close
Hashes for service-Rabbit-thread-0.0.5.post1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | c923cd3d45fbce0c5114549a4df4a3ece52e8919c487bbe69c58bbf16a047c4e |
|
MD5 | d626a11f700d4fd5f8212b9a8dc65c38 |
|
BLAKE2b-256 | d68a378824509864b2e8c7c0d7463b90567954a6a222e7cb08608136863eb756 |