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;
import com.aliyun.oss.ClientBuilderConfiguration;
import com.aliyun.oss.common.comm.SignVersion;
public class Demo {
public static void main(String[] args) throws Exception {
// この例では、中国 (杭州) リージョンのエンドポイントを使用します。実際にご利用のリージョンに基づいてエンドポイントを指定してください。
String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
// エンドポイントに対応するリージョン (cn-hangzhou など) を指定します。
String region = "cn-hangzhou";
// プロジェクトコードにアクセス資格情報を保存しないことを強く推奨します。そうしないと、アクセス資格情報が漏洩し、アカウントのすべてのリソースのセキュリティが損なわれる可能性があります。この例では、アクセス資格情報は環境変数から取得されます。このサンプルコードを実行する前に、環境変数を設定してください。
EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
// ソースバケットの名前を指定します。
String bucketName = "src-bucket";
// データのレプリケート先のデスティネーションバケットを指定します。デスティネーションバケットとソースバケットは、同じアカウントに属している必要があります。
String targetBucketName = "dest-bucket";
// デスティネーションバケットのリージョンを指定します。デスティネーションバケットとソースバケットは、同じリージョンにある必要があります。
String targetBucketLocation = "oss-cn-hangzhou";
// OSSClient インスタンスを作成します。
// OSSClient インスタンスが不要になったら、シャットダウンメソッドを呼び出してリソースを解放します。
ClientBuilderConfiguration clientBuilderConfiguration = new ClientBuilderConfiguration();
// V4 署名アルゴリズムの使用を明示的に宣言します。
clientBuilderConfiguration.setSignatureVersion(SignVersion.V4);
OSS ossClient = OSSClientBuilder.create()
.endpoint(endpoint)
.credentialsProvider(credentialsProvider)
.clientConfiguration(clientBuilderConfiguration)
.region(region)
.build();
try {
AddBucketReplicationRequest request = new AddBucketReplicationRequest(bucketName);
request.setTargetBucketName(targetBucketName);
request.setTargetBucketLocation(targetBucketLocation);
// 履歴データはデフォルトでレプリケートされます。履歴データのレプリケーションを無効にするには、これを false に設定します。
request.setEnableHistoricalObjectReplication(false);
// OSS にデータレプリケーションを許可するロールの名前を指定します。このロールには、ソースバケットで同一リージョンレプリケーションを実行し、デスティネーションバケットでレプリケートされたオブジェクトを受信する権限が付与されている必要があります。
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");
// レプリケートするオブジェクトのプレフィックスを指定します。プレフィックスを指定すると、プレフィックスに一致するオブジェクトのみがデスティネーションバケットにレプリケートされます。
//request.setObjectPrefixList(prefixes);
//List actions = new ArrayList();
//actions.add(AddBucketReplicationRequest.ReplicationAction.PUT);
// ソースバケット内のオブジェクトの作成および更新操作をデスティネーションバケットにレプリケートします。
//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())
# ソースバケットのリージョンに対応するエンドポイントを指定します。たとえば、ソースバケットが中国 (杭州) リージョンにある場合、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。
# ソースバケットの名前 (例: src-bucket) を指定します。
bucket = oss2.Bucket(auth, 'https://oss-cn-hangzhou.aliyuncs.com', 'src-bucket')
replica_config = ReplicationRule(
# データのレプリケート先のデスティネーションバケットを指定します。デスティネーションバケットとソースバケットは、同じアカウントに属している必要があります。
target_bucket_name='dest-bucket',
# デスティネーションバケットのリージョンを指定します。デスティネーションバケットとソースバケットは、同じリージョンにある必要があります。
target_bucket_location='oss-cn-hangzhou',
# OSS にデータレプリケーションを許可するロールの名前を指定します。このロールには、ソースバケットで同一リージョンレプリケーションを実行し、デスティネーションバケットでレプリケートされたオブジェクトを受信する権限が付与されている必要があります。
sync_role_name='roleNameTest',
)
# レプリケートするオブジェクトのプレフィックスを指定します。プレフィックスを指定すると、プレフィックスに一致するオブジェクトのみがデスティネーションバケットにレプリケートされます。
# prefix_list = ['prefix1', 'prefix2']
# データレプリケーションルールを設定します。
# replica_config = ReplicationRule(
# prefix_list=prefix_list,
# ソースバケット内のオブジェクトの作成および更新操作をデスティネーションバケットにレプリケートします。
# action_list=[ReplicationRule.PUT],
# データのレプリケート先のデスティネーションバケットを指定します。
# target_bucket_name='dest-bucket',
# デスティネーションバケットのリージョンを指定します。
# target_bucket_location='yourTargetBucketLocation',
# 履歴データはデフォルトでレプリケートされます。履歴データのレプリケーションを無効にするには、これを False に設定します。
# is_enable_historical_object_replication=False,
# SSE-KMS 暗号化を使用して作成されたオブジェクトをレプリケートします。
# sse_kms_encrypted_objects_status=ReplicationRule.ENABLED
# SSE-KMS キー ID を指定します。SSE-KMS 暗号化を使用して作成されたオブジェクトのレプリケートを指定する場合、この要素は必須です。
# replica_kms_keyid='9468da86-3509-4f8d-a61e-6eab1eac****',
#)
# データレプリケーションを有効にします。
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 をバケットに対応するエンドポイントに設定します。たとえば、バケットが中国 (杭州) リージョンにある場合は、https://oss-cn-hangzhou.aliyuncs.com に設定します。実際の状況に応じて他のリージョンを指定してください。
client, err := oss.New("yourEndpoint", "", "", oss.SetCredentialsProvider(&provider))
if err != nil {
fmt.Println("Error:", err)
os.Exit(-1)
}
// ソースバケットの名前を指定します。
srcbucketName := "yourSrcBucket"
// データのレプリケート先のデスティネーションバケットを指定します。
destBucketName := "yourDestBucket"
// レプリケートするオブジェクトのプレフィックス prefix_1 と prefix_2 を指定します。プレフィックスを指定すると、プレフィックスに一致するオブジェクトのみがデスティネーションバケットにレプリケートされます。
// ソースバケット内のすべてのオブジェクトをデスティネーションバケットにレプリケートする場合は、プレフィックスを指定する必要はありません。
prefix1 := "prefix_1"
prefix2 := "prefix_2"
// SSE-KMS キー ID を指定します。Status が Enabled に設定されている場合、この要素は必須です。
keyId := "c4d49f85-ee30-426b-a5ed-95e9****"
// OSS が SSE-KMS 暗号化を使用して作成されたオブジェクトをレプリケートするかどうかを指定します。
source := "Enabled"
prefixSet := oss.ReplicationRulePrefix{Prefix: []*string{&prefix1, &prefix2}}
reqReplication := oss.PutBucketReplication{
Rule: []oss.ReplicationRule{
{
PrefixSet: &prefixSet,
// ソースバケット内のオブジェクトの作成および更新操作をデスティネーションバケットにレプリケートします。
Action: "PUT",
Destination: &oss.ReplicationRuleDestination{
Bucket: destBucketName,
// デスティネーションバケットのリージョンを指定します。ソースバケットとデスティネーションバケットは、同じリージョンにある必要があります。
Location: "oss-cn-hangzhou",
},
// 履歴データはデフォルトでレプリケートされます。履歴データのレプリケーションを無効にするには、これを disabled に設定します。
HistoricalObjectReplication: "disabled",
// OSS にデータレプリケーションを許可するロールの名前を指定します。このロールには、ソースバケットで同一リージョンレプリケーションを実行し、デスティネーションバケットでレプリケートされたオブジェクトを受信する権限が付与されている必要があります。
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!")
}