Object Storage Service：Gunakan pengambilan skalar untuk menanyakan file di OSS berdasarkan properti metadata

import com.aliyun.oss.*;
import com.aliyun.oss.common.auth.*;
import com.aliyun.oss.common.comm.SignVersion;
import com.aliyun.oss.model.MetaQueryMode;

public class OpenMetaQuery {
    public static void main(String[] args) throws com.aliyuncs.exceptions.ClientException {
        // Dalam contoh ini, endpoint dari wilayah Cina (Hangzhou) digunakan.
        String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
        // Tentukan nama bucket. Contoh: examplebucket.
        String bucketName = "examplebucket";
        // Dapatkan kredensial akses dari variabel lingkungan. 
        // Sebelum menjalankan kode sampel, pastikan bahwa variabel lingkungan OSS_ACCESS_KEY_ID dan OSS_ACCESS_KEY_SECRET telah dikonfigurasi.
        EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
        // Tentukan wilayah tempat bucket berada. Misalnya, jika bucket berada di wilayah Cina (Hangzhou), atur wilayah menjadi cn-hangzhou.
        String region = "cn-hangzhou";

        // Buat instance OSSClient.
        // Panggil metode shutdown untuk melepaskan sumber daya terkait ketika instance 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 fitur MetaSearch.
            ossClient.openMetaQuery(bucketName);
        } catch (OSSException oe) {
            System.out.println("Pesan Kesalahan:" + oe.getErrorMessage());
            System.out.println("Kode Kesalahan:" + oe.getErrorCode());
            System.out.println("ID Permintaan:" + oe.getRequestId());
            System.out.println("ID Host:" + oe.getHostId());
        } catch (ClientException ce) {
            System.out.println("Pesan Kesalahan: " + ce.getMessage());
        } finally {
            // Matikan instance OSSClient.
            if(ossClient != null){
                ossClient.shutdown();
            }
        }
    }
}

import argparse
import alibabacloud_oss_v2 as oss

# Buat parser parameter baris perintah dan tambahkan deskripsi.
parser = argparse.ArgumentParser(description="contoh open meta query")
# Tambahkan parameter baris perintah --region yang diperlukan, yang menentukan wilayah tempat bucket berada.
parser.add_argument('--region', help='Wilayah tempat bucket berada.', required=True)
# Tambahkan parameter baris perintah --bucket yang diperlukan, yang menentukan nama bucket untuk dioperasikan.
parser.add_argument('--bucket', help='Nama bucket.', required=True)
# Tambahkan parameter baris perintah --endpoint opsional, yang menentukan nama domain untuk digunakan saat mengakses OSS.
parser.add_argument('--endpoint', help='Nama domain yang dapat digunakan layanan lain untuk mengakses OSS')

def main():
    # Parsing argumen baris perintah.
    args = parser.parse_args()

    # Muat informasi otentikasi dari variabel lingkungan.
    credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()

    # Gunakan konfigurasi default yang disediakan oleh SDK.
    cfg = oss.config.load_default()
    # Atur penyedia informasi otentikasi.
    cfg.credentials_provider = credentials_provider
    # Atur wilayah berdasarkan argumen baris perintah.
    cfg.region = args.region
    # Jika endpoint diberikan, perbarui endpoint dalam konfigurasi.
    if args.endpoint is not None:
        cfg.endpoint = args.endpoint

    # Buat klien OSS.
    client = oss.Client(cfg)

    # Mulai permintaan untuk mengaktifkan meta query.
    result = client.open_meta_query(oss.OpenMetaQueryRequest(
            bucket=args.bucket,
    ))

    # Cetak kode status dan ID permintaan dari permintaan.
    print(f'kode status: {result.status_code},'
          f' ID permintaan: {result.request_id},'
          )

# Panggil fungsi utama saat dijalankan sebagai program utama.
if __name__ == "__main__":
    main()

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

var (
	region     string // Definisikan variabel untuk menyimpan informasi wilayah yang diperoleh dari baris perintah.
	bucketName string // Definisikan variabel untuk menyimpan nama bucket yang diperoleh dari baris perintah.
)

