AWSのS3をMavenのパッケージを使用してアップロード、ダウンロードを実施

キーアクセスには

ファイルの場合と設定ファイルなどよりキーの値より取得する２パターンがある
別途定数などに入れて扱いたいのでちょっと別の方法をやる

BasicAWSCredentials

パラメータに直接キーとシークレットキーを指定するのでキーの元がわかりやすい

pom.xml

  <dependencies>
    
    <!-- https://mvnrepository.com/artifact/com.amazonaws/aws-java-sdk -->
    <dependency>
      <groupId>com.amazonaws</groupId>
      <artifactId>aws-java-sdk</artifactId>
      <version>1.11.76</version>
    </dependency>
  
  </dependencies>

アップロードサンプル

Sample01.java

package com.example.awssample;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.UUID;

import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3Client;
import com.amazonaws.services.s3.model.ObjectMetadata;
import com.amazonaws.services.s3.model.PutObjectRequest;
import com.amazonaws.services.s3.transfer.TransferManager;
import com.amazonaws.services.s3.transfer.TransferManagerConfiguration;

public class Sample01 {
    
    // アクセスキー
    private static final String ACCESS_KEY = "アクセスキーの文字列";
    // シークレットアクセスキー
    private static final String SECRET_ACCESS_KEY = "シークレットアクセスキーの文字列";
    // 分割サイズ
    private static final long PART_SIZE = 5 * 1024L * 1024L;
    
    public static void main(String[] args) throws IOException {
        
        byte[] b;
        
        // ファイルを読み込み
        File file = new File("画像ファイパス/sample1.jpg");
        InputStream inputStream = new FileInputStream(file);
        ByteArrayOutputStream bout = new ByteArrayOutputStream();
        int data;
        while ((data = inputStream.read()) != -1) {
            bout.write(data);
        }
        b = bout.toByteArray();
        
        // 長さ
        long contentLength = b.length;
        
        // 設定情報
        BasicAWSCredentials credentials;
        credentials = new BasicAWSCredentials(ACCESS_KEY, SECRET_ACCESS_KEY); 
        
        // AWSのクライアント取得
        AmazonS3 s3 = new AmazonS3Client(credentials);
        
        // バケット名
        String bucketName = "awsuploadsample";
        
        // アップロードキー名
        String key = UUID.randomUUID().toString();
        
        // パスを指定することで指定の場所へ配置できる
        String objectPath = "sample1/" + key;
        
        // TransferManagerを利用
        TransferManager manager = new TransferManager(s3);
     
        // 分割サイズを設定
        TransferManagerConfiguration c = new TransferManagerConfiguration();
        c.setMinimumUploadPartSize(PART_SIZE);
        manager.setConfiguration(c);
        
        // メタデータに分割したデータのサイズを指定
        ObjectMetadata putMetaData = new ObjectMetadata();
        putMetaData.setContentLength(contentLength);
        
        // upload
        PutObjectRequest object = new PutObjectRequest(bucketName, objectPath, new ByteArrayInputStream(b), putMetaData);
        s3.putObject(object);
    }
    
}

ダウンロードサンプル

Sample02.java

package com.example.awssample;

import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;

import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3Client;
import com.amazonaws.services.s3.model.GetObjectRequest;
import com.amazonaws.services.s3.model.S3Object;


public class Sample02 {
    
    // アクセスキー
    private static final String ACCESS_KEY = "アクセスキーの文字列";
    // シークレットアクセスキー
    private static final String SECRET_ACCESS_KEY = "シークレットアクセスキーの文字列";
    // 分割サイズ
    private static final long PART_SIZE = 5 * 1024L * 1024L;
    
    public static void main(String[] args) throws IOException {
        
        // 設定情報
        BasicAWSCredentials credentials;
        credentials = new BasicAWSCredentials(ACCESS_KEY, SECRET_ACCESS_KEY); 
                
        // AWSのクライアント取得
        AmazonS3 s3 = new AmazonS3Client(credentials);
                
        // バケット名
        String bucketName = "awsuploadsample";
                
        // ダウンロードキー名
        String key = "41dbccd0-c33b-44f1-9635-37a73f42b3e7";
         // パスを指定することで指定の場所へ配置できる
        String objectPath = "sample1/" + key;
        
        // リクエストを取得
        GetObjectRequest request = new GetObjectRequest(bucketName, objectPath);
        
        // objectを取得
        S3Object object = s3.getObject(request);
        
        // データ取得
        InputStream is = object.getObjectContent();
        FileOutputStream fos = new FileOutputStream("/Users/matsumotoshigeharu/Documents/sample2.jpg");
        
        // ファイル出力
        byte[] buffer = new byte[5 * 1024 * 1024];
        int readSize = -1;
        while( (readSize = is.read(buffer, 0, buffer.length)) != -1) {
          fos.write(buffer, 0, readSize);
        }
        fos.flush();
    }
    
}

参考

Amazon S3へデータの格納・取得を行う【AmazonS3Client】 Java編 ｜ Developers.IO
覚え書き: AWS SDK for JAVA -S3 アップロード編-
Kinesis S3へデータを書き込むサンプルアプリケーション - Qiita

おわり
今回はここまで…