Object Storage Service:Gunakan QoS kolam sumber daya untuk menjamin bandwidth bagi layanan kritis

Konsol

Pada halaman Resource Pool QoS, klik nama kolam sumber daya target. Untuk bucket target, klik Modify Throttling Configuration dan atur nilai bandwidth.

ossutil

Sebelum memulai, instal ossutil.

1. Buat file XML lokal bernama qos.xml dengan konfigurasi bandwidth:

   Intranet mengacu pada trafik jaringan internal (VPC). Extranet mengacu pada trafik jaringan publik. Semua nilai dalam Gbps. Atur -1 untuk unlimited.

      import alibabacloud_oss_v2 as oss
   
      def put_bucket_qos_info():
          credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()
   
          cfg = oss.config.load_default()
          cfg.credentials_provider = credentials_provider
          cfg.region = "cn-hangzhou"  # Ganti dengan wilayah bucket Anda
   
          client = oss.Client(cfg)
   
          with open('qos.xml', 'r') as f:
              qos_xml_body = f.read()
   
          req = oss.OperationInput(
              op_name='PutBucketQoSInfo',
              method='PUT',
              parameters={'qosInfo': ''},
              headers=None,
              body=qos_xml_body,
              bucket='examplebucket',  # Ganti dengan nama bucket Anda
          )
   
          resp = client.invoke_operation(req)
          print(resp.status_code)
   
      if __name__ == "__main__":
          put_bucket_qos_info()

2. Terapkan konfigurasi ke bucket (ganti examplebucket dengan nama bucket Anda):

      ossutil api invoke-operation --op-name put-bucket-qos-info --method PUT --bucket examplebucket --parameters qosInfo --body=file://qos.xml

3. (Opsional) Verifikasi konfigurasi:

      ossutil api invoke-operation --op-name get-bucket-qos-info --method GET --bucket examplebucket --parameters qosInfo

SDK

Batas bandwidth bucket didukung oleh Python SDK V2 dan Go SDK V2.

1. Buat qos.xml dengan konten yang sama seperti contoh ossutil di atas.

2. Terapkan konfigurasi: Python

      import alibabacloud_oss_v2 as oss
   
      def put_bucket_qos_info():
          credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()
   
          cfg = oss.config.load_default()
          cfg.credentials_provider = credentials_provider
          cfg.region = "cn-hangzhou"  # Ganti dengan wilayah bucket Anda
   
          client = oss.Client(cfg)
   
          with open('qos.xml', 'r') as f:
              qos_xml_body = f.read()
   
          req = oss.OperationInput(
              op_name='PutBucketQoSInfo',
              method='PUT',
              parameters={'qosInfo': ''},
              headers=None,
              body=qos_xml_body,
              bucket='examplebucket',  # Ganti dengan nama bucket Anda
          )
   
          resp = client.invoke_operation(req)
          print(resp.status_code)
   
      if __name__ == "__main__":
          put_bucket_qos_info()

API

Panggil PutBucketQoSInfo dengan badan permintaan berikut:

<QoSConfiguration>
  <TotalUploadBandwidth>100</TotalUploadBandwidth>
  <IntranetUploadBandwidth>-1</IntranetUploadBandwidth>
  <ExtranetUploadBandwidth>20</ExtranetUploadBandwidth>
  <TotalDownloadBandwidth>100</TotalDownloadBandwidth>
  <IntranetDownloadBandwidth>-1</IntranetDownloadBandwidth>
  <ExtranetDownloadBandwidth>20</ExtranetDownloadBandwidth>
</QoSConfiguration>

Konsol

1. Pada halaman Resource Pool QoS, klik nama kolam sumber daya target. Klik Create BucketGroup, masukkan nama, dan atur batas bandwidth.

2. Untuk setiap bucket yang akan ditambahkan ke grup, klik Configure BucketGroup di sebelah kanan bucket.

ossutil

Sebelum memulai, instal ossutil.

1. Tambahkan bucket ke BucketGroup (jalankan sekali per bucket):

      ossutil api invoke-operation --op-name put-bucket-resource-pool-bucket-group --method PUT --bucket scheduled-posts --parameters resourcePool=pool-for-ai --parameters resourcePoolBucketGroup=test-group
   
      ossutil api invoke-operation --op-name put-bucket-resource-pool-bucket-group --method PUT --bucket archived-comments --parameters resourcePool=pool-for-ai --parameters resourcePoolBucketGroup=test-group

