跨账号同区域复制

前提条件

• 已在账号A下的某个地域创建Bucket A作为同区域复制的源Bucket，并记录账号A的UID、Bucket A的名称及所在地域。

• 已在账号B下的相同地域创建Bucket B作为同区域复制的目标Bucket，并记录账号B的UID、Bucket B的名称。

角色授权

跨账号复制任务涉及两个不同账号的Bucket，您需要按照以下说明完成RAM角色所需的信任策略和最小权限策略。

1. 通过账号A完成以下操作。

   1. 创建普通服务角色。

      重要

      您可以选择通过RAM用户创建角色，RAM用户必须拥有以下权限：ram:CreateRole、ram:GetRole、ram:ListPoliciesForRole、ram:AttachPolicyToRole。但是考虑到授予RAM用户ram:CreateRole、ram:GetRole等角色相关的权限风险较大，您可以通过RAM用户关联的阿里云账号创建RAM角色并为相应的RAM角色完成授权。授权完成后，RAM用户可以直接复用阿里云账号创建的RAM角色。

      创建角色过程中，信任主体类型选择云服务，信任主体名称选择对象存储。具体步骤，请参见创建普通服务角色。

      说明

      角色创建成功后，请记录基本信息区域的RAM角色ARN，以便后续添加权限时使用。

   2. 为角色授予源Bucket执行跨区域复制的权限。

      您可以选择以下任意方式为角色授权。

      为RAM角色授予系统策略

      警告

      您可以选择为RAM角色授予系统策略AliyunOSSFullAccess。AliyunOSSFullAccess默认拥有当前账号下所有Bucket的所有操作权限，请谨慎使用。

      为RAM角色授予自定义策略

      通过RAM Policy的方式对RAM角色授予源Bucket（src-bucket）复制所需的最小权限。

      说明

      实际使用时，请相应替换源Bucket名称。

      {
         "Version":"1",
         "Statement":[
            {
               "Effect":"Allow",
               "Action":[
                  "oss:ReplicateList",
                  "oss:ReplicateGet"
               ],
               "Resource":[
                  "acs:oss:*:*:src-bucket",          	
                  "acs:oss:*:*:src-bucket/*"
               ]
            }
         ]
      }

      如果您希望将KMS加密的Object复制到目标Bucket，您还需要为角色授予AliyunKMSFullAccess系统策略。具体步骤，请参见为RAM角色授权。

2. 通过账号B授予角色在目标Bucket接收复制对象的权限。

   （推荐）方式一：按图形策略添加

   1. 登录OSS管理控制台。

   2. 在左侧导航栏，单击Bucket 列表，然后单击目标bucket名称dest-bucket。

   3. 在左侧导航栏，选择权限控制 > Bucket 授权策略。

   4. 在Bucket 授权策略页面的按图形策略添加页签，单击接收复制对象。

   5. 在接收复制对象面板，UID及RAM角色获取方式选中从源端复制RAM角色ARN获取，源端复制RAM角色ARN选择步骤1创建的角色ARN，授权用途选中跨账号跨区域复制。

   6. 单击生成 Policy。

   方式二：按语法策略添加

   1. 在左侧导航栏，选择权限控制>Bucket 授权策略。

   2. 在Bucket 授权策略页面的按语法策略添加页签，单击编辑。

   3. 在语法策略输入框中，输入以下Bucket Policy。

      重要

      • 通过Bucket Policy按语法策略的方式进行授权时，新添加的策略会覆盖已有的策略，请确保新添加策略包含已有策略的内容，否则可能导致关联已有策略的操作失败。

      • 实际使用时，请相应替换自定义角色名称（如果自定义角色名称包含大写字母，需转换为对应的小写字母。例如已创建的角色名称为AliyunOssDrsRole，您需要转换为aliyunossdrsrole）、目标Bucket名称（dest-bucket）、源Bucket所属账号UID（137918634953xxxx）以及目标Bucket所属账号UID（111933544165xxxx）。UID必须填写阿里云账号UID。

      {
         "Version":"1",
         "Statement":[
            {
              "Effect":"Allow",
              "Action":[
                  "oss:ReplicateList",
                  "oss:ReplicateGet",
                  "oss:ReplicatePut",
                  "oss:ReplicateDelete"			
               ],
              "Principal": [
                  "arn:sts::137918634953xxxx:assumed-role/aliyunossdrsrole/*"		 
      		 ],
               "Resource":[
                  "acs:oss:*:111933544165xxxx:dest-bucket",          	
                  "acs:oss:*:111933544165xxxx:dest-bucket/*"
               ]
            }
         ]
      }

   4. 单击保存。

复制KMS加密的Object

