CakePHPにAWS SDK for PHPを導入しS3のファイル操作を行う

公開： 2018年4月28日

カテゴリ： PHP CakePHP
タグ： PHP,AWS,S3,CakePHP,3.5,Component,3.6,SDK

PHPからAWS S3を操作するには専用のSDKである「AWS SDK for PHP」が用いられますが、CakePHPにそれを導入し、一連のファイル操作を行います。

ファイル操作にはリスト取得・アップロード・ダウンロード・削除・コピー・移動が主なものになりますが、今回はそれら全てをコンポーネントで実装していきます。

アジェンダ

開発環境
AWS SDK for PHPのインストール
初期設定
1. IAM資格情報
2. ローカルストレージ
コンポーネントの作成
1. コンポーネントの作成
2. S3Clientコンポーネントの実装
コントローラの作成
1. コントローラの生成
2. コントローラ実装

開発環境

今回の開発環境は以下の通りです。

Linux CentOS 7
Apache 2.4
PHP 7.2/7.1
composer 1.6.3
CakePHP 3.6/3.5

CakePHPのルートディレクトリを「cakephp/」とします。

今回はAWS S3を使用するので、接続可能なIAMユーザーが必要です。

AWS SDK for PHPのインストール

まずはAWS SDK for PHPをインストールします。バージョンは3です。CakePHPのルートディレクトリに移動し、以下のコマンドを叩きます。

# CakePHPのルートディレクトリへ移動する
cd /path/to/cakephp

# AWS SDK for PHPのインストール
composer require aws/aws-sdk-php

# 実行結果
[demo@localhost cakephp]$ composer require aws/aws-sdk-php
Using version ^3.55 for aws/aws-sdk-php
./composer.json has been updated
Loading composer repositories with package information
Updating dependencies (including require-dev)
Package operations: 5 installs, 0 updates, 0 removals
  - Installing mtdowling/jmespath.php (2.4.0): Loading from cache
  - Installing guzzlehttp/psr7 (1.4.2): Loading from cache
  - Installing guzzlehttp/promises (v1.3.1): Loading from cache
  - Installing guzzlehttp/guzzle (6.3.3): Downloading (100%)         
  - Installing aws/aws-sdk-php (3.55.3): Downloading (100%)         
aws/aws-sdk-php suggests installing aws/aws-php-sns-message-validator (To validate incoming SNS notifications)
aws/aws-sdk-php suggests installing doctrine/cache (To use the DoctrineCacheAdapter)
Writing lock file
Generating autoload files
> Cake\Composer\Installer\PluginInstaller::postAutoloadDump

初期設定

SDKを使って処理を書くのに必要な設定を初めに行っておきます。

IAM資格情報

S3に接続可能なIAMユーザ情報をenvファイルに追記します。

export AWS_S3_BUCKET=your-bucket-name
export AWS_S3_REGION=ap-northeast-1
export AWS_S3_KEY=YourAccesskeyID
export AWS_S3_SECRET=YourSecretAccesskey

ローカルストレージ

アップロードやダウンロードを行う際のディレクトリを作成します。CakePHPのルートディレクトリ配下へstorageディレクトリを作成します。

cakephp
├─ storage

そしてこのディレクトリまでのパスを環境変数として登録します。

cakephp/config/paths.php

define('STORAGE_PATH', ROOT . '/storage');

コンポーネントの作成

aws-sdk-phpで操作する為のコンポーネントを作成していきます。

コンポーネントの作成

CakePHPルートディレクトリへ移動し、以下のBakeコマンドでコンポーネントを生成します。

# CakePHPのルートディレクトリへ移動
cd /path/to/cakephp

# S3Clientコンポーネントの生成
bin/cake bake component S3Client

#実行結果
[demo@localhost cakephp]$ bin/cake bake component S3Client

Creating file /path/to/cakephp/src/Controller/Component/S3ClientComponent.php
Wrote `/path/to/cakephp/src/Controller/Component/S3ClientComponent.php`
Deleted `/path/to/cakephp/src/Controller/Component/empty`

