Object Storage Service：Gunakan aturan lifecycle berdasarkan waktu akses terakhir untuk menerapkan tiering data cerdas

1. Aktifkan pelacakan akses.

   1. Masuk ke Konsol OSS.

   2. Di panel navigasi sebelah kiri, klik Buckets. Pada halaman Buckets, temukan dan klik bucket yang diinginkan.

   3. Di panel navigasi sebelah kiri, pilih Data Management > Lifecycle.

   4. Pada halaman Lifecycle, aktifkan sakelar Enable Access Tracking.

      Catatan

      Setelah Anda mengaktifkan pelacakan akses, OSS menetapkan waktu akses terakhir untuk semua objek dalam bucket ke waktu saat pelacakan akses diaktifkan.

2. Konfigurasikan aturan lifecycle.

   1. Pada halaman Lifecycle, klik Create Rule.

   2. Pada panel Create Lifecycle Rule, konfigurasikan aturan lifecycle untuk awalan data/ dan awalan log/ seperti dijelaskan pada bagian berikut.

      Aturan lifecycle untuk awalan data/

      Konfigurasikan parameter yang diperlukan untuk aturan lifecycle awalan data/ seperti dijelaskan di bawah. Anda dapat mempertahankan pengaturan default untuk parameter lainnya.

      Item konfigurasi	Deskripsi
      Status	Klik Start.
      Applied To	Pilih Match by Prefix.
      Prefix	Masukkan data/.
      Object Lifecycle	Pilih Specify Days.
      Lifecycle-based Rules	Dari daftar tarik-turun, pilih Last Access Time. Masukkan 200 hari. Data secara otomatis dialihkan ke Infrequent Access (Data remains in IA after being accessed).

      Aturan lifecycle untuk awalan log/

      Konfigurasikan parameter yang diperlukan untuk aturan lifecycle awalan log/ seperti dijelaskan di bawah. Anda dapat mempertahankan pengaturan default untuk parameter lainnya.

      Item konfigurasi	Deskripsi
      Status	Pilih Start.
      Applied To	Pilih Match by Prefix.
      Prefix	Masukkan log/.
      Object Lifecycle	Pilih Specify Days.
      Lifecycle-based Rules	Dari daftar tarik-turun, pilih Last Access Time. Masukkan 120 hari. Data secara otomatis dialihkan ke Infrequent Access (Data remains in IA after being accessed). Dari daftar tarik-turun, pilih Last Access Time. Masukkan 250 hari. Data secara otomatis dialihkan ke Archive.

   3. Klik OK.

Hanya SDK Java, Python, dan Go yang mendukung pembuatan aturan lifecycle berdasarkan waktu akses terakhir. Sebelum membuat aturan lifecycle berdasarkan waktu akses terakhir, Anda harus mengaktifkan pelacakan akses untuk bucket yang ditentukan.

