FEAT : CDE-195-creer-consumer-pour-generer-les-2-fichiers-de-log

- modification du fichier de log en fichier tabulé
abes-esr · Oct 10, 2023 · 8562e02 · 8562e02
1 parent b5c7a3f
commit 8562e02
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/main/java/fr/abes/logskbart/kafka/LogsListener.java b/src/main/java/fr/abes/logskbart/kafka/LogsListener.java
@@ -53,7 +53,7 @@ public void listenInfoKbart2KafkaAndErrorKbart2Kafka(ConsumerRecord<String, Stri
             if (entity.getLevel().toString().equals("ERROR")) {
                 String nbrLine = message.key().substring(message.key().indexOf(".tsv")+4).replaceAll("\\[line\\s:\\s", "").replaceAll("]", "");
                 String fileName = message.key().replaceAll(".tsv\\[line\\s:\\s\\d+\\]", ".err");
-                String line = "LINE : " + nbrLine + " - MESSAGE : " + dto.getMessage();
+                String line = nbrLine + "\t" + dto.getMessage();
 
                 //  Vérifie qu'un fichier portant le nom du kbart en cours existe
                 Path of = Path.of(fileName);
@@ -64,6 +64,9 @@ public void listenInfoKbart2KafkaAndErrorKbart2Kafka(ConsumerRecord<String, Stri
                     try {
                         //  Créer le fichier et inscrit la ligne dedans
                         Files.createFile(of);
+                        //  Créer la ligne d'en-tête
+                        Files.write(of, ("LINE\tMESSAGE" + System.lineSeparator()).getBytes(), StandardOpenOption.APPEND);
+                        //  Inscrit les informations sur la ligne
                         Files.write(of, (line + System.lineSeparator()).getBytes(), StandardOpenOption.APPEND);
                         log.info("Fichier temporaire créé.");
                     } catch (SecurityException | IOException e) {