Baking test case for App\Controller\Component\S3ClientComponent ...
Deleted `/path/to/cakephp/tests/TestCase/Controller/Component/empty`

Creating file /path/to/cakephp/tests/TestCase/Controller/Component/S3ClientComponentTest.php
Wrote `/path/to/cakephp/tests/TestCase/Controller/Component/S3ClientComponentTest.php`

cakephp/src/Controller/Component 配下に S3ClientComponent.php が生成されます。

cakephp
├─ src
│   ├─ Controller
│   │   ├─ Component
│   │   │   └─ S3ClientComponent.php

cakephp/src/Controller/Component/S3ClientComponent.php

<?php
namespace App\Controller\Component;

use Cake\Controller\Component;
use Cake\Controller\ComponentRegistry;

/**
 * S3Client component
 */
class S3ClientComponent extends Component
{

    /**
     * Default configuration.
     *
     * @var array
     */
    protected $_defaultConfig = [];
}

S3Clientコンポーネントの実装

それではコンポーネントを定義します。結果的に、以下のようになりました。

cakephp/src/Controller/Component/S3ClientComponent.php

<?php
namespace App\Controller\Component;

use Cake\Controller\Component;
use Cake\Controller\ComponentRegistry;
use Aws\S3\S3Client;
use Aws\S3\Exception\S3Exception;

/**
 * CakePHP3 S3Client Component
 *            with
 *      AWS SDK for PHP3
 * @see https://aws.amazon.com/jp/sdk-for-php/
 * @see https://github.com/aws/aws-sdk-php
 */
class S3ClientComponent extends Component
{
    protected $_defaultConfig = [];

    protected $default_bucket;

    public function initialize(array $config)
    {
        $this->s3 = S3Client::factory([
            'credentials' => [
                'key' => env('AWS_S3_KEY', ''),
                'secret' => env('AWS_S3_SECRET', ''),
            ],
            'region' => env('AWS_S3_REGION', ''),
            'version' => 'latest',
        ]);

        $this->default_bucket = env('AWS_S3_BUCKET', '');
    }

    /**
     * Get a list of files
     * @param string $bucket_name
     * @param string $dir
     * @param int $get_max
     * @return array
     * @see https://docs.aws.amazon.com/aws-sdk-php/v3/api/class-Aws.S3.S3Client.html#_listObjects
     */
    public function getList($bucket_name=null, $dir=null, $get_max=100)
    {
        try {
            if(!$bucket_name) $bucket_name = $this->default_bucket;
            $list_obj = $this->s3->listObjects([
                'Bucket' => $bucket_name,
                'MaxKeys' => $get_max,
                'Prefix' => $dir
            ]);

            foreach ($list_obj['Contents'] as $file) {
                if (mb_substr($file['Key'], -1) !== "/" && (!$dir  || ($dir && strpos($file['Key'], sprintf('%s/', $dir)) !== false))) {
                    $result[] = $file['Key'];
                }
            }

            return $result;
        } catch (S3Exception $e) {
            echo $e->getMessage();
        }
    }

    /**
     * Uploading files
     * @param string $file_path
     * @param string $store_path
     * @param string $bucket_name
     * @return mixed
     * @see https://docs.aws.amazon.com/aws-sdk-php/v3/api/api-s3-2006-03-01.html#putobject
     */
    public function putFile($file_path, $store_path, $bucket_name=null)
    {
        try {
            if(!$bucket_name) $bucket_name = $this->default_bucket;
            $result = $this->s3->putObject(array(
                'Bucket'       => $bucket_name,
                'Key'          => $store_path,
                'SourceFile'   => $file_path,
            ));

            return $result;
        } catch (S3Exception $e) {
            echo $e->getMessage();
        }
    }

