Buscador.py

Este código define duas funções: automatizado e manual. 

A função automatizada processa registos de um tópico Kafka e insere-os numa tabela de base de dados. A função devolve o primeiro ID de processo inserido. Se não houver novos registos, a função verifica se há registos previamente enviados que falharam, e se assim for, devolve o primeiro ID de processo falhado. Se não houver registos falhados, a função atira um erro indicando não haver novos registos disponíveis. A função manual devolve a ID do primeiro processo na tabela da base de dados com um estado de “Novo”.

Deixe um comentário

O seu endereço de e-mail não será publicado. Campos obrigatórios são marcados com *