PHPでAWSのS3のファイルを操作する方法まとめ【アップロード・DL他】

$s3 = Aws\S3\S3Client::factory([
    'credentials' => [
        'key' => 'your access key',
        'secret' => 'your access secret',  
    ],
    'version' => 'latest',
    'region'  => 'ap-northeast-1',
]);

$s3_list = $s3->ListObjects([
    'Bucket' => 'xxxxxxxxxx',//バケット名
    'Prefix' => $s3_dir,//ファイル指定
]);

$s3_dir_list = $s3->ListObjects([
    'Bucket' => 'xxxxxxxxxx',//バケット名
    'Prefix' => $s3_dir . '/',//ファイル指定
    'Delimiter' => '/',
]);

$input_time = date("Y-m-d H:i:s",strtotime("-10 minute"));//10分前

//AWSのCLI(コマンドラインからの実行)でフィルターを掛けつつ情報取得
$s3_list = shell_exec('aws s3api list-objects --bucket '
. $s3_bucket . ' --prefix "foo/" --query "Contents[?LastModified >= \`'
. $input_time . '\`]" --output=json');

$s3_list = json_decode($s3_list, true);

//LastModifiedは、アップロード開始時間
//時間を日本時間に戻す
foreach($s3_list as $key => $value){
    $time = new DateTime($s3_list[$key]['LastModified']);
    $s3_list[$key]['LastModified'] = $time->setTimeZone( new DateTimeZone('Asia/Tokyo'))->format('Y-m-d H:i:s');
}

use Aws\S3\Exception\S3Exception;
$files = count($_FILES['files']['name']);
if( !$_FILES['files']['name'][0] ){
    //エラーを返して終了
}

//s3へのアップロード
for( $i = 0; $i < $files; $i++ ){
    try{
        $s3_upload = $s3->putObject([
            'ACL' => 'public-read',
            'Bucket' => 'xxxxxxxxxxxx',
            'Key' => $s3_dir . '/' . $_FILES['files']['name'][$i],
            'SourceFile' => $_FILES['files']['tmp_name'][$i],
            'ContentType' => $_FILES['files']['type'][$i],
        ]);
    } catch (S3Exception $e ){
        //エラー処理
    }
}

try{
    $s3_download = $s3->getObject(array(
        'Bucket' => 'xxxxxxxxxxxx',
        'Key' => $s3_dir . '/' . $file_name,
    ));

    $s3_content = $s3_download['Body'];
    $s3_content = base64_encode($s3_content);

    //エンコードした内容を返す
    echo json_encode($s3_content);
}
catch(S3Exception $e){
    //エラー処理
}

var binary = atob(data['file']);//data['file']が返ってきたファイル内容のことです
var len = binary.length;
var bytes = new Uint8Array(len);
for (var i = 0; i < len; i++){
    bytes[i] = binary.charCodeAt(i);
}
var blob = new Blob(
    [bytes],
);
var link = document.createElement('a');
link.href = window.URL.createObjectURL(blob);
link.download = file_name;
link.click();

$key = $s3_dir . '/' . $file_name;//ファイル名は半角英数字にすること

$cmd = $s3->getCommand( 'PutObject', [
    'Bucket' => 'xxxxxxxxx',
    'Key' => $key,
]);
$r = $s3->createPresignedRequest( $cmd, '+1 minute' );
//URLを返す
echo (string)$r->getUri();

$fp = $s3_dir . '/' . $filename;
//s3にファイルが存在するか
if( !$s3->doesObjectExist('bucket名', $fp) ){
    //エラー処理
} else {
    $s3_delete = $s3->deleteObject([
        'Bucket' => 'xxxxxxxx',
        'Key'    => $fp,
    ]);
}

$file_list = $s3->listObjects([
    'Bucket' => 'xxxxxxx',
    'region' => 'ap-northeast-1',
]);

foreach( $file_list['Contents'] as $filename ){
    $files[] = ['Key' => $filename['Key']];
}
try{
    $s3_delete = $s3->deleteObjects(array(
        'Bucket' => 'xxxxxxxx',
        'Delete' => [
            'Objects' => $files,
        ]
    ));
} catch (s3Exception $e ){
     //エラーを返す
}

$path = $s3_dir . '/' . $filename;
$s3_copy = $s3->copyObject([
    'Bucket' => 'xxxxxxxxx',//バケットBを指定
    'CopySource' => 'xxxxxxx/' . $path,//xxxxxはバケットAを指定
    'Key' => $path,
]);

$s3_list = $s3->listObjects([
    'Bucket' => 'xxxxxxx',バケットAを指定
    'Prefix' => $s3_dir . '/',//コピーするディレクトリを指定
    'Delimiter' => '/',
]);

$batch = array();
//ディレクトリ配下をコピー
foreach( $s3_list['Contents'] as $file ){
    $batch[] = $s3->getCommand('CopyObject', [
        'Bucket'  => 'xxxxxxxx',//バケットBを指定
        'Key'  => $file['Key'],
        'CopySource' => 'xxxxxx/' . $file['Key'],//xxxxxxはバケットAを指定
    ]);
}
$results = CommandPool::batch($s3, $batch);