    /**
     * File download
     * @param string $s3_file_path
     * @param string $store_dir_path
     * @param string $bucket_name
     * @return mixed
     * @see https://docs.aws.amazon.com/ja_jp/AmazonS3/latest/dev/RetrieveObjSingleOpPHP.html
     */
    public function getFile($s3_file_path, $store_file_path, $bucket_name=null)
    {
        try {
            if(!$bucket_name) $bucket_name = $this->default_bucket;
            $result = $this->s3->getObject([
                'Bucket' => $bucket_name,
                'Key'    => $s3_file_path,
                'SaveAs' => $store_file_path
            ]);

            return $result;
        } catch (S3Exception $e) {
            echo $e->getMessage();
        }
    }

    /**
     * Directory download (Recursive download)
     * @param string $s3_dir_path
     * @param string $local_dir_path
     * @param string $bucket_name
     */
    public function getDirectory($s3_dir_path, $local_dir_path, $bucket_name=null)
    {
        try {
            if(!$bucket_name) $bucket_name = $this->default_bucket;
            $file_list = $this->getList($bucket_name, $s3_dir_path);
            $this->chkDirHandle($file_list, $local_dir_path);
            foreach ($file_list as $from_path) {
                $to_path = sprintf('%s/%s', $local_dir_path, $from_path);
                $this->getFile($from_path, $to_path);
            }
        } catch (S3Exception $e) {
            echo $e->getMessage();
        }
    }

    /**
     * Copying files
     * @param string $s3_file_path
     * @param string $s3_copy_file_path
     * @param string $bucket_name_from
     * @param string $bucket_name_to
     * @return mixed
     * @see https://docs.aws.amazon.com/ja_jp/AmazonS3/latest/dev/CopyingObjectUsingPHP.html
     */
    public function copyFile($s3_file_path, $s3_copy_file_path, $bucket_name_from=null, $bucket_name_to=null)
    {
        try {
            if(!$bucket_name_from) $bucket_name_from = $this->default_bucket;
            if(!$bucket_name_to) $bucket_name_to = $this->default_bucket;
            $result = $this->s3->copyObject(array(
                'Bucket'     => $bucket_name_to,
                'Key'        => $s3_copy_file_path,
                'CopySource' => sprintf('%s/%s', $bucket_name_from, $s3_file_path),
            ));

            return $result;
        } catch (S3Exception $e) {
            echo $e->getMessage();
        }
    }

    /**
     * Copy directory (Recursive copy)
     * @param string $s3_from_dir
     * @param string $s3_to_dir
     * @param string $bucket_name_from
     * @param string $bucket_name_to
     */
    public function copyDirectory($s3_from_dir, $s3_to_dir, $bucket_name_from=null, $bucket_name_to=null)
    {
        try {
            if(!$bucket_name_from) $bucket_name_from = $this->default_bucket;
            if(!$bucket_name_to) $bucket_name_to = $this->default_bucket;
            $file_list = $this->getList($bucket_name_from, $s3_from_dir);

            foreach ($file_list as $from_path) {
                $to_path = sprintf('%s/%s', $s3_to_dir, basename($from_path));
                $this->copyFile($from_path, $to_path);
            }
        } catch (S3Exception $e) {
            echo $e->getMessage();
        }
    }

    /**
     * Moving files
     * @param $s3_from_path
     * @param $s3_to_path
     * @return bool|mixed
     */
    public function moveFile($s3_from_path, $s3_to_path)
    {
        try {
            $result = false;
            if($this->copyFile($s3_from_path, $s3_to_path)) {
                $result = $this->deleteFile($s3_from_path);
            }

            return $result;
        } catch (S3Exception $e) {
            echo $e->getMessage();
        }
    }

    /**
     * Move directory (Recursive movement)
     * @param string $s3_from_dir
     * @param string $s3_to_dir
     * @param string null $bucket_name
     */
    public function moveDirectory($s3_from_dir, $s3_to_dir, $bucket_name=null)
    {
        try {
            if(!$bucket_name) $bucket_name = $this->default_bucket;
            $file_list = $this->getList($bucket_name, $s3_from_dir);
            foreach ($file_list as $from_path) {
                $to_path = sprintf('%s/%s', $s3_to_dir, basename($from_path));
                $this->moveFile($from_path, $to_path);
            }
        } catch (S3Exception $e) {
            echo $e->getMessage();
        }
    }

