Object Storage Service:Mengelola direktori OSS

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.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.util.ArrayList;
import java.util.List;

public class Demo {

    public static void main(String[] args) throws Exception {
        // Endpoint untuk wilayah China (Hangzhou) digunakan sebagai contoh. Tentukan endpoint untuk wilayah bucket Anda.
        String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
        // Hindari hard-coding kredensial akses dalam kode Anda untuk mencegah risiko keamanan akibat kebocoran. Contoh ini memuat kredensial dari variabel lingkungan. Pastikan variabel ini dikonfigurasi sebelum menjalankan kode.
        EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
        // Tentukan nama bucket, misalnya examplebucket.
        String bucketName = "examplebucket";
        // Tentukan jalur mutlak direktori. Jalur tidak boleh mengandung nama bucket.
        String directoryName = "exampledir";
        // Tentukan jalur lengkap direktori yang akan dihapus. Jalur tidak boleh mengandung nama bucket.
        final String prefix = "log/";

        // Buat instance OSSClient.
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);

        try {
            // Metode 1: Hapus direktori secara rekursif dengan memanggil operasi deleteDirectory. Sebelum menggunakan metode ini, Anda harus mengaktifkan fitur hierarchical namespace.
            DeleteDirectoryRequest deleteDirectoryRequest = new DeleteDirectoryRequest(bucketName, directoryName);
            deleteDirectoryRequest.setDeleteRecursive(true);
            DeleteDirectoryResult deleteDirectoryResult = ossClient.deleteDirectory(deleteDirectoryRequest);

            // Lihat hasil penghapusan.
            // Maksimal 100 direktori dan objek dapat dihapus sekaligus. Jika penghapusan belum lengkap, server mengembalikan `nextDeleteToken`. Gunakan token ini untuk melanjutkan penghapusan item yang tersisa.
            // Parameter nextDeleteToken menentukan titik awal untuk penghapusan berikutnya.
            String nextDeleteToken = deleteDirectoryResult.getNextDeleteToken();
            System.out.println("token hapus berikutnya:" + nextDeleteToken);
            // Jalur mutlak direktori yang dihapus.
            System.out.println("nama direktori yang dihapus :" + deleteDirectoryResult.getDirectoryName());
            // Jumlah total objek dan direktori yang dihapus dalam operasi ini.
            System.out.println("jumlah yang dihapus:" + deleteDirectoryResult.getDeleteNumber());


            // Metode 2: Hapus direktori dan semua objek di dalamnya dengan mengiterasi hasil yang dikembalikan oleh operasi listObjects.
            String nextMarker = null;
            ObjectListing objectListing = null;
            do {
                ListObjectsRequest listObjectsRequest = new ListObjectsRequest(bucketName)
                        .withPrefix(prefix)
                        .withMarker(nextMarker);

                objectListing = ossClient.listObjects(listObjectsRequest);
                if (objectListing.getObjectSummaries().size() > 0) {
                    List<String> keys = new ArrayList<String>();
                    for (OSSObjectSummary s : objectListing.getObjectSummaries()) {
                        System.out.println("nama kunci: " + s.getKey());
                        keys.add(s.getKey());
                    }
                    DeleteObjectsRequest deleteObjectsRequest = new DeleteObjectsRequest(bucketName).withKeys(keys).withEncodingType("url");
                    DeleteObjectsResult deleteObjectsResult = ossClient.deleteObjects(deleteObjectsRequest);
                    List<String> deletedObjects = deleteObjectsResult.getDeletedObjects();
                    try {
                        for(String obj : deletedObjects) {
                            String deleteObj =  URLDecoder.decode(obj, "UTF-8");
                            System.out.println(deleteObj);
                        }
                    } catch (UnsupportedEncodingException e) {
                        e.printStackTrace();
                    }
                }

                nextMarker = objectListing.getNextMarker();
            } while (objectListing.isTruncated());
        } catch (OSSException oe) {
            System.out.println("Terjadi OSSException, artinya permintaan Anda sampai ke OSS, "
                    + "tetapi ditolak dengan respons error karena suatu alasan.");
            System.out.println("Pesan Error:" + oe.getErrorMessage());
            System.out.println("Kode Error:" + oe.getErrorCode());
            System.out.println("ID Permintaan:" + oe.getRequestId());
            System.out.println("Host ID:" + oe.getHostId());
        } catch (ClientException ce) {
            System.out.println("Terjadi ClientException, artinya klien mengalami "
                    + "masalah internal serius saat mencoba berkomunikasi dengan OSS, "
                    + "seperti tidak dapat mengakses jaringan.");
            System.out.println("Pesan Error:" + ce.getMessage());
        } finally {
            if (ossClient != null) {
                ossClient.shutdown();
            }
        }
    }
}