2. (Opsional) Daftar semua bucket dalam BucketGroup:

      ossutil api invoke-operation --op-name list-resource-pool-bucket-groups --method GET --parameters resourcePool=pool-for-ai --parameters resourcePoolBucketGroup

3. Buat qos.xml dengan batas bandwidth untuk BucketGroup:

      <QoSConfiguration>
        <TotalUploadBandwidth>20</TotalUploadBandwidth>
        <IntranetUploadBandwidth>-1</IntranetUploadBandwidth>
        <ExtranetUploadBandwidth>10</ExtranetUploadBandwidth>
        <TotalDownloadBandwidth>30</TotalDownloadBandwidth>
        <IntranetDownloadBandwidth>-1</IntranetDownloadBandwidth>
        <ExtranetDownloadBandwidth>20</ExtranetDownloadBandwidth>
      </QoSConfiguration>

4. Terapkan konfigurasi bandwidth ke BucketGroup:

      ossutil api invoke-operation --op-name put-resource-pool-bucket-group-qos-info --method PUT --parameters resourcePoolBucketGroupQosInfo --parameters resourcePool pool-for-ai --parameters resourcePoolBucketGroup offline-group --body=file://qos.xml

5. (Opsional) Verifikasi konfigurasi:

      ossutil api invoke-operation --op-name get-resource-pool-bucket-group-qos-info --method GET --parameters resourcePool=pool-for-ai --parameters resourcePoolBucketGroup=offline-group --parameters resourcePoolBucketGroupQoSInfo

SDK

Batas bandwidth BucketGroup didukung oleh Python SDK V2 dan Go SDK V2.

1. Tambahkan bucket ke BucketGroup: Python

      import alibabacloud_oss_v2 as oss
   
      def put_bucket_resource_pool_bucket_group():
          credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()
          cfg = oss.config.load_default()
          cfg.credentials_provider = credentials_provider
          cfg.region = "cn-hangzhou"
   
          client = oss.Client(cfg)
   
          req = oss.OperationInput(
              op_name='PutBucketResourcePoolBucketGroup',
              method='PUT',
              parameters={
                  'resourcePoolBucketGroup': 'example-group',  # Ganti dengan nama BucketGroup Anda
                  'resourcePool': 'example-resource-pool',     # Ganti dengan nama kolam sumber daya Anda
              },
              headers=None,
              body=None,
              bucket='examplebucket',  # Ganti dengan nama bucket Anda
          )
   
          resp = client.invoke_operation(req)
          print(resp.status_code)
   
      if __name__ == "__main__":
          put_bucket_resource_pool_bucket_group()

2. Buat qos.xml dengan batas bandwidth (konten sama seperti contoh ossutil di atas).

3. Terapkan konfigurasi bandwidth ke BucketGroup: Python

      import alibabacloud_oss_v2 as oss
   
      def put_resource_pool_bucket_group_qos_info():
          credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()
          cfg = oss.config.load_default()
          cfg.credentials_provider = credentials_provider
          cfg.region = "cn-hangzhou"
   
          client = oss.Client(cfg)
   
          with open('qos.xml', 'r') as f:
              qos_xml_body = f.read()
   
          req = oss.OperationInput(
              op_name='PutResourcePoolBucketGroupQoSInfo',
              method='PUT',
              parameters={
                  'resourcePoolBucketGroupQosInfo': '',
                  'resourcePool': 'example-resource-pool',    # Ganti dengan nama kolam sumber daya Anda
                  'resourcePoolBucketGroup': 'example-group', # Ganti dengan nama BucketGroup Anda
              },
              headers=None,
              body=qos_xml_body,
              bucket=None,
          )
   
          resp = client.invoke_operation(req)
          print(resp.status_code)
   
      if __name__ == "__main__":
          put_resource_pool_bucket_group_qos_info()

API

Panggil PutResourcePoolBucketGroupQoSInfo dengan badan permintaan berikut:

<QoSConfiguration>
  <TotalUploadBandwidth>20</TotalUploadBandwidth>
  <IntranetUploadBandwidth>-1</IntranetUploadBandwidth>
  <ExtranetUploadBandwidth>10</ExtranetUploadBandwidth>
  <TotalDownloadBandwidth>30</TotalDownloadBandwidth>
  <IntranetDownloadBandwidth>-1</IntranetDownloadBandwidth>
  <ExtranetDownloadBandwidth>20</ExtranetDownloadBandwidth>
</QoSConfiguration>

Konsol

1. Dapatkan ID Pengguna RAM atau ID Peran RAM.

