Object Storage Service:データインデックス作成

com.aliyun.oss.ClientExceptionをインポートします。com.aliyun.oss.OSSをインポートします。impor t com.aliyun.oss.com mon.auth.*;
com.aliyun.oss.OSSClientBuilderをインポートします。com.aliyun.oss.OSSExceptionをインポートします。com.aliyun.oss.mo delをインポートします。*;
java.util.ArrayListをインポートします。java.util.Listをインポートします。public classデモ {

    // この例では、中国 (杭州) リージョンのエンドポイントが使用されます。 実際のエンドポイントを指定します。 
    プライベート静的文字列エンドポイント="https://oss-cn-hangzhou.aliyuncs.com";
    // バケットの名前を指定します。 例: examplebucket. 
    プライベート静的文字列bucketName = "examplebucket";

    public static void main(String[] args) throws Exception {
        // 環境変数からアクセス資格情報を取得します。 サンプルコードを実行する前に、OSS_ACCESS_KEY_IDおよびOSS_ACCESS_KEY_SECRET環境変数が設定されていることを確認してください。 
        EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
        // Create an OSSClient instance. 
        OSS ossClient = new OSSClientBuilder().build(endpoint, credentialsProvider);

        try {
            // 特定の条件を満たすオブジェクトを照会し、特定のフィールドとソート方法に基づいてオブジェクトに関する情報を一覧表示します。 
            int maxResults = 20;
            // サイズが1,048,576バイト未満のオブジェクトを照会し、一度に最大20個のオブジェクトを返し、オブジェクトを昇順に並べ替えます。 
            String query = "{\" Field\": \" Size\",\" Value\": \" 1048576\",\" Operation\": \" lt\"}";
            文字列ソート="サイズ";
            DoMetaQueryRequest doMetaQueryRequest=新しいDoMetaQueryRequest(bucketName、maxResults、query、sort);
            Aggregation aggregationRequest = new Aggregation();
            Aggregations aggregations = new Aggregations();
            List<Aggregation> aggregationList = new ArrayList<Aggregation>();
            // 集計操作で使用されるフィールドの名前を指定します。 
            aggregationRequest.setField("サイズ");
            // 集計操作で使用する演算子を指定します。 maxは最大値を示す。 
            aggregationRequest.setOperation("max");
            aggregationList.add(aggregationRequest);
            aggregations.setAggregation(aggregationList);

            // 集計操作を指定します。 
            doMetaQueryRequest.setAggregations (集計);
            doMetaQueryRequest.setOrder(SortOrder.ASC);
            DoMetaQueryResult doMetaQueryResult = ossClient.doMetaQuery(doMetaQueryRequest);
            if(doMetaQueryResult.getFiles() ! =null){
                for(ObjectFileファイル: doMetaQueryResult.getFiles().getFile()){
                    System.out.println("Filename: " + file.getFilename());
                    // オブジェクトのコンテンツを識別するために使用されるETag値を照会します。 
                    System.out.println("ETag: " + file.getETag());
                    // オブジェクトのアクセス制御リスト (ACL) を照会します。
                    System.out.println("ObjectACL: " + file.getObjectACL());
                    // オブジェクトのタイプを照会します。 
                    System.out.println("OssObjectType: " + file.getOssObjectType());
                    // オブジェクトのストレージクラスを照会します。 
                    System.out.println("OssStorageClass: " + file.getOssStorageClass());
                    // オブジェクトのタグ数を照会します。 
                    System.out.println("TaggingCount: " + file.getOssTaggingCount());
                    if(file.getOssTagging() !) =null){
                        for (タグ: 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()){
                    // 集計フィールドの名前を照会します。 
                    System.out.println("Field: " + aggre.getField());
                    // 集計演算子を照会します。 
                    System.out.println("Operation: " + aggre.getOperation());
                    // 集計操作の値を照会します。 
                    System.out.println("Value: " + aggre.getValue());
                    if(aggre.getGroups() ! =null && aggre.getGroups().getGroup().size() > 0){
                        // グループごとに集計操作の値を照会します。 
                        System.out.println("Groups value: " + aggre.getGroups().getGroup().get(0).getValue());
                        // グループごとに集計操作の総数を照会します。 
                        System.out.println("Groups count: " + aggre.getGroups().getGroup().get(0).getCount());
                    }
                }
            } else {
                System.out.println("NextToken: " + doMetaQueryResult.getNextToken());
            }
        } catch (Exception e) {
            System.out.println("エラーメッセージ:" + oe.getErrorMessage());
            System.out.println("エラーコード:" + oe.getErrorCode());
            System.out.println("リクエストID:" + oe.getRequestId());
            System.out.println("ホストID:" + oe.getHostId());
        } catch (ClientException e) {
            System.out.println("Error Message: " + ce.getMessage());
        } 最後に{
            // Shut down the OSSClient instance. 
            ossClient.shutdown();
        }
    }

# -*-コーディング: utf-8 -*-
oss2のインポート
oss2.credentialsからEnvironmentVariableCredentialsProviderをインポート
oss2.modelsからMetaQuery、AggregationsRequestをインポート
# 環境変数からアクセス資格情報を取得します。 サンプルコードを実行する前に、OSS_ACCESS_KEY_IDおよびOSS_ACCESS_KEY_SECRET環境変数が設定されていることを確認してください。 
auth = oss2.ProviderAuth(EnvironmentVariableCredentialsProvider())

# この例では、中国 (杭州) リージョンのエンドポイントが使用されます。 実際のエンドポイントを指定します。 
# バケットの名前を指定します。 例: examplebucket. 
bucket = oss2.Bucket(auth, 'http:// oss-cn-hangzhou.aliyuncs.com ', 'examplebucket')

# 特定の条件を満たすオブジェクトを照会し、特定のフィールドとソート方法に基づいてオブジェクト情報を一覧表示します。 
#1 MB未満のオブジェクトを照会し、一度に最大10個のオブジェクトを返し、オブジェクトを昇順で並べ替えます。 
do_meta_query_request = MetaQuery(max_results=10、query='{"Field": "Size" 、"Value": "1048576" 、"Operation": "lt"}' 、sort='Size' 、order='asc')
result = bucket.do_bucket_meta_query(do_meta_query_request)

# オブジェクト名を表示します。 
print(result.files[0].file_name)
# オブジェクトのETagsを表示します。 
print(result.files[0].etag)
# オブジェクトのタイプを表示します。 
print(result.files[0].oss_object_type)
# オブジェクトのストレージクラスを表示します。 
print(result.files[0].oss_storage_class)
# オブジェクトのCRC-64値を表示します。 
print(result.files[0].oss_crc64)
# オブジェクトのアクセス制御リスト (ACL) を表示します。 
プリント (result.files[0].object_acl) 

パッケージメイン

import (import (import)
    "fmt"
    "github.com/aliyun/aliyun-oss-go-sdk/oss"
    "os"
)
func main() {
    // 環境変数からアクセス資格情報を取得します。 サンプルコードを実行する前に、OSS_ACCESS_KEY_IDおよびOSS_ACCESS_KEY_SECRET環境変数が設定されていることを確認してください。 
    provider, err := oss.NewEnvironmentVariableCredentialsProvider()
    if err! =nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }

    // Create an OSSClient instance. 
    // バケットが配置されているリージョンのエンドポイントを指定します。 たとえば、バケットが中国 (杭州) リージョンにある場合、エンドポイントをhttps://oss-cn-hangzhou.aliyuncs.comに設定します。 実際のエンドポイントを指定します。 
    client, err := oss.New("yourEndpoint", ", " ", ", oss.SetCredentialsProvider(&provider))
    if err! =nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }    
    // サイズが30バイトを超えるオブジェクトを照会し、同時に最大10個のオブジェクトを返し、オブジェクトを昇順に並べ替えます。 
    query := oss.MetaQuery {
        NextToken: "" 、
        MaxResults: 10,
        クエリ: '{"Field": "Size","Value": "30","Operation": "gt"}',
        並べ替え: 「サイズ」、
        注文: "asc" 、
    }
    // 指定された条件に一致するオブジェクトを照会し、指定されたフィールドとソート方法に基づいてオブジェクト情報を一覧表示します。 
    result,err := client.DoMetaQuery("examplebucket",query)
    if err! =nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    fmt.Printf("NextToken:% s\n", result.NextToken)
    _, file := range result.Files {
        fmt.Printf("ファイル名: % s\n", File. Filename)
        fmt.Printf("size: % d\n", file.Size)
        fmt.Printf("File Modified Time:% s\n", file.FileModifiedTime)
        fmt.Printf("Oss Object Type:% s\n", file.OssObjectType)
        fmt.Printf("Oss Storage Class:% s\n", file.OssStorageClass)
        fmt.Printf("Object ACL:% s\n", file.ObjectACL)
        fmt.Printf("ETag:% s\n", file.ETag)
        fmt.Printf("Oss CRC64:% s\n", file.OssCRC64)
        fmt.Printf("Oss Tagging Count:% d\n", file.OssTaggingCount)
        for _, tagging := range file.OssTagging {
            fmt.Printf("Oss Tagging Key:% s\n", tagging.Key)
            fmt.Printf("Oss Tagging Value:% s\n", tagging.Value)
        }
        _, userMeta := range file.OssUserMeta {
            fmt.Printf("Oss User Meta Key:% s\n", userMeta.Key)
            fmt.Printf("Oss User Meta Key Value:% s\n", userMeta.Value)
        }
    }
}