Java
import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSS;
import com.aliyun.oss.common.auth.*;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;
import com.aliyun.oss.model.AddBucketReplicationRequest;
public class Demo {
public static void main(String[] args) throws Exception {
// Endpoint以華東1（杭州）為例，其它Region請按實際情況填寫。
String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
// 強烈建議不要把訪問憑證儲存到工程代碼裡，否則可能導致訪問憑證泄露，威脅您帳號下所有資源的安全。本程式碼範例以從環境變數中擷取訪問憑證為例。運行本程式碼範例之前，請先配置環境變數。
EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
// 填寫源Bucket名稱。
String bucketName = "src-bucket";
// 指定資料要複製到的目標Bucket。目標Bucket與源Bucket必須屬於相同帳號。
String targetBucketName = "dest-bucket";
// 指定目標Bucket所在地區。目標Bucket與源Bucket必須處於不同地區。
String targetBucketLocation = "oss-cn-shanghai";
// 建立OSSClient執行個體。
OSS ossClient = new OSSClientBuilder().build(endpoint, credentialsProvider);
try {
AddBucketReplicationRequest request = new AddBucketReplicationRequest(bucketName);
request.setTargetBucketName(targetBucketName);
request.setTargetBucketLocation(targetBucketLocation);
// 預設複製歷史資料。此處設定為false，表示禁止複製歷史資料。
request.setEnableHistoricalObjectReplication(false);
// 指定授權OSS進行資料複製的角色名稱，且該角色必須已被授予源Bucket執行跨地區複製以及目標Bucket接收複製對象的許可權。
request.setSyncRole("yourRole");
// 指定OSS是否複製通過SSE-KMS加密建立的對象。
//request.setSseKmsEncryptedObjectsStatus("Enabled");
// 指定SSE-KMS密鑰ID。如果指定Status為Enabled，則必須指定該元素。
//request.setReplicaKmsKeyID("3542abdd-5821-4fb5-a425-90adca***");
//List prefixes = new ArrayList();
//prefixes.add("image/");
//prefixes.add("video");
//prefixes.add("a");
//prefixes.add("A");
// 指定待覆制Object的首碼Prefix。指定Prefix後，只有匹配該Prefix的Object才會複製到目標Bucket。
//request.setObjectPrefixList(prefixes);
//List actions = new ArrayList();
//actions.add(AddBucketReplicationRequest.ReplicationAction.ALL);
// 指定可以被複製到目標Bucket的操作。預設值為ALL，表示源Bucket的所有操作都會複製到目標Bucket。
//request.setReplicationActionList(actions);
ossClient.addBucketReplication(request);
} catch (OSSException oe) {
System.out.println("Caught an OSSException, which means your request made it to OSS, "
+ "but was rejected with an error response for some reason.");
System.out.println("Error Message:" + oe.getErrorMessage());
System.out.println("Error Code:" + oe.getErrorCode());
System.out.println("Request ID:" + oe.getRequestId());
System.out.println("Host ID:" + oe.getHostId());
} catch (ClientException ce) {
System.out.println("Caught an ClientException, which means the client encountered "
+ "a serious internal problem while trying to communicate with OSS, "
+ "such as not being able to access the network.");
System.out.println("Error Message:" + ce.getMessage());
} finally {
if (ossClient != null) {
ossClient.shutdown();
}
}
}
}
Python
# -*- coding: utf-8 -*-
import oss2
from oss2.credentials import EnvironmentVariableCredentialsProvider
from oss2.models import ReplicationRule
# 從環境變數中擷取訪問憑證。運行本程式碼範例之前，請確保已設定環境變數OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
auth = oss2.ProviderAuth(EnvironmentVariableCredentialsProvider())
# 填寫源Bucket所在地區對應的Endpoint。以華東1（杭州）為例，Endpoint填寫為https://oss-cn-hangzhou.aliyuncs.com。
# 填寫源Bucket名稱，例如src-bucket。
bucket = oss2.Bucket(auth, 'https://oss-cn-hangzhou.aliyuncs.com', 'src-bucket')
replica_config = ReplicationRule(
# 指定資料要複製到的目標Bucket。目標Bucket與源Bucket必須屬於不同帳號。
target_bucket_name='dest-bucket',
# 指定目標Bucket所在地區。目標Bucket與源Bucket必須處於不同地區。
target_bucket_location='oss-cn-shanghai',
# 指定授權OSS進行資料複製的角色名稱，且該角色必須已被授予源Bucket執行跨地區複製以及目標Bucket接收複製對象的許可權。
sync_role_name='roleNameTest',
)
# 指定待覆制Object的首碼Prefix。指定Prefix後，只有匹配該Prefix的Object才會複製到目標Bucket。
# prefix_list = ['prefix1', 'prefix2']
# 設定資料複製規則。
# replica_config = ReplicationRule(
# prefix_list=prefix_list,
# 指定可以被複製到目標Bucket的操作。預設值為ALL，表示源Bucket的所有操作都會複製到目標Bucket。
# action_list=[ReplicationRule.ALL],
# 指定資料要複製到的目標Bucket。目標Bucket與源Bucket必須屬於不同帳號。
# target_bucket_name='dest-bucket',
# 指定目標Bucket所在地區。目標Bucket與源Bucket必須處於不同地區。
# target_bucket_location='yourTargetBucketLocation',
# 預設複製歷史資料。此處設定為False，表示禁止複製歷史資料。
# is_enable_historical_object_replication=False,
# 指定資料複製時使用的資料轉送鏈路。
# target_transfer_type='oss_acc',
#)
# 開啟資料複製。
bucket.put_bucket_replication(replica_config)
Go
package main
import (
"encoding/xml"
"fmt"
"github.com/aliyun/aliyun-oss-go-sdk/oss"
"os"
)
func HandleError(err error) {
fmt.Println("Error:", err)
os.Exit(-1)
}
// 開啟資料複製。
func main() {
// 從環境變數中擷取訪問憑證。運行本程式碼範例之前，請確保已設定環境變數OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
provider, err := oss.NewEnvironmentVariableCredentialsProvider()
if err != nil {
fmt.Println("Error:", err)
os.Exit(-1)
}
// 建立OSSClient執行個體。
// yourEndpoint填寫Bucket對應的Endpoint，以華東1（杭州）為例，填寫為https://oss-cn-hangzhou.aliyuncs.com。其它Region請按實際情況填寫。
client, err := oss.New("yourEndpoint", "", "", oss.SetCredentialsProvider(&provider))
if err != nil {
fmt.Println("Error:", err)
os.Exit(-1)
}
// 指定源Bucket名稱。
srcbucketName := "yourSrcBucket"
// 指定資料要複製到的目標Bucket。
destBucketName := "yourDestBucket"
// 指定待覆制Object的首碼prefix_1和prefix_2。指定Prefix後，只有匹配該Prefix的Object才會複製到目標Bucket。
// 如果您需要將源Bucket中的所有Object複製到目標Bucket，則無需設定Prefix。
prefix1 := "prefix_1"
prefix2 := "prefix_2"
// 指定SSE-KMS密鑰ID。如果指定Status為Enabled，則必須指定該元素。
keyId := "c4d49f85-ee30-426b-a5ed-95e9xxxx"
// 指定OSS是否複製通過SSE-KMS加密建立的對象。
source := "Enabled"
prefixSet := oss.ReplicationRulePrefix{Prefix: []*string{&prefix1, &prefix2}}
// 在配置跨地區複製規則時，開啟資料複製時間控制（RTC）功能。
enabled := "enabled"
reqReplication := oss.PutBucketReplication{
Rule: []oss.ReplicationRule{
{
PrefixSet: &prefixSet,
//指定可以被複製到目標Bucket的操作。預設值為ALL，表示源Bucket的所有操作都會複製到目標Bucket。
Action: "ALL",
RTC: &enabled,
Destination: &oss.ReplicationRuleDestination{
Bucket: destBucketName,
// 指定目標Bucket所在地區。源Bucket與目標Bucket必須處於不同的地區。
Location: "oss-cn-shanghai",
// 指定資料複製時使用的資料轉送鏈路。此處設定為oss_acc，表示使用了傳輸加速鏈路。
TransferType: "oss_acc",
},
// 預設複製歷史資料。此處設定為disabled，表示禁止複製歷史資料。
HistoricalObjectReplication: "disabled",
// 指定授權OSS進行資料複製的角色名稱，且該角色必須已被授予源Bucket執行跨地區複製以及目標Bucket接收複製對象的許可權。
SyncRole: "yourRole",
EncryptionConfiguration: &keyId,
SourceSelectionCriteria: &source,
},
},
}
xmlBody, err := xml.Marshal(reqReplication)
if err != nil {
HandleError(err)
}
err = client.PutBucketReplication(srcbucketName, string(xmlBody))
if err != nil {
HandleError(err)
}
fmt.Println("Put Bucket Replication Success!")
}