# 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.
- 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.
- close_connection
- Realizar o fechamento da conexão com o rabbit.
# Requerimentos(DEV):
- Para poder iniciar é preciso ter instalado as dependências abaixo:
- [Python](https://www.python.org/)
- [Pip](https://pip.pypa.io/)
- [Poetry](https://poetry.eustace.io/)
- [Git](https://git-scm.com/)
- [poethepoet](https://github.com/nat-n/poethepoet)
# Como montar a biblioteca e fazer uploud para o pypi.org
- Video de auxlilio pode ser encontrado [aqui](https://www.youtube.com/watch?v=_14MS9oFZZI)
- 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](https://github.com/nat-n/poethepoet) pode ser executado ```poe cove_tests```
Raw data
{
"_id": null,
"home_page": "",
"name": "service-Rabbit-thread",
"maintainer": "",
"docs_url": null,
"requires_python": "",
"maintainer_email": "",
"keywords": "rabbit",
"author": "Eli\u00e9zer Schwartz",
"author_email": "eliezer.mail090@gmail.com",
"download_url": "https://files.pythonhosted.org/packages/9e/00/1e9d4e30b8729dba6a6874255ba7b54d076e2d0964127fbc07133751dec4/service-Rabbit-thread-0.0.6.tar.gz",
"platform": null,
"description": "# Biblioteca para trabalhar com o Rabbit\r\n- Ao instanciar a classe do Rabbit j\u00c3\u00a1 deve ser passado os parametros de conex\u00c3\u00a3o e de reconex\u00c3\u00a3o se assim desejar.\r\n- Nesta biblioteca pode ser encontrado os metodos:\r\n - getMessages\r\n - Pegar as mensagens de uma fila e passa a mesma para a fun\u00c3\u00a7\u00c3\u00a3o de callback passada para a fun\u00c3\u00a7\u00c3\u00a3o getMessages, exemplo:\r\n ````\r\n class example():\r\n def process_message(self, channel, method, properties, body):\r\n pass\r\n def example(self):\r\n self.queue.getMessages('name_queue', 'name_exchange', self.process_message, 1)\r\n ````\r\n - Parametros:\r\n - queue: str\r\n - Nome da fila que ficar\u00c3\u00a1 escutando para ler as mensagens.\r\n - exchange: str\r\n - Nome da exchange que a fila est\u00c3\u00a1 vinculada.\r\n - message_handler: typing.Callable\r\n - Fun\u00c3\u00a7\u00c3\u00a3o de processamento da mensagem recebida, serve para fazer o processamento da mensagem que est\u00c3\u00a1 entrando na fila.\r\n - limit_get_messages: int\r\n - Quantidade de mensagens que deseja pegar por vez do rabbit, por padr\u00c3\u00a3o se nao informada ser\u00c3\u00a1 atribuido 1.\r\n - postMessage\r\n - Enviar uma mensagem para uma fila do rabbit.\r\n - Parametros:\r\n - queue: str\r\n - Nome da fila que ser\u00c3\u00a1 colocado a mensagem.\r\n - exchange: str\r\n - Nome da exchange que a fila est\u00c3\u00a1 vinculada.\r\n - message: str\r\n - Conte\u00c3\u00bado da mensagem que ser\u00c3\u00a1 colocado na fila.\r\n - close_connection\r\n - Realizar o fechamento da conex\u00c3\u00a3o com o rabbit.\r\n# Requerimentos(DEV):\r\n- Para poder iniciar \u00c3\u00a9 preciso ter instalado as depend\u00c3\u00aancias abaixo:\r\n - [Python](https://www.python.org/)\r\n - [Pip](https://pip.pypa.io/)\r\n - [Poetry](https://poetry.eustace.io/)\r\n - [Git](https://git-scm.com/)\r\n - [poethepoet](https://github.com/nat-n/poethepoet)\r\n# Como montar a biblioteca e fazer uploud para o pypi.org\r\n- Video de auxlilio pode ser encontrado [aqui](https://www.youtube.com/watch?v=_14MS9oFZZI)\r\n- O arquivo de LICENCE \u00c3\u00a9 necess\u00c3\u00a1rio para dizer de quem \u00c3\u00a9 esta biblioteca, alterar de acordo com as regras e necessidade.\r\n- Necess\u00c3\u00a1rio instalar o setuptools, j\u00c3\u00a1 est\u00c3\u00a1 sendo instalado pelo poetry\r\n######\r\n pip install setuptools\r\n- Criar/editar o arquivo setup.py e configura-lo de acordo com a necessidade\r\n- Rodar o comando abaixo para ele realizar o empacotamento da nossa biblioteca de acordo com o que est\u00c3\u00a1 configurado no setup.py:\r\n######\r\n python3 setup.py sdist\r\n- Necess\u00c3\u00a1rio instalar o twine para poder fazer uploud desta biblioteca para fazer uploud para o pypi:\r\n######\r\n pip install twine\r\n- Necess\u00c3\u00a1rio ter uma conta no pypi criado para poder fazer uploud\r\n- Rodar o comando abaixo para fazer o uploud de tudo que tem na pasta dist que foi criada pelo processo de gera\u00c3\u00a7\u00c3\u00a3o da nossa biblioteca:\r\n######\r\n twine upload dist/*\r\n\r\n# Testes\r\n- 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](https://github.com/nat-n/poethepoet) pode ser executado ```poe cove_tests```\r\n",
"bugtrack_url": null,
"license": "MIT License",
"summary": "Wrapper n\u00e3o oficial do Rabbit",
"version": "0.0.6",
"project_urls": null,
"split_keywords": [
"rabbit"
],
"urls": [
{
"comment_text": "",
"digests": {
"blake2b_256": "9e001e9d4e30b8729dba6a6874255ba7b54d076e2d0964127fbc07133751dec4",
"md5": "9a37f455d4b26b6441e6ee3fa6d07c91",
"sha256": "8396ba1cddd4ce784c253e453e67efc110882a6fd13405460458d2c5b14e17a8"
},
"downloads": -1,
"filename": "service-Rabbit-thread-0.0.6.tar.gz",
"has_sig": false,
"md5_digest": "9a37f455d4b26b6441e6ee3fa6d07c91",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 7776,
"upload_time": "2023-10-26T12:12:11",
"upload_time_iso_8601": "2023-10-26T12:12:11.097000Z",
"url": "https://files.pythonhosted.org/packages/9e/00/1e9d4e30b8729dba6a6874255ba7b54d076e2d0964127fbc07133751dec4/service-Rabbit-thread-0.0.6.tar.gz",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2023-10-26 12:12:11",
"github": false,
"gitlab": false,
"bitbucket": false,
"codeberg": false,
"lcname": "service-rabbit-thread"
}
JSON