* log-exporter: tweak logging

Signed-off-by: neo <[email protected]>
neowu · Dec 9, 2024 · 8a0fb3a · 8a0fb3a
1 parent 5fcc52d
commit 8a0fb3a
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/ext/log-exporter/src/main/java/core/log/service/ArchiveService.java b/ext/log-exporter/src/main/java/core/log/service/ArchiveService.java
@@ -4,6 +4,8 @@
 import core.framework.inject.Inject;
 import core.framework.util.Network;
 import core.framework.util.Strings;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.io.File;
 import java.io.IOException;
@@ -16,6 +18,7 @@
  * @author neo
  */
 public class ArchiveService {
+    private final Logger logger = LoggerFactory.getLogger(ArchiveService.class);
     private final String hash = Hash.md5Hex(Network.LOCAL_HOST_NAME).substring(0, 5);   // generally there only need one log-exporter, this is to avoid file name collision with multiple log-exporter
     private final Shell shell = new Shell();
 
@@ -25,6 +28,8 @@ public class ArchiveService {
     UploadService uploadService;
 
     public void uploadArchive(LocalDate date) {
+        logger.info("uploading begin, date={}", date);
+
         String actionLogPath = actionLogPath(date);
         Path actionLogFilePath = Path.of(logDir.toString(), actionLogPath);
         if (Files.exists(actionLogFilePath)) {
@@ -50,9 +55,13 @@ public void uploadArchive(LocalDate date) {
                 }
             }
         }
+
+        logger.info("uploading end, date={}", date);
     }
 
     public void cleanupArchive(LocalDate date) {
+        logger.info("cleaning up archives, date={}", date);
+
         Path actionLogFilePath = Path.of(logDir.toString(), actionLogPath(date));
         shell.execute("rm", "-f", actionLogFilePath.toString());
 

diff --git a/ext/log-exporter/src/main/java/core/log/web/UploadController.java b/ext/log-exporter/src/main/java/core/log/web/UploadController.java
@@ -6,11 +6,15 @@
 import core.framework.web.Request;
 import core.framework.web.Response;
 import core.log.service.ArchiveService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * @author neo
  */
 public class UploadController implements Controller {
+    private final Logger logger = LoggerFactory.getLogger(UploadController.class);
+
     @Inject
     ArchiveService archiveService;
     @Inject
@@ -19,6 +23,7 @@ public class UploadController implements Controller {
     @Override
     public Response execute(Request request) {
         UploadRequest uploadRequest = request.bean(UploadRequest.class);
+        logger.info("manually upload, date={}", uploadRequest.date);
         executor.submit("upload", () -> archiveService.uploadArchive(uploadRequest.date));
         return Response.empty();
     }