Árvore de páginas

Detalhamento:

Descritivo sobre o funcionamento do serviço Rating Service.

Fluxo do Processo

JOB

  • Configurações de scheduler de processamento e diretórios de processamento, serão via banco de dados.
  • Também será configurado a quantidade de arquivos simultâneos a serem processados no job.


KAFKA

  • Kafka, permitirá multiprocessos para persistência dos dados do arquivo.
  • Utilização do Kafka será mediante a configuração, o serviço pode ser utilizado sem Kafka


ShedLock Spring

  • ShedLock, permite que o RatingService seja executado simultaneamente em mais de um servidor


Processo de Importação

Processo de Importação dos arquivos NCRF e CADOC3040.

O processo de importação utiliza dois jobs de execução automática, um para cada tipo de arquivo(3040 e NCR). Cada job possui uma linha de configuração na tabela t425sist, onde está configurado o diretório onde o serviço irá buscar os arquivos a serem importados. Para  a configuração do agendamento da execução que utiliza uma notação “cron”, será utilizado a coluna ds_cron da tabela t425sist.

Para identificar a configuração na tabela T425CFIT, é utilizado a coluna ID_TP_ITF, onde ‘N’ corresponde a configuração do job para NCRCF e ‘C’ corresponde a configuração do job para 3040.


  • Jobs configurados para executar a cada 10 segundos.

 select ds_cron from t425sist


  • Diretórios configurados para utilização dos Jobs..

select cd_emp, sg_itf, de_itf, nm_dir from t425cfit

where sg_itf in ('CD', 'NC')

Configurações>>Configurações de Interface  ---- Em desenvolvimento

Alterar a frequência de execução dos Jobs.


Forma de Importação

A importação se dará da seguinte forma:

  • Após iniciado o serviço, os jobs serão executados conforme a configuração obtida na coluna ds_cron. O agendamento do job é carregado uma única vez, ou seja, caso seja necessário alterar o agendamento em ds_cron, será necessário reiniciar o serviço.
  • Ao identificar um arquivo no diretório, configurado em nm_dir, o job inicia o processamento movendo o arquivo para a subpasta chamada PROCESSANDO.
  • Após o processo de importação, o arquivo será movido para a subpasta SUCESSO, ou, em caso de erro na importação, movido para a subpasta ERRO.


         

  • Não é necessário criar a estrutura de pastas, o serviço irá criar as pastas, incluindo o diretório configurado na tabela t425cfit, caso os mesmos não existam.


Serviço com KAFKA

A utilização do Kafka no serviço é parametrizada, ou seja, o serviço pode ser utilizado com ou sem a utilização do Kafka.

  • O Kafka deve estar previamente instalado e em funcionamento, caso contrário será exibido erro de comunicação no log do ratingService.
  • Para ativar o uso do Kafka é necessário alterar, na base de dados do Rating, a coluna t425sist.id_kfk para ‘S’.

Exemplo:

update t425sist set id_kfk = 'S'





  • Sem rótulos