<?php
if (is_file(__DIR__ . '/../autoload.php')) {
   require_once __DIR__ . '/../autoload.php';
}
if (is_file(__DIR__ . '/../vendor/autoload.php')) {
   require_once __DIR__ . '/../vendor/autoload.php';
}

use OSS\OssClient;
use OSS\Core\OssException;
// Contoh ini memuat kredensial akses dari variabel lingkungan. Sebelum menjalankan, pastikan `OSS_ACCESS_KEY_ID` dan `OSS_ACCESS_KEY_SECRET` telah diatur.
$accessKeyId = getenv("OSS_ACCESS_KEY_ID");
$accessKeySecret = getenv("OSS_ACCESS_KEY_SECRET");
// Tentukan endpoint untuk wilayah bucket Anda. Misalnya, untuk wilayah China (Hangzhou), tetapkan endpoint ke https://oss-cn-hangzhou.aliyuncs.com.
$endpoint = "your-endpoint";
// Tentukan nama bucket.
$bucket = "examplebucket";

try {
   $ossClient = new OssClient($accessKeyId, $accessKeySecret, $endpoint, false);
   $option = array(
      OssClient::OSS_MARKER => null,
      // Tentukan jalur lengkap direktori yang akan dihapus. Jalur tidak boleh mengandung nama bucket.
      OssClient::OSS_PREFIX => "log/",
      OssClient::OSS_DELIMITER=>'',
   );
   $bool = true;
   while ($bool){
      $result = $ossClient->listObjects($bucket,$option);
      $objects = array();
      if(count($result->getObjectList()) > 0){
         foreach ($result->getObjectList() as $key => $info){
            printf("nama kunci:".$info->getKey().PHP_EOL);
            $objects[] = $info->getKey();
         }
         // Hapus direktori dan semua objek di dalamnya.
         $delObjects = $ossClient->deleteObjects($bucket, $objects);
         foreach ($delObjects as $info){
            $obj = strval($info);
            printf("Hapus ".$obj." : Berhasil" . PHP_EOL);
         }
      }

      if($result->getIsTruncated() === 'true'){
         $option[OssClient::OSS_MARKER] = $result->getNextMarker();
      }else{
         $bool = false;
      }
   }
   printf("Hapus Objek : BERHASIL" . PHP_EOL);
} catch (OssException $e) {
   printf("Hapus Objek : GAGAL" . PHP_EOL);
   printf($e->getMessage() . PHP_EOL);
   return;
}

const OSS = require('ali-oss');

const client = new OSS({
  // Tentukan wilayah tempat bucket Anda berada. Misalnya, untuk wilayah China (Hangzhou), tetapkan region ke oss-cn-hangzhou.
  region: 'yourregion',
  // Contoh ini memuat kredensial akses dari variabel lingkungan. Sebelum menjalankan, pastikan `OSS_ACCESS_KEY_ID` dan `OSS_ACCESS_KEY_SECRET` telah diatur.
  accessKeyId: process.env.OSS_ACCESS_KEY_ID,
  accessKeySecret: process.env.OSS_ACCESS_KEY_SECRET,
  // Tentukan nama bucket.
  bucket: 'yourbucketname'
});

// Tangani permintaan yang gagal untuk mencegah `promise.all` terganggu. Mengembalikan alasan kegagalan dan nama objek yang gagal dihapus.
async function handleDel(name, options) {
  try {
    await client.delete(name);
  } catch (error) {
    error.failObjectName = name;
    return error;
  }
}

// Hapus beberapa objek.
async function deletePrefix(prefix) {
  const list = await client.list({
    prefix: prefix,
  });

  list.objects = list.objects || [];
  const result = await Promise.all(list.objects.map((v) => handleDel(v.name)));
  console.log(result);
}
// Hapus direktori dan semua objek di dalamnya.
deletePrefix('log/')

# -*- coding: utf-8 -*-
import oss2
from oss2.credentials import EnvironmentVariableCredentialsProvider

# Contoh ini memuat kredensial akses dari variabel lingkungan. Sebelum menjalankan, pastikan `OSS_ACCESS_KEY_ID` dan `OSS_ACCESS_KEY_SECRET` telah diatur.
auth = oss2.ProviderAuth(EnvironmentVariableCredentialsProvider())
# Tetapkan endpoint Anda ke endpoint wilayah tempat bucket Anda berada. Misalnya, untuk wilayah China (Hangzhou), tetapkan endpoint ke https://oss-cn-hangzhou.aliyuncs.com.
# Tentukan nama bucket.
bucket = oss2.Bucket(auth, 'https://oss-cn-hangzhou.aliyuncs.com', 'examplebucket')
prefix = "exampledir/"

