public String getTextFromS3()

in src/main/java/software/amazon/payloadoffloading/S3Dao.java [38:66]


    public String getTextFromS3(String s3BucketName, String s3Key) {
        GetObjectRequest getObjectRequest = GetObjectRequest.builder()
                .bucket(s3BucketName)
                .key(s3Key)
                .build();

        ResponseInputStream<GetObjectResponse> object = null;
        try {
            object = s3Client.getObject(getObjectRequest);
        } catch (SdkException e) {
            String errorMessage = "Failed to get the S3 object which contains the payload.";
            LOG.error(errorMessage, e);
            throw SdkException.create(errorMessage, e);
        }

        String embeddedText;
        try {
            embeddedText = IoUtils.toUtf8String(object);
        } catch (IOException e) {
            String errorMessage = "Failure when handling the message which was read from S3 object.";
            LOG.error(errorMessage, e);
            throw SdkClientException.create(errorMessage, e);

        } finally {
            IoUtils.closeQuietly(object, LOG);
        }

        return embeddedText;
    }