2. Pada halaman Resource Pool QoS, klik nama kolam sumber daya target. Pada tab Resource Pool Requester List, klik Modify Throttling Configuration untuk Pengguna RAM atau Peran RAM target.

ossutil

Sebelum memulai, instal ossutil.

1. Buat qos.xml dengan batas bandwidth:

      <QoSConfiguration>
        <TotalUploadBandwidth>100</TotalUploadBandwidth>
        <IntranetUploadBandwidth>50</IntranetUploadBandwidth>
        <ExtranetUploadBandwidth>50</ExtranetUploadBandwidth>
        <TotalDownloadBandwidth>200</TotalDownloadBandwidth>
        <IntranetDownloadBandwidth>150</IntranetDownloadBandwidth>
        <ExtranetDownloadBandwidth>50</ExtranetDownloadBandwidth>
      </QoSConfiguration>

2. Dapatkan ID Pengguna RAM atau ID Peran RAM.

3. Terapkan konfigurasi (ganti examplepool dan 266xxxx dengan nilai Anda):

      ossutil api invoke-operation --op-name put-resource-pool-requester-qos-info --method PUT --parameters resourcePool=examplepool --parameters qosRequester=266xxxx --parameters requesterQosInfo --body=file://qos.xml

4. (Opsional) Daftar semua konfigurasi Pengguna RAM dalam kolam sumber daya:

      ossutil api invoke-operation --op-name list-resource-pool-requester-qos-infos --method GET --parameters resourcePool=examplePool --parameters requesterQosInfo

SDK

Batas bandwidth requester kolam sumber daya didukung oleh Python SDK V2 dan Go SDK V2.

1. Buat qos.xml dengan konten yang sama seperti contoh ossutil di atas.

2. Dapatkan ID Pengguna RAM atau ID Peran RAM.

3. Terapkan konfigurasi: Python

      import alibabacloud_oss_v2 as oss
   
      def put_resource_pool_requester_qos_info():
          credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()
          cfg = oss.config.load_default()
          cfg.credentials_provider = credentials_provider
          cfg.region = "cn-hangzhou"
   
          client = oss.Client(cfg)
   
          with open('qos.xml', 'r') as f:
              qos_xml_body = f.read()
   
          req = oss.OperationInput(
              op_name='PutResourcePoolRequesterQoSInfo',
              method='PUT',
              parameters={
                  'requesterQosInfo': '',
                  'resourcePool': 'example-resource-pool',  # Ganti dengan nama kolam sumber daya Anda
                  'qosRequester': '2598732222222xxxx',       # Ganti dengan ID Pengguna RAM atau Peran RAM
              },
              headers=None,
              body=qos_xml_body,
              bucket=None,
          )
   
          resp = client.invoke_operation(req)
          print(resp.status_code)
          print(resp.headers)
          print(resp.http_response.content)
   
      if __name__ == "__main__":
          put_resource_pool_requester_qos_info()

API

1. Dapatkan ID Pengguna RAM atau ID Peran RAM.

2. Panggil PutResourcePoolRequesterQoSInfo dengan badan permintaan berikut:

      <QoSConfiguration>
        <TotalUploadBandwidth>100</TotalUploadBandwidth>
        <IntranetUploadBandwidth>50</IntranetUploadBandwidth>
        <ExtranetUploadBandwidth>50</ExtranetUploadBandwidth>
        <TotalDownloadBandwidth>200</TotalDownloadBandwidth>
        <IntranetDownloadBandwidth>150</IntranetDownloadBandwidth>
        <ExtranetDownloadBandwidth>50</ExtranetDownloadBandwidth>
      </QoSConfiguration>

ossutil

