Demonstrar integração entre micro serviços em Python 3 utilizando RabbitMQ.

Toda inserção de registro na base de dados é publicada em uma exchange no RabbitMQ, com o objetivo de notificar todas as aplicações inscritas, que novo registro foi alterado ou modificado.

Por que replicar os dados nos micros serviços?

• Evitar de implementar circuit breakers;
• Otimizar a base de dados de acordo com cada micro serviço. Armzenar a informação desnormalizada e apenas o que é pertinente ao domínio. Poder escolher outras formas de armazenamento de dados. Ex: uso de cache, banco não relacional, arquivo, etc;
• Serviços devem ser independentes, devem fazer uma coisa só e muito bem feita (aka SOLID);
• Escalar um serviço sem impactar outros;
• Tempo de resposta do meu serviço não é impactada por lentidão de outro serviço;

• Atraso nas informações entre os serviço (vide youtube onde após clicar like e atualizar a pagina, seu like ainda não está "salvo");
• Ponto de falha no RabbitMQ (se cair, comunicação acaba);
• Complexidade aumenta (muito);
• Problemas de rede;
• Retry de mensagens;
• Publicar a mensagem para o Broker pode falhar, precisa implementar mecanismo de replay em cada serviço;
• Controle de estado de um registro é complexo (ativo, inativo, saldo, etc);
• Precisa utilizar um service discover para chamar e proteger os enpoints dos serviços, particularmente usaria o Traefik;

A implementação de Consumer e Producer do RabbitMQ está replicada em cada servico. Não é certo fazer isso.

O ideal é criar uma abstração e reutilizar em outros serviços. Fiz assim porquê não encontrei uma lib em python que trabalhe assim.

Não tem nenhum teste unitário também, não fiz porquê não estava com tempo para fazer, se fosse pra fazer, faria somente no score por enquanto, onde tem alguma lógica de negócio mais importante, o resto é praticamente código de infra.

docker-compose up

curl -i -H 'Content-Type: application/json' http://person.localhost/person --data @payloads/new_person.json

curl -i -H 'Content-Type: application/json' http://person.localhost/person/11111/income --data @payloads/new_income.json

curl -i -H 'Content-Type: application/json' http://person.localhost/person/11111/asset --data @payloads/new_asset.json

curl -i -H 'Content-Type: application/json' http://person.localhost/person/11111/debt --data @payloads/new_debt.json

curl -i http://score.localhost/11111/score

• PostgreSQL
• RabbitMQ
• Python 3.7
• Docker
• Traefik

requirements.txt

http://admin:seguro@localhost:8080/dashboard/