1. Aktifkan pelacakan akses.

   Java

   import com.aliyun.oss.*;
   import com.aliyun.oss.common.auth.*;
   import com.aliyun.oss.common.comm.SignVersion;
   import com.aliyun.oss.model.AccessMonitor;
   
   public class Demo {
   
       public static void main(String[] args) throws Exception {
           // Dalam contoh ini, endpoint wilayah China (Hangzhou) digunakan. Tentukan endpoint aktual Anda.
           String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
           // Dapatkan kredensial akses dari variabel lingkungan. Sebelum menjalankan kode contoh, pastikan variabel lingkungan OSS_ACCESS_KEY_ID dan OSS_ACCESS_KEY_SECRET telah dikonfigurasi.
           EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
           // Tentukan nama bucket. Contoh: examplebucket.
           String bucketName = "examplebucket";
   
           // Tentukan wilayah tempat bucket berada. Misalnya, jika bucket berada di wilayah China (Hangzhou), atur wilayah ke cn-hangzhou.
           String region = "cn-hangzhou";
   
           // Buat instance OSSClient.
           // Panggil metode shutdown untuk melepaskan sumber daya terkait ketika OSSClient tidak lagi digunakan.
           ClientBuilderConfiguration clientBuilderConfiguration = new ClientBuilderConfiguration();
           clientBuilderConfiguration.setSignatureVersion(SignVersion.V4);        
           OSS ossClient = OSSClientBuilder.create()
           .endpoint(endpoint)
           .credentialsProvider(credentialsProvider)
           .clientConfiguration(clientBuilderConfiguration)
           .region(region)               
           .build();
   
           try {
               // Aktifkan pelacakan akses untuk bucket. Sebelum mengubah status pelacakan akses dari Enabled ke Disabled, pastikan tidak ada aturan lifecycle berdasarkan waktu akses terakhir untuk bucket tersebut.
               ossClient.putBucketAccessMonitor(bucketName, AccessMonitor.AccessMonitorStatus.Enabled.toString());
           } 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
   
   # Dapatkan kredensial akses dari variabel lingkungan. Sebelum menjalankan kode ini, pastikan variabel lingkungan OSS_ACCESS_KEY_ID dan OSS_ACCESS_KEY_SECRET telah diatur.
   auth = oss2.ProviderAuthV4(EnvironmentVariableCredentialsProvider())
   
   # Tentukan endpoint untuk wilayah tempat bucket berada. Misalnya, jika bucket berada di wilayah China (Hangzhou), atur endpoint ke https://oss-cn-hangzhou.aliyuncs.com.
   endpoint = "https://oss-cn-hangzhou.aliyuncs.com"
   # Tentukan wilayah yang sesuai dengan endpoint, misalnya cn-hangzhou. Catatan: Parameter ini wajib untuk signature V4.
   region = "cn-hangzhou"
   
   # Ganti "examplebucket" dengan nama bucket Anda.
   bucket = oss2.Bucket(auth, endpoint, "examplebucket", region=region)
   
   # Aktifkan pelacakan akses untuk bucket. Setelah pelacakan akses diaktifkan, jika Anda ingin mengubah status menjadi Disabled, pastikan bucket tidak memiliki aturan lifecycle berdasarkan aturan pencocokan LastAccessTime.
   bucket.put_bucket_access_monitor("Enabled")

   Go

   package main
   
   import (
   	"context"
   	"flag"
   	"log"
   
   	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
   	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
   )
   
   // Definisikan variabel global.
   var (
   	region     string // Wilayah bucket.
   	bucketName string // Nama bucket.
   )
   
   // Fungsi init menginisialisasi parameter baris perintah.
   func init() {
   	flag.StringVar(&region, "region", "", "Wilayah tempat bucket berada.")
   	flag.StringVar(&bucketName, "bucket", "", "Nama bucket.")
   }
   
   // Fungsi main mengaktifkan pelacakan akses untuk bucket.
   func main() {
   	// Parsing parameter baris perintah.
   	flag.Parse()
   
   	// Periksa apakah nama bucket kosong.
   	if len(bucketName) == 0 {
   		flag.PrintDefaults()
   		log.Fatalf("invalid parameters, bucket name required")
   	}
   
   	// Periksa apakah wilayah kosong.
   	if len(region) == 0 {
   		flag.PrintDefaults()
   		log.Fatalf("invalid parameters, region required")
   	}
   
   	// Muat konfigurasi default, dan atur penyedia kredensial serta wilayah.
   	cfg := oss.LoadDefaultConfig().
   		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
   		WithRegion(region)
   
   	// Buat klien OSS.
   	client := oss.NewClient(cfg)
   
   	// Buat permintaan untuk mengaktifkan pelacakan akses untuk bucket.
   	request := &oss.PutBucketAccessMonitorRequest{
   		Bucket: oss.Ptr(bucketName),
   		AccessMonitorConfiguration: &oss.AccessMonitorConfiguration{
   			Status: oss.AccessMonitorStatusEnabled, // Aktifkan pelacakan akses.
   		},
   	}
   
   	// Jalankan operasi untuk mengaktifkan pelacakan akses untuk bucket.
   	putResult, err := client.PutBucketAccessMonitor(context.TODO(), request)
   	if err != nil {
   		log.Fatalf("failed to put bucket access monitor %v", err)
   	}
   
   	// Cetak hasilnya.
   	log.Printf("put bucket access monitor result: %#v\n", putResult)
   }
   

2. Konfigurasikan aturan lifecycle berdasarkan waktu akses terakhir untuk awalan data/ dan awalan log/.

   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.*;
   import java.util.ArrayList;
   import java.util.List;
   
   public class Lifecycle {
   
       public static void main(String[] args) throws Exception {
           // Endpoint diatur ke China (Hangzhou) dalam contoh ini. Tentukan endpoint aktual.
           String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
           // Dapatkan kredensial akses dari variabel lingkungan. Sebelum menjalankan kode contoh, pastikan variabel lingkungan OSS_ACCESS_KEY_ID dan OSS_ACCESS_KEY_SECRET telah diatur.
           EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
           // Tentukan nama bucket, misalnya examplebucket.
           String bucketName = "examplebucket";
   
           // Buat instance OSSClient.
           // Saat instance OSSClient tidak lagi diperlukan, panggil metode shutdown untuk melepaskan sumber daya.
           OSS ossClient = new OSSClientBuilder().build(endpoint, credentialsProvider);
   
           try {
               String ruleId1 = "rule1";
               String ruleId2 = "rule2";
               // Tentukan awalan sebagai data/.
               String matchPrefix = "data/";
               // Tentukan awalan sebagai log/.
               String matchPrefix2 = "log/";
   
               SetBucketLifecycleRequest request = new SetBucketLifecycleRequest(bucketName);
   
               // Dalam aturan lifecycle 1, alihkan semua file dengan awalan data/ ke kelas penyimpanan Infrequent Access 200 hari setelah waktu akses terakhirnya. Ketika file-file ini diakses lagi, mereka tetap berada di kelas penyimpanan Infrequent Access.
               List<LifecycleRule.StorageTransition> storageTransitions = new ArrayList<LifecycleRule.StorageTransition>();
               LifecycleRule.StorageTransition storageTransition = new LifecycleRule.StorageTransition();
               storageTransition.setStorageClass(StorageClass.IA);
               storageTransition.setExpirationDays(200);
               storageTransition.setIsAccessTime(true);
               storageTransition.setReturnToStdWhenVisit(false);
               storageTransitions.add(storageTransition);
   
               LifecycleRule rule = new LifecycleRule(ruleId1, matchPrefix, LifecycleRule.RuleStatus.Enabled);
               rule.setStorageTransition(storageTransitions);
               request.AddLifecycleRule(rule);
   
               // Dalam aturan lifecycle 2, alihkan semua file dengan awalan log/ ke kelas penyimpanan Infrequent Access 120 hari setelah waktu akses terakhirnya. Ketika file-file ini diakses lagi, mereka tetap berada di kelas penyimpanan Infrequent Access.
               List<LifecycleRule.StorageTransition> storageTransitions2 = new ArrayList<LifecycleRule.StorageTransition>();
               LifecycleRule.StorageTransition storageTransition2 = new LifecycleRule.StorageTransition();
               storageTransition2.setStorageClass(StorageClass.IA);
               storageTransition2.setExpirationDays(120);
               storageTransition2.setIsAccessTime(true);
               storageTransition2.setReturnToStdWhenVisit(false);
               storageTransitions2.add(storageTransition2);
               // Dalam aturan yang sama, alihkan semua file dengan awalan log/ ke kelas penyimpanan Archive 250 hari setelah waktu modifikasi terakhirnya.
               LifecycleRule.StorageTransition storageTransition3 = new LifecycleRule.StorageTransition();
               storageTransition3.setStorageClass(StorageClass.Archive);
               storageTransition3.setExpirationDays(250);
               storageTransition3.setIsAccessTime(false);
               storageTransitions2.add(storageTransition3);
   
               LifecycleRule rule2 = new LifecycleRule(ruleId2, matchPrefix2, LifecycleRule.RuleStatus.Enabled);
               rule2.setStorageTransition(storageTransitions2);
               request.AddLifecycleRule(rule2);
   
               VoidResult result = ossClient.setBucketLifecycle(request);
   
               System.out.println("Return status code:"+result.getResponse().getStatusCode()+" set lifecycle succeed");
           } 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 LifecycleRule, BucketLifecycle, StorageTransition
   
   # Dapatkan kredensial akses dari variabel lingkungan. Sebelum menjalankan kode contoh ini, pastikan variabel lingkungan OSS_ACCESS_KEY_ID dan OSS_ACCESS_KEY_SECRET telah diatur.
   auth = oss2.ProviderAuth(EnvironmentVariableCredentialsProvider())
   # Atur yourEndpoint ke endpoint wilayah tempat bucket berada. Misalnya, jika bucket berada di wilayah China (Hangzhou), atur endpoint ke https://oss-cn-hangzhou.aliyuncs.com.
   # Tentukan nama bucket, misalnya examplebucket.
   bucket = oss2.Bucket(auth, 'https://oss-cn-hangzhou.aliyuncs.com', 'examplebucket')
   
   # Dalam aturan lifecycle 1, alihkan semua file dengan awalan data/ ke kelas penyimpanan Infrequent Access 200 hari setelah waktu akses terakhirnya. Ketika file-file ini diakses lagi, mereka tetap berada di kelas penyimpanan Infrequent Access.
   rule1 = LifecycleRule('rule1', 'data/', status=LifecycleRule.ENABLED)
   rule1.storage_transitions = [StorageTransition(days=200,
                                                  storage_class=oss2.BUCKET_STORAGE_CLASS_IA,
                                                  is_access_time=True,
                                                  return_to_std_when_visit=False)]
   
   # Dalam aturan lifecycle 2, alihkan semua file dengan awalan log/ ke kelas penyimpanan Infrequent Access 120 hari setelah waktu akses terakhirnya. Ketika file-file ini diakses lagi, mereka tetap berada di kelas penyimpanan Infrequent Access.
   # Dalam aturan yang sama, alihkan semua file dengan awalan log/ ke kelas penyimpanan Archive 250 hari setelah waktu modifikasi terakhirnya.
   rule2 = LifecycleRule('rule2', 'log/', status=LifecycleRule.ENABLED)
   rule2.storage_transitions = [StorageTransition(days=120,
                                                  storage_class=oss2.BUCKET_STORAGE_CLASS_IA,
                                                  is_access_time=True,
                                                  return_to_std_when_visit=False),
                                StorageTransition(days=250,
                                                  storage_class=oss2.BUCKET_STORAGE_CLASS_ARCHIVE,
                                                  is_access_time=False)]
   
   lifecycle = BucketLifecycle([rule1, rule2])
   
   # Tetapkan aturan lifecycle.
   result = bucket.put_bucket_lifecycle(lifecycle)
   
   print('Lifecycle rule set successfully. Return status:' + str(result.status))

   Go

   package main
   
   import (
   	"context"
   	"flag"
   	"log"
   
   	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
   	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
   )
   
   // Definisikan variabel global.
   var (
   	region     string // Wilayah tempat bucket berada.
   	bucketName string // Nama bucket.
   )
   
   // Tentukan fungsi init yang digunakan untuk menginisialisasi parameter baris perintah.
   func init() {
   	flag.StringVar(&region, "region", "", "Wilayah tempat bucket berada.")
   	flag.StringVar(&bucketName, "bucket", "", "Nama bucket.")
   }
   
   func main() {
   	// Parsing parameter baris perintah.
   	flag.Parse()
   
   	// Periksa apakah nama bucket telah ditentukan.
   	if len(bucketName) == 0 {
   		flag.PrintDefaults()
   		log.Fatalf("invalid parameters, bucket name required")
   	}
   
   	// Periksa apakah wilayah telah ditentukan.
   	if len(region) == 0 {
   		flag.PrintDefaults()
   		log.Fatalf("invalid parameters, region required")
   	}
   
   	// Muat konfigurasi default dan tentukan penyedia kredensial serta wilayah.
   	cfg := oss.LoadDefaultConfig().
   		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
   		WithRegion(region)
   
   	// Buat klien OSS.
   	client := oss.NewClient(cfg)
   
   	// Buat permintaan untuk mengonfigurasi aturan lifecycle untuk bucket.
   	request := &oss.PutBucketLifecycleRequest{
   		Bucket: oss.Ptr(bucketName), // Nama bucket.
   		LifecycleConfiguration: &oss.LifecycleConfiguration{
   			Rules: []oss.LifecycleRule{
   				{
   					// Konfigurasikan rule1 untuk mengubah kelas penyimpanan objek yang namanya mengandung awalan data/ menjadi IA 200 hari setelah akses terakhir. Tentukan bahwa objek tetap berada di kelas penyimpanan IA ketika diakses lagi.
   					ID:     oss.Ptr("rule1"),
   					Status: oss.Ptr("Enabled"),
   					Prefix: oss.Ptr("data/"),
   					Transitions: []oss.LifecycleRuleTransition{
   						{
   							Days:                 oss.Ptr(int32(200)),
   							StorageClass:         oss.StorageClassIA,
   							IsAccessTime:         oss.Ptr(true), // Atur parameter ini ke true untuk menentukan bahwa kelas penyimpanan objek diubah berdasarkan waktu akses terakhir.
   							ReturnToStdWhenVisit: oss.Ptr(false),
   						},
   					},
   				},
   				{
   					// Konfigurasikan rule2 untuk mengubah kelas penyimpanan objek yang namanya mengandung awalan log/ menjadi IA 120 hari setelah akses terakhir. Tentukan bahwa objek tetap berada di kelas penyimpanan IA ketika diakses lagi.
   					// Ubah kelas penyimpanan objek yang namanya mengandung awalan log/ menjadi Archive 250 hari setelah akses terakhir.
   					ID:     oss.Ptr("rule2"),
   					Status: oss.Ptr("Enabled"),
   					Prefix: oss.Ptr("log/"),
   					Transitions: []oss.LifecycleRuleTransition{
   						{
   							Days:                 oss.Ptr(int32(120)),
   							StorageClass:         oss.StorageClassIA,
   							IsAccessTime:         oss.Ptr(true), // Atur parameter ini ke true untuk menentukan bahwa kelas penyimpanan objek diubah berdasarkan waktu akses terakhir.
   							ReturnToStdWhenVisit: oss.Ptr(false),
   						},
   						{
   							Days:                 oss.Ptr(int32(250)),
   							StorageClass:         oss.StorageClassArchive,
   							IsAccessTime:         oss.Ptr(true),
   							ReturnToStdWhenVisit: oss.Ptr(false),
   						},
   					},
   				},
   			},
   		},
   	}
   
   	// Konfigurasikan aturan lifecycle untuk bucket.
   	result, err := client.PutBucketLifecycle(context.TODO(), request)
   	if err != nil {
   		log.Fatalf("failed to put bucket lifecycle %v", err)
   	}
   
   	// Tampilkan hasilnya.
   	log.Printf("put bucket lifecycle result:%#v\n", result)
   }
   

Jika program Anda memiliki persyaratan kustomisasi tinggi, Anda dapat langsung membuat permintaan REST API. Untuk membuat permintaan REST API, Anda harus menulis kode secara manual untuk menghitung signature. Untuk informasi selengkapnya, lihat PutBucketAccessMonitor dan PutBucketLifecycle.