1. Buat file konfigurasi prioritas bernama priority-qos.xml:

      <PriorityQosConfiguration>
        <PriorityCount>3</PriorityCount>
        <DefaultPriorityLevel>1</DefaultPriorityLevel>
   
        <!-- Default minimum bandwidth commitment for unassigned priority levels -->
        <DefaultGuaranteedQosConfiguration>
          <TotalUploadBandwidth>10</TotalUploadBandwidth>
          <IntranetUploadBandwidth>5</IntranetUploadBandwidth>
          <ExtranetUploadBandwidth>5</ExtranetUploadBandwidth>
          <TotalDownloadBandwidth>20</TotalDownloadBandwidth>
          <IntranetDownloadBandwidth>10</IntranetDownloadBandwidth>
          <ExtranetDownloadBandwidth>10</ExtranetDownloadBandwidth>
        </DefaultGuaranteedQosConfiguration>
   
        <!-- Priority 3 (highest): core service buckets -->
        <QosPriorityLevelConfiguration>
          <PriorityLevel>3</PriorityLevel>
          <GuaranteedQosConfiguration>
            <TotalUploadBandwidth>50</TotalUploadBandwidth>
            <IntranetUploadBandwidth>20</IntranetUploadBandwidth>
            <ExtranetUploadBandwidth>30</ExtranetUploadBandwidth>
            <TotalDownloadBandwidth>80</TotalDownloadBandwidth>
            <IntranetDownloadBandwidth>30</IntranetDownloadBandwidth>
            <ExtranetDownloadBandwidth>50</ExtranetDownloadBandwidth>
          </GuaranteedQosConfiguration>
          <Subjects>
            <Bucket>critical-bucket</Bucket>
            <BucketGroup>core-group</BucketGroup>
          </Subjects>
        </QosPriorityLevelConfiguration>
   
        <!-- Priority 2: important service buckets -->
        <QosPriorityLevelConfiguration>
          <PriorityLevel>2</PriorityLevel>
          <GuaranteedQosConfiguration>
            <TotalUploadBandwidth>30</TotalUploadBandwidth>
            <IntranetUploadBandwidth>10</IntranetUploadBandwidth>
            <ExtranetUploadBandwidth>20</ExtranetUploadBandwidth>
            <TotalDownloadBandwidth>50</TotalDownloadBandwidth>
            <IntranetDownloadBandwidth>20</IntranetDownloadBandwidth>
            <ExtranetDownloadBandwidth>30</ExtranetDownloadBandwidth>
          </GuaranteedQosConfiguration>
          <Subjects>
            <Bucket>important-bucket</Bucket>
          </Subjects>
        </QosPriorityLevelConfiguration>
      </PriorityQosConfiguration>

2. Terapkan konfigurasi (ganti hz-rp-03 dengan nama kolam sumber daya Anda):

      ossutil api invoke-operation --op-name put-resource-pool-priority-qos-configuration --method PUT --parameters resourcePool=hz-rp-03 --parameters priorityQos --body=file://priority-qos.xml

3. (Opsional) Verifikasi konfigurasi:

      ossutil api invoke-operation --op-name get-resource-pool-priority-qos-configuration --method GET --parameters resourcePool=hz-rp-03 --parameters priorityQos

SDK

Go

package main