// Fungsi init dieksekusi sebelum fungsi utama untuk menginisialisasi program.
func init() {
	// Tetapkan parameter baris perintah untuk menentukan wilayah.
	flag.StringVar(&region, "region", "", "Wilayah tempat bucket berada.")
	// Tetapkan parameter baris perintah untuk menentukan nama bucket.
	flag.StringVar(&bucketName, "bucket", "", "Nama bucket.")
}

func main() {
	flag.Parse() // Parsing parameter baris perintah.

	// Periksa apakah nama bucket diberikan. Jika tidak, program mencetak parameter default dan keluar.
	if len(bucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("parameter tidak valid, nama bucket diperlukan") // Log kesalahan dan hentikan program.
	}

	// Periksa apakah wilayah diberikan. Jika tidak, program mencetak parameter default dan keluar.
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("parameter tidak valid, wilayah diperlukan") // Log kesalahan dan hentikan program.
	}

	// Buat konfigurasi klien dan gunakan variabel lingkungan sebagai penyedia kredensial.
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg) // Gunakan konfigurasi untuk membuat instance klien OSS.

	// Buat permintaan OpenMetaQuery untuk mengaktifkan fitur manajemen metadata untuk bucket tertentu.
	request := &oss.OpenMetaQueryRequest{
		Bucket: oss.Ptr(bucketName), // Tentukan nama bucket untuk dioperasikan.
	}
	result, err := client.OpenMetaQuery(context.TODO(), request) // Eksekusi permintaan untuk mengaktifkan fitur manajemen metadata untuk bucket.
	if err != nil {
		log.Fatalf("gagal membuka meta query %v", err) // Jika terjadi kesalahan, log pesan kesalahan dan hentikan program.
	}

	log.Printf("hasil pembukaan meta query:%#v\n", result) // Cetak hasil pengaktifan manajemen metadata.
}

import com.aliyun.oss.*;
import com.aliyun.oss.common.auth.*;
import com.aliyun.oss.common.comm.SignVersion;
import com.aliyun.oss.model.*;
import java.util.ArrayList;
import java.util.List;