    /**
     * Delete files
     * @param string $file_path
     * @param string $bucket_name
     * @return mixed
     * @see https://docs.aws.amazon.com/ja_jp/AmazonS3/latest/dev/DeletingMultipleObjectsUsingPHPSDK.html
     */
    public function deleteFile($file_path, $bucket_name=null)
    {
        try {
            if(!$bucket_name) $bucket_name = $this->default_bucket;
            $result = $this->s3->deleteObject(array(
                'Bucket' => $bucket_name,
                'Key'    => $file_path
            ));

            return $result;
        } catch (S3Exception $e) {
            echo $e->getMessage();
        }
    }

    /**
     * Delete directory (Remove recursively)
     * @param string $dir_name
     * @param string $bucket_name
     * @return mixed
     * @see https://docs.aws.amazon.com/ja_jp/AmazonS3/latest/dev/DeletingMultipleObjectsUsingPHPSDK.html
     * @see https://docs.aws.amazon.com/aws-sdk-php/v3/api/api-s3-2006-03-01.html#deleteobjects
     */
    public function deleteDirectory($dir_name, $bucket_name=null)
    {
        try {
            if(!$bucket_name) $bucket_name = $this->default_bucket;
            $file_list = $this->getList($bucket_name, $dir_name);
            $files = $this->createArrayMultipleObjects($file_list);

            $result = $this->s3->deleteObjects(array(
                'Bucket'  => $bucket_name,
                'Delete' => [
                    'Objects' => $files
                ]
            ));

            return $result;
        } catch (S3Exception $e) {
            echo $e->getMessage();
        }
    }

    /**
     * Convert from file list to array for multiple objects
     * @param $file_list
     * @return array
     */
    private function createArrayMultipleObjects($file_list)
    {
        foreach ($file_list as $name) {
            $files[] = array('Key' => $name);
        }
        return $files;
    }

    /**
     * Recursively check the path directories in the file list
     * @param $file_list
     */
    private function chkDirHandle($file_list, $local_dir_path)
    {
        foreach ($file_list as $filename) {
            $local_path = sprintf('%s/%s', $local_dir_path, dirname($filename));
            $this->chkDir($local_path);
        }
    }
    /**
     * Confirm existence of directory and create it if it does not exist.
     * @param $local_dir_path
     */
    private function chkDir($local_dir_path)
    {
        if(!file_exists($local_dir_path)) {
            mkdir($local_dir_path, 0777, true);
        }
    }
}

上から解説します。

initialize()

public function initialize(array $config)
{
    $this->s3 = S3Client::factory([
        'credentials' => [
            'key' => env('AWS_S3_KEY', ''),
            'secret' => env('AWS_S3_SECRET', ''),
        ],
        'region' => env('AWS_S3_REGION', ''),
        'version' => 'latest',
    ]);

    $this->default_bucket = env('AWS_S3_BUCKET', '');
}

コンストラクタでS3Clientの設定を行っています。そして、バケット名だけはメンバ変数$default_bucketに格納し、操作する際に自由にバケットを変更できるようにしています。各メソッドの引数にバケット名を渡さない場合は、このデフォルトのバケット名が使用されます。

getList()

public function getList($bucket_name=null, $dir=null, $get_max=100)
{
    try {
        if(!$bucket_name) $bucket_name = $this->default_bucket;
        $list_obj = $this->s3->listObjects([
            'Bucket' => $bucket_name,
            'MaxKeys' => $get_max,
            'Prefix' => $dir
        ]);

        foreach ($list_obj['Contents'] as $file) {
            if (mb_substr($file['Key'], -1) !== "/" && (!$dir  || ($dir && strpos($file['Key'], sprintf('%s/', $dir)) !== false))) {
                $result[] = $file['Key'];
            }
        }

        return $result;
    } catch (S3Exception $e) {
        echo $e->getMessage();
    }
}