# Hapus direktori dan semua objek di dalamnya.
for obj in oss2.ObjectIterator(bucket, prefix=prefix):
    bucket.delete_object(obj.key)

package main

import (
    "fmt"
    "os"

    "github.com/aliyun/aliyun-oss-go-sdk/oss"
)

func main() {
    // Contoh ini memuat kredensial akses dari variabel lingkungan. Sebelum menjalankan, pastikan `OSS_ACCESS_KEY_ID` dan `OSS_ACCESS_KEY_SECRET` telah diatur.
    provider, err := oss.NewEnvironmentVariableCredentialsProvider()
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }

    // Buat instance OSSClient.
    // Tentukan endpoint untuk wilayah tempat bucket Anda berada. Misalnya, endpoint untuk wilayah China (Hangzhou) adalah `https://oss-cn-hangzhou.aliyuncs.com`. Ganti ini dengan endpoint untuk wilayah Anda yang sebenarnya.
    client, err := oss.New("your-endpoint", "", "", oss.SetCredentialsProvider(&provider))
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }

    // Tentukan nama bucket.
    bucket, err := client.Bucket("examplebucket")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    
    marker := oss.Marker("")
    // Tentukan jalur lengkap direktori yang akan dihapus. Jalur tidak boleh mengandung nama bucket.
    prefix := oss.Prefix("log/")
    count := 0
    for {
        lor, err := bucket.ListObjects(marker, prefix)
        if err != nil {
            fmt.Println("Error:", err)
            os.Exit(-1)
        }

        objects := []string{}
        for _, object := range lor.Objects {
            objects = append(objects, object.Key)
        }
        // Hapus direktori dan semua objek di dalamnya.
        // Atur `oss.DeleteObjectsQuiet` ke `true` untuk menekan hasil penghapusan.
        delRes, err := bucket.DeleteObjects(objects, oss.DeleteObjectsQuiet(true))
        if err != nil {
            fmt.Println("Error:", err)
            os.Exit(-1)
        }

        if len(delRes.DeletedObjects) > 0 {
            fmt.Println("Objek-objek berikut gagal dihapus:", delRes.DeletedObjects)
            os.Exit(-1)
        }

        count += len(objects)

        prefix = oss.Prefix(lor.Prefix)
        marker = oss.Marker(lor.NextMarker)
        if !lor.IsTruncated {
            break
        }
    }
    fmt.Printf("berhasil,total jumlah objek yang dihapus:%d\n", count)
}

#include <alibabacloud/oss/OssClient.h>
using namespace AlibabaCloud::OSS;

int main(void)
{
    /* Inisialisasi informasi akun OSS. */
            
    /* Tentukan endpoint untuk wilayah tempat bucket Anda berada. Misalnya, untuk wilayah China (Hangzhou), tetapkan endpoint ke https://oss-cn-hangzhou.aliyuncs.com. */
    std::string Endpoint = "your-endpoint";
    /* Tentukan nama bucket. */
    std::string BucketName = "examplebucket";
    /* Tentukan jalur lengkap direktori yang akan dihapus. Jalur tidak boleh mengandung nama bucket. */
    std::string keyPrefix = "log/";

    /* Inisialisasi resource, seperti jaringan. */
    InitializeSdk();

    ClientConfiguration conf;
    /* Contoh ini memuat kredensial akses dari variabel lingkungan. Sebelum menjalankan, pastikan `OSS_ACCESS_KEY_ID` dan `OSS_ACCESS_KEY_SECRET` telah diatur. */
    auto credentialsProvider = std::make_shared<EnvironmentVariableCredentialsProvider>();
    OssClient client(Endpoint, credentialsProvider, conf);

    std::string nextMarker = "";
    bool isTruncated = false;
    do {            
            ListObjectsRequest request(BucketName);            
            request.setPrefix(keyPrefix);
            request.setMarker(nextMarker);
            auto outcome = client.ListObjects(request);

            if (!outcome.isSuccess()) {
                /* Tangani pengecualian. */
                std::cout << "ListObjects gagal" <<
                ",kode:" << outcome.error().Code() <<
                ",pesan:" << outcome.error().Message() <<
                ",requestId:" << outcome.error().RequestId() << std::endl;
                break;
            }
            for (const auto& object : outcome.result().ObjectSummarys()) {
                DeleteObjectRequest request(BucketName, object.Key());
                /* Hapus direktori dan semua objek di dalamnya. */
                auto delResult = client.DeleteObject(request);
            }
            nextMarker = outcome.result().NextMarker();
            isTruncated = outcome.result().IsTruncated();
    } while (isTruncated);

    /* Lepaskan resource, seperti jaringan. */
    ShutdownSdk();
    return 0;
}