public class DoMetaQuery {
    public static void main(String[] args) throws Exception {
        // Dalam contoh ini, endpoint wilayah China (Hangzhou) digunakan.
        String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
        // Tentukan nama bucket. Contoh: examplebucket.
        String bucketName = "examplebucket";
        // Dapatkan kredensial akses dari variabel lingkungan. 
        // Sebelum menjalankan kode sampel, pastikan variabel lingkungan OSS_ACCESS_KEY_ID dan OSS_ACCESS_KEY_SECRET telah dikonfigurasi.
        EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
        // 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 instance 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 {
            // Kueri objek yang memenuhi kondisi tertentu dan kembalikan objek berdasarkan bidang tertentu dan dalam urutan pengurutan yang ditentukan.
            int maxResults = 20;
            // Kueri objek yang lebih kecil dari 1.048.576 byte, kembalikan hingga 20 objek sekaligus, dan urutkan objek dalam urutan naik.
            String query = "{\"Field\": \"Size\",\"Value\": \"1048576\",\"Operation\": \"lt\"}";
            String sort = "Size";
            DoMetaQueryRequest doMetaQueryRequest = new DoMetaQueryRequest(bucketName, maxResults, query, sort);
            Aggregation aggregationRequest = new Aggregation();
            Aggregations aggregations = new Aggregations();
            List<Aggregation> aggregationList = new ArrayList<Aggregation>();
            // Tentukan nama bidang yang digunakan dalam operasi agregasi.
            aggregationRequest.setField("Size");
            // Tentukan operator yang digunakan dalam operasi agregasi. max menunjukkan nilai maksimum.
            aggregationRequest.setOperation("max");
            aggregationList.add(aggregationRequest);
            aggregations.setAggregation(aggregationList);

            // Tentukan operasi agregasi.
            doMetaQueryRequest.setAggregations(aggregations);
            doMetaQueryRequest.setOrder(SortOrder.ASC);
            DoMetaQueryResult doMetaQueryResult = ossClient.doMetaQuery(doMetaQueryRequest);
            if(doMetaQueryResult.getFiles() != null){
                for(ObjectFile file : doMetaQueryResult.getFiles().getFile()){
                    System.out.println("Nama File: " + file.getFilename());
                    // Kueri nilai ETag yang digunakan untuk mengidentifikasi konten objek.
                    System.out.println("ETag: " + file.getETag());
                    // Kueri daftar kontrol akses (ACL) objek.
                    System.out.println("ObjectACL: " + file.getObjectACL());
                    // Kueri tipe objek.
                    System.out.println("OssObjectType: " + file.getOssObjectType());
                    // Kueri kelas penyimpanan objek.
                    System.out.println("OssStorageClass: " + file.getOssStorageClass());
                    // Kueri jumlah tag objek.
                    System.out.println("TaggingCount: " + file.getOssTaggingCount());
                    if(file.getOssTagging() != null){
                        for(Tagging tag : file.getOssTagging().getTagging()){
                            System.out.println("Key: " + tag.getKey());
                            System.out.println("Value: " + tag.getValue());
                        }
                    }
                    if(file.getOssUserMeta() != null){
                        for(UserMeta meta : file.getOssUserMeta().getUserMeta()){
                            System.out.println("Key: " + meta.getKey());
                            System.out.println("Value: " + meta.getValue());
                        }
                    }
                }
            } else if(doMetaQueryResult.getAggregations() != null){
                for(Aggregation aggre : doMetaQueryResult.getAggregations().getAggregation()){
                    // Kueri bidang yang digunakan untuk agregasi.
                    System.out.println("Field: " + aggre.getField());
                    // Kueri operator agregasi.
                    System.out.println("Operation: " + aggre.getOperation());
                    // Kueri hasil operasi agregasi.
                    System.out.println("Value: " + aggre.getValue());
                    if(aggre.getGroups() != null && aggre.getGroups().getGroup().size() > 0){
                        // Kueri nilai agregasi.
                        System.out.println("Nilai Grup: " + aggre.getGroups().getGroup().get(0).getValue());
                        // Kueri jumlah total agregasi.
                        System.out.println("Jumlah Grup: " + aggre.getGroups().getGroup().get(0).getCount());
                    }
                }
            } else {
                System.out.println("NextToken: " + doMetaQueryResult.getNextToken());
            }
        } catch (OSSException oe) {
            System.out.println("Pesan Kesalahan:" + oe.getErrorMessage());
            System.out.println("Kode Kesalahan:" + oe.getErrorCode());
            System.out.println("ID Permintaan:" + oe.getRequestId());
            System.out.println("ID Host:" + oe.getHostId());
        } catch (ClientException ce) {
            System.out.println("Pesan Kesalahan: " + ce.getMessage());
        } finally {
            // Matikan instance OSSClient.
            ossClient.shutdown();
        }
    }
}

import argparse
import alibabacloud_oss_v2 as oss

# Buat parser parameter baris perintah untuk menerima parameter input pengguna.
parser = argparse.ArgumentParser(description="do meta query sample")
parser.add_argument('--region', help='Wilayah tempat bucket berada.', required=True)
parser.add_argument('--bucket', help='Nama bucket.', required=True)
parser.add_argument('--endpoint', help='Nama domain yang dapat digunakan layanan lain untuk mengakses OSS')