getList()メソッドでは、ファイルの一覧を取得します。引数にはバケット名、ディレクトリ、取得上限数を取ります。バケット名は渡さなければデフォルトのバケット名が使われます。取得上限数の上限設定値は1000です。

putFile()

public function putFile($file_path, $store_path, $bucket_name=null)
{
    try {
        if(!$bucket_name) $bucket_name = $this->default_bucket;
        $result = $this->s3->putObject(array(
            'Bucket'       => $bucket_name,
            'Key'          => $store_path,
            'SourceFile'   => $file_path,
        ));

        return $result;
    } catch (S3Exception $e) {
        echo $e->getMessage();
    }
}

putFile()メソッドでは、1つのファイルのアップロード処理を行います。引数にはアップロード元ファイルパス、アップロード先ファイルパス、バケット名を取ります。

getFile()

public function getFile($s3_file_path, $store_dir_path, $bucket_name=null)
{
    try {
        if(!$bucket_name) $bucket_name = $this->default_bucket;
        $result = $this->s3->getObject([
            'Bucket' => $bucket_name,
            'Key'    => $s3_file_path,
            'SaveAs' => $store_dir_path
        ]);

        return $result;
    } catch (S3Exception $e) {
        echo $e->getMessage();
    }
}

getFile()メソッドでは、ファイルのダウンロード処理を行います。引数にはS3上のファイルパス、保存するローカルのファイルパス、バケット名を取ります。

getDirectory()

public function getDirectory($s3_dir_path, $local_dir_path, $bucket_name=null)
{
    try {
        if(!$bucket_name) $bucket_name = $this->default_bucket;
        $file_list = $this->getList($bucket_name, $s3_dir_path);
        $this->chkDirHandle($file_list, $local_dir_path);
        foreach ($file_list as $from_path) {
            $to_path = sprintf('%s/%s', $local_dir_path, $from_path);
            $this->getFile($from_path, $to_path);
        }
    } catch (S3Exception $e) {
        echo $e->getMessage();
    }
}

getDirectory()メソッドでは、指定したディレクトリをダウンロードします。指定ディレクトリ以下を再帰的（ディレクトリ構造を保ったまま）にダウンロードします。引数には、ダウンロードするS3のディレクトリ、保存するローカルのディレクトリパス、バケット名を取ります。

copyFile()

public function copyFile($s3_file_path, $s3_copy_file_path, $bucket_name_from=null, $bucket_name_to=null)
{
    try {
        if(!$bucket_name_from) $bucket_name_from = $this->default_bucket;
        if(!$bucket_name_to) $bucket_name_to = $this->default_bucket;
        $result = $this->s3->copyObject(array(
            'Bucket'     => $bucket_name_to,
            'Key'        => $s3_copy_file_path,
            'CopySource' => sprintf('%s/%s', $bucket_name_from, $s3_file_path),
        ));

        return $result;
    } catch (S3Exception $e) {
        echo $e->getMessage();
    }
}

copyFile()メソッドでは、ファイルをS3内で1つのファイルをコピーします。引数にはコピー元ファイルパス、コピー先ファイルパス、コピー元バケット名、コピー先バケット名を取ります。

copyDirectory()

public function copyDirectory($s3_from_dir, $s3_to_dir, $bucket_name_from=null, $bucket_name_to=null)
{
    try {
        if(!$bucket_name_from) $bucket_name_from = $this->default_bucket;
        if(!$bucket_name_to) $bucket_name_to = $this->default_bucket;
        $file_list = $this->getList($bucket_name_from, $s3_from_dir);

        foreach ($file_list as $from_path) {
            $to_path = sprintf('%s/%s', $s3_to_dir, basename($from_path));
            $this->copyFile($from_path, $to_path);
        }
    } catch (S3Exception $e) {
        echo $e->getMessage();
    }
}