import (
    "bytes"
    "context"
    "crypto/md5"
    "encoding/base64"
    "fmt"
    "os"

    "github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
    "github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)

func PutResourcePoolPriorityQosConfiguration() {
    // Ganti cn-hangzhou dengan wilayah bucket Anda
    cfg := oss.LoadDefaultConfig().
        WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
        WithRegion("cn-hangzhou")

    client := oss.NewClient(cfg)

    resourcePool := "hz-rp-01" // Ganti dengan nama kolam sumber daya Anda

    qosConf, err := os.ReadFile("priority-qos.xml")
    if err != nil {
        fmt.Printf("failed to read priority-qos.xml: %v\n", err)
        os.Exit(1)
    }

    calcMd5 := func(input []byte) string {
        if len(input) == 0 {
            return "1B2M2Y8AsgTpgAmY7PhCfg=="
        }
        h := md5.New()
        h.Write(input)
        return base64.StdEncoding.EncodeToString(h.Sum(nil))
    }

    input := &oss.OperationInput{
        OpName: "PutResourcePoolPriorityQoSConfiguration",
        Method: "PUT",
        Parameters: map[string]string{
            "priorityQos":  "",
            "resourcePool": resourcePool,
        },
        Headers: map[string]string{
            "Content-MD5": calcMd5(qosConf),
        },
        Body:   bytes.NewReader(qosConf),
        Bucket: nil,
    }

    res, err := client.InvokeOperation(context.TODO(), input)
    if err != nil {
        fmt.Printf("invoke operation got error: %v\n", err)
        os.Exit(1)
    }

    fmt.Println("PutResourcePoolPriorityQoSConfiguration result:", res.Status)
}

API

PutResourcePoolPriorityQosConfiguration

ossutil

1. Buat file konfigurasi prioritas requester bernama requester-priority-qos.xml:

      <PriorityQosConfiguration>
        <PriorityCount>3</PriorityCount>
        <DefaultPriorityLevel>1</DefaultPriorityLevel>
   
        <!-- Default minimum bandwidth commitment for unassigned requesters -->
        <DefaultGuaranteedQosConfiguration>
          <TotalUploadBandwidth>10</TotalUploadBandwidth>
          <IntranetUploadBandwidth>5</IntranetUploadBandwidth>
          <ExtranetUploadBandwidth>5</ExtranetUploadBandwidth>
          <TotalDownloadBandwidth>20</TotalDownloadBandwidth>
          <IntranetDownloadBandwidth>10</IntranetDownloadBandwidth>
          <ExtranetDownloadBandwidth>10</ExtranetDownloadBandwidth>
        </DefaultGuaranteedQosConfiguration>
   
        <!-- Priority 3 (highest): premium customers -->
        <QosPriorityLevelConfiguration>
          <PriorityLevel>3</PriorityLevel>
          <GuaranteedQosConfiguration>
            <TotalUploadBandwidth>60</TotalUploadBandwidth>
            <IntranetUploadBandwidth>20</IntranetUploadBandwidth>
            <ExtranetUploadBandwidth>40</ExtranetUploadBandwidth>
            <TotalDownloadBandwidth>100</TotalDownloadBandwidth>
            <IntranetDownloadBandwidth>40</IntranetDownloadBandwidth>
            <ExtranetDownloadBandwidth>60</ExtranetDownloadBandwidth>
          </GuaranteedQosConfiguration>
          <Subjects>
            <Requester>123456789012****</Requester>
            <Requester>234567890123****</Requester>
          </Subjects>
        </QosPriorityLevelConfiguration>
   
        <!-- Priority 2: standard customers -->
        <QosPriorityLevelConfiguration>
          <PriorityLevel>2</PriorityLevel>
          <GuaranteedQosConfiguration>
            <TotalUploadBandwidth>30</TotalUploadBandwidth>
            <IntranetUploadBandwidth>10</IntranetUploadBandwidth>
            <ExtranetUploadBandwidth>20</ExtranetUploadBandwidth>
            <TotalDownloadBandwidth>50</TotalDownloadBandwidth>
            <IntranetDownloadBandwidth>20</IntranetDownloadBandwidth>
            <ExtranetDownloadBandwidth>30</ExtranetDownloadBandwidth>
          </GuaranteedQosConfiguration>
          <Subjects>
            <Requester>345678901234****</Requester>
          </Subjects>
        </QosPriorityLevelConfiguration>
      </PriorityQosConfiguration>

2. Terapkan konfigurasi:

      ossutil api invoke-operation --op-name put-resource-pool-requester-priority-qos-configuration --method PUT --parameters resourcePool=hz-rp-03 --parameters requesterPriorityQos --body=file://requester-priority-qos.xml

3. (Opsional) Verifikasi konfigurasi:

      ossutil api invoke-operation --op-name get-resource-pool-requester-priority-qos-configuration --method GET --parameters resourcePool=hz-rp-03 --parameters requesterPriorityQos

SDK

Go

package main

import (
    "bytes"
    "context"
    "crypto/md5"
    "encoding/base64"
    "fmt"
    "os"

    "github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
    "github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)

func PutResourcePoolRequesterPriorityQosConfiguration() {
    cfg := oss.LoadDefaultConfig().
        WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
        WithRegion("cn-hangzhou") // Ganti dengan wilayah Anda

    client := oss.NewClient(cfg)

    resourcePool := "hz-rp-01" // Ganti dengan nama kolam sumber daya Anda

    qosConf, err := os.ReadFile("requester-priority-qos.xml")
    if err != nil {
        fmt.Printf("failed to read requester-priority-qos.xml: %v\n", err)
        os.Exit(1)
    }

    calcMd5 := func(input []byte) string {
        if len(input) == 0 {
            return "1B2M2Y8AsgTpgAmY7PhCfg=="
        }
        h := md5.New()
        h.Write(input)
        return base64.StdEncoding.EncodeToString(h.Sum(nil))
    }

    input := &oss.OperationInput{
        OpName: "PutResourcePoolRequesterPriorityQoSConfiguration",
        Method: "PUT",
        Parameters: map[string]string{
            "requesterPriorityQos": "",
            "resourcePool":         resourcePool,
        },
        Headers: map[string]string{
            "Content-MD5": calcMd5(qosConf),
        },
        Body:   bytes.NewReader(qosConf),
        Bucket: nil,
    }

    res, err := client.InvokeOperation(context.TODO(), input)
    if err != nil {
        fmt.Printf("invoke operation got error: %v\n", err)
        os.Exit(1)
    }

    fmt.Println("PutResourcePoolRequesterPriorityQoSConfiguration result:", res.Status)
}

API

PutResourcePoolRequesterPriorityQosConfiguration