def main():
    # Parse argumen baris perintah.
    args = parser.parse_args()

    # Muat informasi otentikasi dari variabel lingkungan.
    credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()

    # Gunakan konfigurasi default SDK.
    cfg = oss.config.load_default()
    # Setel penyedia otentikasi.
    cfg.credentials_provider = credentials_provider
    # Setel wilayah berdasarkan parameter input.
    cfg.region = args.region
    # Jika endpoint disediakan, perbarui endpoint dalam konfigurasi.
    if args.endpoint is not None:
        cfg.endpoint = args.endpoint

    # Buat klien OSS.
    client = oss.Client(cfg)

    # Jalankan operasi kueri meta.
    result = client.do_meta_query(oss.DoMetaQueryRequest(
            bucket=args.bucket,  # Tentukan bucket untuk dikueri.
            meta_query=oss.MetaQuery(  # Definisikan isi spesifik dari kueri.
                aggregations=oss.MetaQueryAggregations(  # Definisikan operasi agregasi.
                    aggregations=[  # Daftar agregasi.
                        oss.MetaQueryAggregation(  # Agregasi pertama: hitung total ukuran.
                            field='Size',
                            operation='sum',
                        ),
                        oss.MetaQueryAggregation(  # Agregasi kedua: temukan nilai maksimum.
                            field='Size',
                            operation='max',
                        )
                    ],
                ),
                next_token='',  # Token paginasi.
                max_results=80369,  # Jumlah maksimum hasil yang akan dikembalikan.
                query='{"Field": "Size","Value": "1048576","Operation": "gt"}',  # Kondisi kueri.
                sort='Size',  # Bidang pengurutan.
                order=oss.MetaQueryOrderType.DESC,  # Urutan pengurutan.
            ),
    ))

    # Keluarkan informasi dasar dari hasil kueri.
    print(f'kode status: {result.status_code},'
          f' ID permintaan: {result.request_id},'
          # Bagian yang dikomentari berikut dapat diaktifkan sesuai kebutuhan untuk mendapatkan informasi lebih rinci.
          # f' file: {result.files},'
          # f' file: {result.files.file},'
          # f' waktu modifikasi file: {result.files.file.file_modified_time},'
          # f' etag: {result.files.file.etag},'
          # f' enkripsi sisi server: {result.files.file.server_side_encryption},'
          # f' jumlah tagging OSS: {result.files.file.oss_tagging_count},'
          # f' tagging OSS: {result.files.file.oss_tagging},'
          # f' key: {result.files.file.oss_tagging.taggings[0].key},'
          # f' value: {result.files.file.oss_tagging.taggings[0].value},'
          # f' key: {result.files.file.oss_tagging.taggings[1].key},'
          # f' value: {result.files.file.oss_tagging.taggings[1].value},'
          # f' metadata pengguna OSS: {result.files.file.oss_user_meta},'
          # f' key: {result.files.file.oss_user_meta.user_metas[0].key},'
          # f' value: {result.files.file.oss_user_meta.user_metas[0].value},'
          # f' key: {result.files.file.oss_user_meta.user_metas[1].key},'
          # f' value: {result.files.file.oss_user_meta.user_metas[1].value},'
          # f' nama file: {result.files.file.filename},'
          # f' ukuran: {result.files.file.size},'
          # f' jenis objek OSS: {result.files.file.oss_object_type},'
          # f' kelas penyimpanan OSS: {result.files.file.oss_storage_class},'
          # f' ACL objek: {result.files.file.object_acl},'
          # f' CRC64 OSS: {result.files.file.oss_crc64},'
          # f' algoritma enkripsi sisi server pelanggan: {result.files.file.server_side_encryption_customer_algorithm},'
          # f' agregasi: {result.aggregations},'
          f' bidang: {result.aggregations.aggregations[0].field},'
          f' operasi: {result.aggregations.aggregations[0].operation},'
          f' bidang: {result.aggregations.aggregations[1].field},'
          f' operasi: {result.aggregations.aggregations[1].operation},'
          f' token berikutnya: {result.next_token},'
    )

    # Jika informasi file ada, cetak tag dan metadata yang ditentukan pengguna.
    if result.files:
        if result.files.file.oss_tagging.taggings:
            for r in result.files.file.oss_tagging.taggings:
                print(f'hasil: key: {r.key}, value: {r.value}')
        if result.files.file.oss_user_meta.user_metas:
            for r in result.files.file.oss_user_meta.user_metas:
                print(f'hasil: key: {r.key}, value: {r.value}')
    # Cetak hasil semua agregasi.
    if result.aggregations.aggregations:
        for r in result.aggregations.aggregations:
            print(f'hasil: bidang: {r.field}, operasi: {r.operation}')

if __name__ == "__main__":
    main()