檔案上傳 #

import com.amazonaws.auth.AWSStaticCredentialsProvider;
import com.amazonaws.auth.BasicSessionCredentials;
import com.amazonaws.regions.Regions;
import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3ClientBuilder;
import com.amazonaws.services.s3.model.ObjectMetadata;
import com.amazonaws.services.s3.model.PutObjectRequest;
import com.amazonaws.services.s3.model.PutObjectResult;
import org.apache.commons.io.FilenameUtils;

import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.util.HashMap;
import java.util.Map;

public class Sample {
    public String uploadAndGetETag() throws Exception {
        // WSSID for authorization, obtained from Endpoint GET v1/token
        // ref: https://tw.supplier.yahoo.com/docs/sp/api/endpoints/common/#get-v1token
        String wssid = "ABCDEFabcdef0123456789._-~";
        // Temporary Security Credential from Endpoint GET /api/filerUploader/v1/credentials
        // ref: https://tw.supplier.yahoo.com/docs/sp/api/file_upload/endpoints/#get-v1credentials
        String credentialId = "ABCDE12345";
        String credentialKey = "ABCDEF/abcdef/123456=";
        String credentialToken = "ABCDEFG/abcdefg/1234567===";

        // Create an S3 client with the provided credentials
        AmazonS3ClientBuilder builder = AmazonS3ClientBuilder.standard();
        builder.withRegion(Regions.AP_NORTHEAST_1);
        builder.withCredentials(new AWSStaticCredentialsProvider(
                new BasicSessionCredentials(
                        credentialId, credentialKey, credentialToken
                )
        ));
        AmazonS3 s3 = builder.build();

        // Prepare metadata for the S3 object
        Map<String, String> userMetadata = new HashMap<>();
        userMetadata.put("YahooWSSID-Authorization", wssid);

        ObjectMetadata metadata = new ObjectMetadata();
        metadata.setSSEAlgorithm(ObjectMetadata.AES_256_SERVER_SIDE_ENCRYPTION);
        metadata.setUserMetadata(userMetadata);

        // Set the content length (optional, but recommended)
        String filePath = "test.png";
        File file = new File(filePath);
        metadata.setContentLength(file.length());

        // Construct the S3 object key and upload the file
        String bucketName = "ytw-shp-file-uploader";
        String key = String.format("FileUploader/%s", FilenameUtils.getName(filePath));
        try (InputStream inputStream = new FileInputStream(file)) {
            PutObjectRequest putObjectRequest = new PutObjectRequest(
                    bucketName, key, inputStream, metadata
            );
            return s3.putObject(putObjectRequest).getETag();
        }
    }
}

<?php

require_once ('vendor/autoload.php');

use Aws\Credentials\CredentialProvider;
use Aws\S3\Exception\S3Exception;
use Aws\S3\S3Client;

// WSSID for authorization, obtained from Endpoint GET v1/token
// ref: https://tw.supplier.yahoo.com/docs/sp/api/endpoints/common/#get-v1token
$wssid = 'ABCDEFabcdef0123456789._-~';

// Temporary Security Credential from Endpoint GET /api/filerUploader/v1/credentials
// ref: https://tw.supplier.yahoo.com/docs/sp/api/file_upload/endpoints/#get-v1credentials
$credentialId = 'ABCDE12345';
$credentialKey = 'ABCDEF/abcdef/123456=';
$credentialToken = 'ABCDEFG/abcdefg/1234567===';

// Create an S3 client with the provided credentials
try
{
    $s3Client = new S3Client
    (
        array
        (
            'region'            => 'ap-northeast-1',
            'version'           => 'latest',
            // ref: https://docs.aws.amazon.com/sdk-for-php/v3/developer-guide/guide_credentials_temporary.html
            'credentials'       => array
            (
                'key'           => $credentialId,
                'secret'        => $credentialKey,
                'token'         => $credentialToken,
            )
        )
    );
}
catch (S3Exception $e)
{
    echo "[S3 Client Init Error] " . $e->getMessage() . "\n";
    exit(1);
}

// Construct the S3 object and upload the file
$imgFile = "test.png";
try
{
    // Parameter syntax ref: https://docs.aws.amazon.com/aws-sdk-php/v3/api/api-s3-2006-03-01.html#putobject
    $result = $s3Client->putObject (
        array
        (
            'Bucket'                                => 'ytw-shp-file-uploader',
            'Key'                                   => 'FileUploader/'.basename($imgFile),
            'ServerSideEncryption'                  => 'AES256',
            'SourceFile'                            => $imgFile,
            'x-amz-server-side-encryption'          => 'AES256',
            'x-amz-meta-YahooWSSID-Authorization'   => $wssid,
        )
    );

    echo "ETag: " . $result['ETag'] . "\n";
}
catch (S3Exception $e)
{
    echo "[Upload Error] " . $e->getMessage() . "\n";
    echo "[Detailed Error XML]\n" . $e->getAwsErrorMessage() . "\n";
    echo "Error Code: " . $e->getAwsErrorCode() . "\n";
    echo "Status Code: " . $e->getStatusCode() . "\n";
    exit(2);
}

exit;
?>

import boto3

# WSSID for authorization, obtained from Endpoint GET v1/token
# ref: https://tw.supplier.yahoo.com/docs/sp/api/endpoints/common/#get-v1token
wssid = 'ABCDEFabcdef0123456789._-~'

# Temporary Security Credential from Endpoint GET /api/filerUploader/v1/credentials
# ref: https://tw.supplier.yahoo.com/docs/sp/api/file_upload/endpoints/#get-v1credentials
aws_access_key_id = 'ABCDE12345'
aws_secret_access_key = 'ABCDEF/abcdef/123456='
aws_session_token = 'ABCDEFG/abcdefg/1234567==='

# Create an S3 client with the provided credentials
s3 = boto3.client(
    's3',
    region_name='ap-northeast-1',
    aws_access_key_id=aws_access_key_id,
    aws_secret_access_key=aws_secret_access_key,
    aws_session_token=aws_session_token
)

# Construct the S3 object key
file_path = 'test.png'
file_name = file_path.rsplit('/', 1)[-1]
s3_key = 'FileUploader/' + file_name

# Upload the file to S3
bucket_name = 'ytw-shp-file-uploader'
with open(file_path, 'rb') as file:
    response = s3.put_object(
        Bucket=bucket_name,
        Key=s3_key,
        Body=file,
        Metadata={
            'YahooWSSID-Authorization': wssid
        },
        ServerSideEncryption='AES256'
    )
# Get the ETag of the uploaded object
etag = response.get('ETag')
print(f"ETag: {etag}")