Add S3 Path delimiter varaible in config

Signed-off-by: Dinu John <[email protected]>
dinujoh · Apr 22, 2024 · 8dfae0d · 8dfae0d
1 parent 128c866
commit 8dfae0d
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...main/java/org/opensearch/dataprepper/plugins/mongo/configuration/MongoDBSourceConfig.java b/...main/java/org/opensearch/dataprepper/plugins/mongo/configuration/MongoDBSourceConfig.java
@@ -20,6 +20,7 @@ public class MongoDBSourceConfig {
     private static final String DATAPREPPER_SERVICE_NAME = "DATAPREPPER_SERVICE_NAME";
 
     private static final long currentTimeInEpochMilli = Instant.now().toEpochMilli();
+    public static final String S3_PATH_DELIMITER = "/";
     @JsonProperty("hosts")
     private @NotNull String[] hosts;
     @JsonProperty("port")
@@ -132,11 +133,11 @@ public String getS3Prefix() {
 
     public String getTransformedS3PathPrefix(final String collection) {
         final String serviceName = System.getenv(DATAPREPPER_SERVICE_NAME);
-        final String suffixPath = serviceName +  "/" + collection + "/" + currentTimeInEpochMilli;
+        final String suffixPath = serviceName + S3_PATH_DELIMITER + collection + S3_PATH_DELIMITER + currentTimeInEpochMilli;
         if (this.getS3Prefix() == null || this.getS3Prefix().trim().isBlank()) {
             return suffixPath;
         } else {
-            return this.s3Prefix + "/" + suffixPath;
+            return this.s3Prefix + S3_PATH_DELIMITER + suffixPath;
         }
     }