copyDirectory()メソッドでは、S3内でディレクトリをコピー処理します。ファイルは再帰的（ディレクトリ構成を保ったまま）にコピーされます。引数にはコピー元S3ファイルパス、コピー先S3ファイルパス、コピー元バケット名、コピー先バケット名を取ります。

moveFile()

public function moveFile($s3_from_path, $s3_to_path)
{
    try {
        $result = false;
        if($this->copyFile($s3_from_path, $s3_to_path)) {
            $result = $this->deleteFile($s3_from_path);
        }

        return $result;
    } catch (S3Exception $e) {
        echo $e->getMessage();
    }
}

moveFile()メソッドでは、S3内で1つのファイルを移動します。引数には移動基ファイルパス、移動先ファイルパスを取ります。

moveDirectory()

public function moveDirectory($s3_from_dir, $s3_to_dir, $bucket_name=null)
{
    try {
        if(!$bucket_name) $bucket_name = $this->default_bucket;
        $file_list = $this->getList($bucket_name, $s3_from_dir);
        foreach ($file_list as $from_path) {
            $to_path = sprintf('%s/%s', $s3_to_dir, basename($from_path));
            $this->moveFile($from_path, $to_path);
        }
    } catch (S3Exception $e) {
        echo $e->getMessage();
    }
}

moveDirectory()メソッドでは、S3内でディレクトリを移動します。ファイルは再帰的（ディレクトリ構成を保ったまま）移動します。引数には移動元ディレクトリパス、移動先ディレクトリパス、バケット名を取ります。

deleteFile()

public function deleteFile($file_path, $bucket_name=null)
{
    try {
        if(!$bucket_name) $bucket_name = $this->default_bucket;
        $result = $this->s3->deleteObject(array(
            'Bucket' => $bucket_name,
            'Key'    => $file_path
        ));

        return $result;
    } catch (S3Exception $e) {
        echo $e->getMessage();
    }
}

deleteFile()メソッドでは、1つのファイルを削除します。引数には削除するS3内のファイルパス、バケット名を取ります。

deleteDirectory()

public function deleteDirectory($dir_name, $bucket_name=null)
{
    try {
        if(!$bucket_name) $bucket_name = $this->default_bucket;
        $file_list = $this->getList($bucket_name, $dir_name);
        $files = $this->createArrayMultipleObjects($file_list);

        $result = $this->s3->deleteObjects(array(
            'Bucket'  => $bucket_name,
            'Delete' => [
                'Objects' => $files
            ]
        ));

        return $result;
    } catch (S3Exception $e) {
        echo $e->getMessage();
    }
}

deleteDirectory()では、S3内のディレクトリを削除します。対象ディレクトリ内のファイルは全て削除されます。引数には削除対象ディレクトリパス、バケット名を取ります。

これより以下は、上記メソッドをサポートするメソッド群です。

createArrayMultipleObjects()

private function createArrayMultipleObjects($file_list)
{
    foreach ($file_list as $name) {
        $files[] = array('Key' => $name);
    }
    return $files;
}

createArrayMultipleObjects()メソッドでは、複数オブジェクトを削除する為のデータ構成を作成します。引数にはgetList()メソッドで取得したファイルリストを取ります。

chkDirHandle()

private function chkDirHandle($file_list, $local_dir_path)
{
    foreach ($file_list as $filename) {
        $local_path = sprintf('%s/%s', $local_dir_path, dirname($filename));
        $this->chkDir($local_path);
    }
}

chkDirHandle()メソッドは、ディレクトリ群を再帰的に処理する為のハンドラです。ファイルパスを適切な形へ整形し、chkDir()メソッドに渡します。

chkDir()

private function chkDir($local_dir_path)
{
    if(!file_exists($local_dir_path)) {
        mkdir($local_dir_path, 0777, true);
    }
}

chkDir()メソッドでは、ローカルでの指定ディレクトリの存在確認を行い、存在しない場合はそのディレクトリを作成します。

コントローラの作成

基本的にはコンポーネントを用いれば一通りの操作が行えますが、動作例として、コントローラを作成します。

コントローラの生成

