Remove dependency on AWS S3 SDKv1 (opensearch-project#1628)

* opensearch-project#1562: Working toward removing dependency. Signed-off-by: jzonthemtn <[email protected]> * opensearch-project#1562: Removing unneeded parts. Changing date processing. Signed-off-by: jzonthemtn <[email protected]> * opensearch-project#1562: Adding file header and comment. Signed-off-by: jzonthemtn <[email protected]> * opensearch-project#1562: Removing sysout and removing public from class. Signed-off-by: jzonthemtn <[email protected]> Signed-off-by: jzonthemtn <[email protected]>
engechas · Sep 12, 2022 · 3428298 · 3428298
1 parent 3dcfabd
commit 3428298
Show file tree

Hide file tree

Showing 7 changed files with 465 additions and 7 deletions.
diff --git a/data-prepper-plugins/s3-source/build.gradle b/data-prepper-plugins/s3-source/build.gradle
@@ -17,8 +17,10 @@ dependencies {
     implementation 'software.amazon.awssdk:s3'
     implementation 'software.amazon.awssdk:sts'
     implementation 'software.amazon.awssdk:sqs'
-    implementation 'com.amazonaws:aws-java-sdk-s3:1.12.257'
+    implementation 'com.fasterxml.jackson.core:jackson-core'
+    implementation 'com.fasterxml.jackson.core:jackson-databind:2.13.3'
     implementation 'org.apache.commons:commons-compress:1.21'
+    implementation 'joda-time:joda-time:2.10.14'
     implementation 'org.hibernate.validator:hibernate-validator:7.0.4.Final'
     implementation 'com.fasterxml.jackson.dataformat:jackson-dataformat-csv'
     testImplementation 'org.apache.commons:commons-lang3:3.12.0'

diff --git a/...s3-source/src/main/java/com/amazon/dataprepper/plugins/source/DateTimeJsonSerializer.java b/...s3-source/src/main/java/com/amazon/dataprepper/plugins/source/DateTimeJsonSerializer.java
@@ -0,0 +1,27 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package com.amazon.dataprepper.plugins.source;
+
+import java.io.IOException;
+import java.util.Date;
+
+import software.amazon.awssdk.utils.DateUtils;
+
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.databind.JsonSerializer;
+import com.fasterxml.jackson.databind.SerializerProvider;
+
+/**
+ * A Jackson serializer for Joda {@code DateTime}s.
+ */
+final class DateTimeJsonSerializer extends JsonSerializer<Date> {
+
+  @Override
+  public void serialize(Date value, JsonGenerator jgen, SerializerProvider provider) throws IOException {
+    jgen.writeString(DateUtils.formatIso8601Date(value.toInstant()));
+  }
+
+}