如果您希望将账号A下源Bucket中KMS加密的Object复制到账号B下的目标Bucket，您需要使用目标Bucket所属账号B执行以下步骤。

1. 登录密钥管理服务控制台的实例管理页面，在与目标Bucket相同的地域购买并启用KMS实例。购买KMS实例时，确保访问管理数量大于等于2，其他参数保留默认配置。具体步骤，请参见购买和启用KMS实例。

   说明

   跨账号复制KMS加密的Object依赖于密钥管理服务，支持的地域受限于密钥管理服务。关于密钥管理服务支持的地域，请参见软件密钥管理支持的地域和接入地址。

2. 在KMS实例下创建密钥。密钥类型限制为非默认密钥（建议软件密钥）。具体步骤，请参见创建软件密钥。

   说明

   密钥创建成功后，请记录基本信息区域的密钥ARN，以便后续创建复制规则时使用。

3. 为创建的密钥设置密钥策略。设置密钥策略时，选择其他账号使用者，并将其他账号使用者指定为上述步骤创建的角色ARN。具体步骤，请参见设置密钥策略。

   重要

   跨账号复制KMS加密数据要求密钥策略至少包含解密（kms:Decrypt）和生成数据密钥（kms:GenerateDataKey）的权限。通过控制台设置密钥策略时，默认包含这些权限。如果通过OpenAPI设置自定义密钥策略，需要确保至少包含kms:Decrypt和kms:GenerateDataKey权限。

操作步骤

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名称，例如src-bucket。
        String bucketName = "src-bucket";
        // 指定数据要复制到的目标Bucket，目标Bucket与源Bucket必须属于不同账号。
        String targetBucketName = "dest-bucket";
        // 指定目标Bucket所在地域。目标Bucket与源Bucket必须处于相同地域。
        String targetBucketLocation = "oss-cn-hangzhou";

        // 创建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");           
            //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.PUT);
            // 将源Bucket内Object的新增、更新操作复制到目标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();
            }
        }
    }
}        

# -*- 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-hangzhou',
    # 指定授权OSS进行数据复制的角色名称，且该角色必须已被授予源Bucket执行同区域复制以及目标Bucket接收复制对象的权限。
    sync_role_name='yourRole',
)

# 指定待复制Object的前缀Prefix。指定Prefix后，只有匹配该Prefix的Object才会复制到目标Bucket。
# prefix_list = ['prefix1', 'prefix2']
# 设置数据复制规则。
# replica_config = ReplicationRule(
     # prefix_list=prefix_list,
     # 将源Bucket内Object的新增、更新操作复制到目标Bucket。
     # action_list=[ReplicationRule.PUT],
     # 指定数据要复制到的目标Bucket。目标Bucket与源Bucket必须属于不同账号。
     # target_bucket_name='dest-bucket',
     # 指定目标Bucket所在地域。目标Bucket与源Bucket必须处于不同地域。
     # target_bucket_location='oss-cn-hangzhou',
     # 默认复制历史数据。此处设置为False，表示禁止复制历史数据。
     # is_enable_historical_object_replication=False,      
  #)

# 开启数据复制。
bucket.put_bucket_replication(replica_config)

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。目标Bucket与源Bucket必须属于不同账号。
    destBucketName := "yourDestBucket"
    // 指定待复制Object的前缀prefix_1和prefix_2。指定Prefix后，只有匹配该Prefix的Object才会复制到目标Bucket。
    // 如果您需要将源Bucket中的所有Object复制到目标Bucket，则无需设置Prefix。
    prefix1 := "prefix_1"
    prefix2 := "prefix_2"    
    prefixSet := oss.ReplicationRulePrefix{Prefix: []*string{&prefix1, &prefix2}}
    
    reqReplication := oss.PutBucketReplication{
    Rule: []oss.ReplicationRule{
    {
    PrefixSet: &prefixSet,
    //将源Bucket内Object的新增、更新操作复制到目标Bucket。
    Action: "PUT",    
    Destination: &oss.ReplicationRuleDestination{
    Bucket: destBucketName,
    // 指定目标Bucket所在地域。源Bucket与目标Bucket必须处于相同的地域。    
    Location: "oss-cn-hangzhou",    
    },
    // 默认复制历史数据。此处设置为disabled，表示禁止复制历史数据。
    HistoricalObjectReplication: "disabled",
    // 指定授权OSS进行数据复制的角色名称，且该角色必须已被授予源Bucket执行跨区域复制以及目标Bucket接收复制对象的权限。
    SyncRole:                    "yourRole",    
    },
    },
    }

    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!")
}

相关文档

• 同区域复制

• 同账号同区域复制

• 特殊场景下的复制行为

• 数据复制常见问题