コントローラファイルを生成します。CakePHPルートディレクトリへ移動し、以下のBakeコマンドを叩きます。

# CakePHPのルートディレクトリへ移動
cd /path/to/cakephp

# S3コントローラの生成
bin/cake bake controller S3

#実行結果
[demo@localhost cakephp]$ bin/cake bake controller S3

Baking controller class for S3...

Creating file /path/to/cakephp/src/Controller/S3Controller.php
Wrote `/path/to/cakephp/src/Controller/S3Controller.php`
Bake is detecting possible fixtures...

Baking test case for App\Controller\S3Controller ...

Creating file /path/to/cakephp/tests/TestCase/Controller/S3ControllerTest.php
Wrote `/path/to/cakephp/tests/TestCase/Controller/S3ControllerTest.php`

cakephp/src/Controller 配下に S3Controller.php が生成されます。

cakephp
├─ src
│   ├─ Controller
│   │   ├─ S3Controller.php

コントローラ実装

コントローラを実装します。以下のようになります。

cakephp/src/Controller/S3Controller.php

<?php
namespace App\Controller;

use App\Controller\AppController;

class S3Controller extends AppController
{
    protected $storage_path;
    
    public function initialize()
    {
        parent::initialize();
        $this->loadComponent('S3Client');
        $this->autoRender = false;

        $this->storage_path = STORAGE_PATH;
    }

    public function getList()
    {
        $file_list = $this->S3Client->getList(null);
        print_r($file_list); exit;
    }

    public function upload()
    {
        $file_name = "test.txt";
        $store_dir = "ddd/";

        $file_local_path = sprintf('%s/%s', $this->storage_path, $file_name);
        $file_store_path = sprintf('%s%s', $store_dir, $file_name);

        $result = $this->S3Client->putFile($file_local_path, $file_store_path);
    }

    public function download()
    {
        $file_name = "test.png";
        $s3_dir = "";
        $store_dir = sprintf('%s/d', $this->storage_path);

        $s3_file_path = sprintf('%s%s', $s3_dir, $file_name);
        $store_file_path = sprintf('%s/%s', $store_dir, $file_name);

        $file_obj = $this->S3Client->getFile($s3_file_path, $store_file_path);
    }

    public function downloadDirectory()
    {
        $s3_dir = "cp";
        $local_dir = "dl";
        $local_dir_path = sprintf('%s/%s', $this->storage_path, $local_dir);
        $this->S3Client->getDirectory($s3_dir, $local_dir_path);
    }

    public function copy()
    {
        $file_name = "test.png";
        $s3_dir = "";
        $s3_copy_dir = "cp/";

        $s3_file_path = sprintf('%s%s', $s3_dir, $file_name);
        $s3_copy_file_path = sprintf('%s%s', $s3_copy_dir, $file_name);

        $this->S3Client->copyFile($s3_file_path, $s3_copy_file_path);
    }

    public function copyDirectory()
    {
        $s3_from_dir = "cp";
        $s3_to_dir = "cp_d";
        $this->S3Client->copyDirectory($s3_from_dir, $s3_to_dir);
    }

    public function move()
    {
        $file_name = "test.png";
        $s3_from_dir = "cp/";
        $s3_to_dir = "mv/";
        $s3_from_path = sprintf('%s%s', $s3_from_dir, $file_name);
        $s3_to_path = sprintf('%s%s', $s3_to_dir, $file_name);
        $this->S3Client->moveFile($s3_from_path, $s3_to_path);
    }

    public function moveDirectory()
    {
        $s3_from_dir = "mv";
        $s3_to_dir = "mv_d";
        $this->S3Client->moveDirectory($s3_from_dir, $s3_to_dir);
    }

    public function delete()
    {
        $s3_file_path = 'cp/test.png';
        $this->S3Client->deleteFile($s3_file_path);
    }

    public function deleteDirectory()
    {
        $s3_dir_path = 'cp';
        $this->S3Client->deleteDirectory($s3_dir_path);
    }
}