Biblioteca para se conectar ao rabbit e possibilitar trabalhar com o serviço de mensageria
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.
- Os parametros de conexão são:
- host, port, virtualhost, username e password
- Os parametros opcionais são:
- reconnect: bool = False
- Se deseja que o fluxo faça um reconnect automatico em alguns casos para se recuperar de erros.
- reconnect_delay: int = 300
- Quanto tempo em segundos deseja que ele tenta ficar se reconectando.
- Valor default se nao informado é 300
- continue_execution: bool = False
- Se deseja que a execução codigo continue após a conexão ser estabelecida, caso for definida como True, a reconexão em caso de falha não será possivel.
- reconnect: bool = False
- Os parametros de conexão são:
-
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
- Url da biblioteca do pypi.
- O arquivo de LICENCE é necessário para dizer de quem é esta biblioteca, alterar de acordo com as regras e necessidade.
- Como estamos utilizando o poetry é muito simples para fazer o build e uploud para o pipy:
poetry publish --build -u USERNAME -p PASSWORD
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
rabbit_library-1.0.7.tar.gz
(4.6 kB
view hashes)
Built Distribution
Close
Hashes for rabbit_library-1.0.7-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 6c0679b4b1deb59614e7bd0501b2bc05463e4f0fe12803c8c08b532d0d68faae |
|
MD5 | 828536df8db9fe6bfb6157ceeaf94f06 |
|
BLAKE2b-256 | 655bfeee6fe817a38e248f99736a2ff2d44dcc6c0dccd2142d826b3119088227 |