Aliyun.Oss.Bucket.Replication (aliyun_oss v1.0.0)

Bucket Replication 相关操作

Link to this section Summary

Types

error()

Functions

delete(bucket, rule_id)

DeleteBucketReplication接口用来停止某个存储空间（Bucket）的跨区域复制并删除Bucket的复制配置，此时源Bucket中的任何操作都不会被同步到目标Bucket。

get(bucket)

GetBucketReplication接口用来获取某个存储空间（Bucket）已设置的跨区域复制规则。

get_location(bucket)

GetBucketReplicationLocation接口用于获取可复制到的目标存储空间（Bucket）所在的地域。您可以根据返回结果决定将源Bucket的数据复制到哪个地域。

get_progress(bucket, rule_id)

GetBucketReplicationProgress用于获取某个存储空间（Bucket）的跨区域复制进度。

put(bucket, config)

PutBucketReplication接口用于为存储空间（Bucket）指定跨区域复制规则。

Link to this section Types

error()

Specs

error() ::
  %Aliyun.Oss.Client.Error{
    body: String.t(),
    parsed_details: map(),
    status_code: integer()
  }
  | atom()

Link to this section Functions

delete(bucket, rule_id)

Specs

delete(String.t(), String.t()) ::
  {:error, error()} | {:ok, Aliyun.Oss.Client.Response.t()}

DeleteBucketReplication接口用来停止某个存储空间（Bucket）的跨区域复制并删除Bucket的复制配置，此时源Bucket中的任何操作都不会被同步到目标Bucket。

Examples

iex> Aliyun.Oss.Bucket.Replication.delete("some-bucket", "rule1")
{:ok,
%Aliyun.Oss.Client.Response{
  data: "",
  headers: [
    {"Server", "AliyunOSS"},
    {"Date", "Fri, 11 Jan 2019 05:19:45 GMT"},
    {"Content-Length", "0"},
    {"Connection", "keep-alive"},
    {"x-oss-request-id", "5C3000000000000000000000"},
    {"x-oss-server-time", "90"}
  ]
}}

get(bucket)

Specs

get(String.t()) :: {:error, error()} | {:ok, Aliyun.Oss.Client.Response.t()}

GetBucketReplication接口用来获取某个存储空间（Bucket）已设置的跨区域复制规则。

Examples

iex> Aliyun.Oss.Bucket.Replication.get("some-bucket")
{:ok, %Aliyun.Oss.Client.Response{
  data: %{
    "ReplicationConfiguration" => %{
      "Rule" => %{
        "Action" => "ALL",
        "Destination" => %{
          "Bucket" => "replication-test",
          "Location" => "oss-cn-beijing"
        },
        "HistoricalObjectReplication" => "disabled",
        "ID" => "test_replication_1",
        "Status" => "starting"
      }
    }
  },
  headers: [
    {"Date", "Wed, 05 Dec 2018 02:34:57 GMT"},
    ...
  ]
}}

get_location(bucket)

Specs

get_location(String.t()) ::
  {:error, error()} | {:ok, Aliyun.Oss.Client.Response.t()}

GetBucketReplicationLocation接口用于获取可复制到的目标存储空间（Bucket）所在的地域。您可以根据返回结果决定将源Bucket的数据复制到哪个地域。

Examples

iex> Aliyun.Oss.Bucket.Replication.get_location("some-bucket")
{:ok, %Aliyun.Oss.Client.Response{
  data: %{
    "ReplicationLocation" => %{
      "Location" => ["oss-ap-northeast-1", "oss-ap-south-1",
        "oss-ap-southeast-1", "oss-ap-southeast-2", "oss-ap-southeast-3",
        "oss-ap-southeast-5", "oss-cn-beijing", "oss-cn-chengdu",
        "oss-cn-guangzhou", "oss-cn-hangzhou", "oss-cn-heyuan",
        "oss-cn-hongkong", "oss-cn-huhehaote", "oss-cn-qingdao",
        "oss-cn-shanghai", "oss-cn-wulanchabu", "oss-cn-zhangjiakou",
        "oss-eu-central-1", "oss-eu-west-1", "oss-me-east-1", "oss-rus-west-1",
        "oss-us-east-1", "oss-us-west-1"],
      "LocationTransferTypeConstraint" => %{
        "LocationTransferType" => [
          %{
            "Location" => "oss-cn-hongkong",
            "TransferTypes" => %{"Type" => "oss_acc"}
          },
          # ...
        ]
      }
    }
  },
  headers: [
    {"Date", "Wed, 05 Dec 2018 02:34:57 GMT"},
    ...
  ]
}}

get_progress(bucket, rule_id)

Specs

get_progress(String.t(), String.t()) ::
  {:error, error()} | {:ok, Aliyun.Oss.Client.Response.t()}

GetBucketReplicationProgress用于获取某个存储空间（Bucket）的跨区域复制进度。

Examples

iex> Aliyun.Oss.Bucket.Replication.get_progress("some-bucket", "replication_rule_id_1")
{:ok, %Aliyun.Oss.Client.Response{
  data: %{
    "ReplicationProgress" => %{
      "Rule" => %{
        "Action" => "ALL",
        "Destination" => %{
          "Bucket" => "replication-test",
          "Location" => "oss-cn-beijing"
        },
        "HistoricalObjectReplication" => "disabled",
        "ID" => "replication_rule_id_1",
        "Progress" => %{"NewObject" => "2021-01-19T05:53:07.000Z"},
        "Status" => "doing"
      }
    }
  },
  headers: [
    {"Date", "Wed, 05 Dec 2018 02:34:57 GMT"},
    ...
  ]
}}

put(bucket, config)

Specs

put(String.t(), String.t() | map()) ::
  {:error, error()} | {:ok, Aliyun.Oss.Client.Response.t()}

PutBucketReplication接口用于为存储空间（Bucket）指定跨区域复制规则。

Examples

iex> config_json = %{
  "ReplicationConfiguration" => %{
    "Rule" => %{
      "Action" => "ALL",
      "Destination" => %{
        "Bucket" => "replication-test",
        "Location" => "oss-cn-beijing",
        "TransferType" => "internal"
      },
      "HistoricalObjectReplication" => "disabled"
    }
  }
}
iex> Aliyun.Oss.Bucket.Replication.put("some-bucket", config_json)
{:ok, %Aliyun.Oss.Client.Response{
  data: "",
  headers: [
    {"Date", "Wed, 05 Dec 2018 02:34:57 GMT"},
    ...
  ]
}}
iex> config_xml = ~S[
  <?xml version="1.0" encoding="UTF-8"?>
  <ReplicationConfiguration>
    <Rule>
      <Action>ALL</Action>
      <Destination>
          <Bucket>replication-test</Bucket>
          <Location>oss-cn-beijing</Location>
          <TransferType>internal</TransferType>
      </Destination>
      <HistoricalObjectReplication>disabled</HistoricalObjectReplication>
    </Rule>
  </ReplicationConfiguration>
]
iex> Aliyun.Oss.Bucket.Inventory.put("some-bucket", "inventory_id", config_xml)
{:ok, %Aliyun.Oss.Client.Response{
  data: "",
  headers: [
    {"Date", "Wed, 05 Dec 2018 02:34:57 GMT"},
    ...
  ]
}}