本文介紹如何將源存儲空間(Bucket)中的文件(Object)拷貝到同一地域下相同或不同目標Bucket。
注意事項
本文以華東1(杭州)外網Endpoint為例。如果您希望通過與OSS同地域的其他阿里云產品訪問OSS,請使用內網Endpoint。關于OSS支持的Region與Endpoint的對應關系,請參見OSS訪問域名、數據中心、開放端口。
本文以OSS域名新建OSSClient為例。如果您希望通過自定義域名、STS等方式新建OSSClient,請參見新建OssClient。
通過RAM用戶執行拷貝操作時,您必須有源Object的讀權限(
oss:GetObject
)及目標Bucket的讀寫權限(oss:PutObject
和oss:GetObject
)。有關為RAM用戶授權自定義權限策略的具體步驟,請參見RAM Policy常見示例。拷貝文件時,您需要確保源Bucket和目標Bucket均未設置合規保留策略,否則報錯The object you specified is immutable.。
不支持跨地域拷貝。例如不能將華東1(杭州)地域存儲空間中的文件拷貝到華北1(青島)地域。
拷貝小文件
通過$ossClient->copyObject
方法拷貝小于1 GB文件的示例代碼如下:
<?php
if (is_file(__DIR__ . '/../autoload.php')) {
require_once __DIR__ . '/../autoload.php';
}
if (is_file(__DIR__ . '/../vendor/autoload.php')) {
require_once __DIR__ . '/../vendor/autoload.php';
}
use OSS\Credentials\EnvironmentVariableCredentialsProvider;
use OSS\OssClient;
use OSS\CoreOssException;
// 從環境變量中獲取訪問憑證。運行本代碼示例之前,請確保已設置環境變量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
$provider = new EnvironmentVariableCredentialsProvider();
// Endpoint以華東1(杭州)為例,其它Region請按實際情況填寫。
$endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
// 填寫源Bucket名稱,例如srcexamplebucket。
$from_bucket = "srcexamplebucket";
// 填寫源Object的完整路徑。Object完整路徑中不能包含Bucket名稱,例如srcdir/exampleobject.txt。
$from_object = "srcdir/exampleobject.txt";
// 填寫與源Bucket處于同一地域的目標Bucket名稱,例如destexamplebucket。
// 當在同一個Bucket內拷貝文件時,請確保源Bucket名稱和目標Bucket名稱相同。
$to_bucket = "destexamplebucket";
// 填寫目標Object的完整路徑。Object完整路徑中不能包含Bucket名稱,例如destdir/exampleobject.txt。
$to_object = "destdir/exampleobject.txt";
$options = array(
'headers'=>array(
// 指定CopyObject操作時是否覆蓋同名目標Object。此處設置為true,表示禁止覆蓋同名Object。
// 'x-oss-forbid-overwrite' => 'true',
// 如果源Object的ETag值和您提供的ETag相等,則執行拷貝操作,并返回200 OK。
// 'x-oss-copy-source-if-match' => '5B3C1A2E053D763E1B002CC****',
// 如果源Object的ETag值和您提供的ETag不相等,則執行拷貝操作,并返回200 OK。
// 'x-oss-copy-source-if-none-match' => '5B3C1A2E053D763E1B002CC****',
// 如果指定的時間等于或者晚于文件實際修改時間,則正常拷貝文件,并返回200 OK。
// 'x-oss-copy-source-if-unmodified-since' => gmdate('2021-12-09T07:01:56.000Z'),
// 如果指定的時間早于文件實際修改時間,則正常拷貝文件,并返回200 OK。
// 'x-oss-copy-source-if-modified-since' => gmdate('2021-12-09T07:01:56.000Z'),
// 指定設置目標Object元數據的方式。此處設置為COPY,表示復制源Object的元數據到目標Object。
// 'x-oss-metadata-directive' => 'COPY',
// 指定OSS創建目標Object時使用的服務器端加密算法。
// 'x-oss-server-side-encryption' => 'KMS',
// 表示KMS托管的用戶主密鑰,該參數僅在x-oss-server-side-encryption為KMS時有效。
// 'x-oss-server-side-encryption-key-id' => '9468da86-3509-4f8d-a61e-6eab****',
// 指定OSS創建目標Object時的訪問權限。此處設置為private,表示只有Object的擁有者和授權用戶有該Object的讀寫權限,其他用戶沒有權限操作該Object。
// 'x-oss-object-acl' => 'private',
// 指定Object的存儲類型。此處設置為Standard,表示標準存儲類型。
// 'x-oss-storage-class' => 'Standard',
// 指定Object的對象標簽,可同時設置多個標簽。
// 'x-oss-tagging' => 'k1=v1&k2=v2&k3=v3',
// 指定設置目標Object對象標簽的方式。此處設置為COPY,表示復制源Object的對象標簽到目標Object。
// 'x-oss-tagging-directive' => 'COPY',
),
);
try{
$config = array(
"provider" => $provider,
"endpoint" => $endpoint,
"signatureVersion" => OssClient::OSS_SIGNATURE_VERSION_V4,
"region"=> "cn-hangzhou"
);
$ossClient = new OssClient($config);
$ossClient->copyObject($from_bucket, $from_object, $to_bucket, $to_object);
} catch(OssException $e) {
printf(__FUNCTION__ . ": FAILED\n");
printf($e->getMessage() . "\n");
return;
}
print(__FUNCTION__ . ": OK" . "\n");
拷貝大文件
對于大于1 GB的文件,需要使用分片拷貝(UploadPartCopy)。分片拷貝分為三步:
通過
$ossClient->initiateMultipartUpload
初始化分片拷貝任務。通過
$ossClient->uploadPartCopy
進行分片拷貝。除最后一個分片外,其它分片都要大于100 KB。通過
$ossClient->completeMultipartUpload
提交分片拷貝任務。
以下代碼用于分片拷貝:
<?php
if (is_file(__DIR__ . '/../autoload.php')) {
require_once __DIR__ . '/../autoload.php';
}
if (is_file(__DIR__ . '/../vendor/autoload.php')) {
require_once __DIR__ . '/../vendor/autoload.php';
}
use OSS\Credentials\EnvironmentVariableCredentialsProvider;
use OSS\OssClient;
use OSS\CoreOssException;
// 從環境變量中獲取訪問憑證。運行本代碼示例之前,請確保已設置環境變量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
$provider = new EnvironmentVariableCredentialsProvider();
// Endpoint以杭州為例,其它Region請按實際情況填寫。
$endpoint = "http://oss-cn-hangzhou.aliyuncs.com";
// 填寫源Bucket名稱。
$from_bucket = "yourSrcBucketName";
// 填寫源Object的完整路徑。Object完整路徑中不能包含Bucket名稱,例如srcdir/exampleobject.txt。
$from_object = "yourSrcObjectName";
// 填寫與源Bucket處于同一地域的目標Bucket名稱。
$to_bucket = "yourDestBucketName";
// 填寫目標Object的完整路徑。Object完整路徑中不能包含Bucket名稱,例如destdir/exampleobject.txt。
$to_object = 'yourDestObjectName';
// 根據實際情況設置分片大小,單位為字節。
$part_size = 256*1024*1024;
try{
$config = array(
"provider" => $provider,
"endpoint" => $endpoint,
"signatureVersion" => OssClient::OSS_SIGNATURE_VERSION_V4,
"region"=> "cn-hangzhou"
);
$ossClient = new OssClient($config);
$objectMeta = $ossClient->getObjectMeta($from_bucket, $from_object);
$length = $objectMeta['content-length'] + 0;
// 初始化分片拷貝任務。
$upload_id = $ossClient->initiateMultipartUpload($to_bucket, $to_object);
// 分片拷貝。
$pieces = $ossClient->generateMultiuploadParts($length, $part_size);
$response_upload_part = array();
$copyId = 1;
$upload_position = 0;
foreach ($pieces as $i => $piece) {
$from_pos = $upload_position + (integer)$piece['seekTo'];
$to_pos = (integer)$piece['length'] + $from_pos - 1;
$up_options = array(
'start' => $from_pos,
'end' => $to_pos,
'headers'=>array(
// 如果源Object的ETag值和您提供的ETag相等,則執行拷貝操作,并返回200 OK。
// 'x-oss-copy-source-if-match' => '5B3C1A2E053D763E1B002CC****',
// 如果源Object的ETag值和您提供的ETag不相等,則執行拷貝操作,并返回200 OK。
// 'x-oss-copy-source-if-none-match' => '5B3C1A2E053D763E1B002CC****',
// 如果指定的時間等于或者晚于文件實際修改時間,則正常拷貝文件,并返回200 OK。
// 'x-oss-copy-source-if-unmodified-since' => gmdate('2021-12-09T07:01:56.000Z'),
// 如果指定的時間早于文件實際修改時間,則正常拷貝文件,并返回200 OK。
// 'x-oss-copy-source-if-modified-since' => gmdate('2021-12-09T07:01:56.000Z'),
),
);
$response_upload_part[] = $ossClient->uploadPartCopy( $from_bucket, $from_object, $to_bucket, $to_object, $copyId, $upload_id, $up_options);
$copyId = $copyId + 1;
}
// 完成分片拷貝。
$upload_parts = array();
foreach ($response_upload_part as $i => $etag) {
$upload_parts[] = array(
'PartNumber' => ($i + 1),
'ETag' => $etag,
);
}
$result = $ossClient->completeMultipartUpload($to_bucket, $to_object, $upload_id, $upload_parts);
} catch(OssException $e) {
printf(__FUNCTION__ . ": FAILED\n");
printf($e->getMessage() . "\n");
return;
}
print(__FUNCTION__ . ": OK" . "\n");
相關文檔
拷貝小文件
關于拷貝小文件的完整示例代碼,請參見GitHub示例。
關于拷貝小文件的API接口說明,請參見CopyObject。
拷貝大文件
關于拷貝大文件的完整示例代碼,請參見GitHub示例。
關于拷貝大文件的API接口說明,請參見UploadPartCopy。