لغو بارگذاری چندبخشی آبجکت داخل صندوقچه (Abort Multi-part Upload)
اگر بارگذاری چند بخشی ناموفق بوده و یا از ادامهی بارگذاری بخشها منصرف شدید حتمن باید فرآیند بارگذاری را لغو کنید تا فضای ذخیرهشده برای این بارگذاری در صندوقچهی شما آزاد شود.
بارگذاری که به اتمام رسیده و فایل نهایی از بخش های مجدد ساخته شده دیگر نیازی به متوقف کردن فرآیند ندارد و فرآیند متوقف کردن فقط برای بارگذاریهایی است که شروع شده ولی به اتمام نرسیدهاند.
اگر هنوز فایل در حال بارگذاری دارید، باید بارگذاری آنها تمام شود و سپس بارگذاری را لغو کنید.
مولفهها
- کلیدهای احراز هویت
- نام صندوقچه
- نام آبجکت
نام آبجکت (Key)
نام آبجکت پس از بارگذاری داخل صندوقچه
نمونه کد لغو بارگذاری چند بخشی فایل
زمان آغاز بارگذاری چند بخشی یک کلید UploadId در جواب به کلاینت داده میشود. اگر این کلید را ندارید میتوانید به کمک کد زیر ابتدا لیست بارگذاریهای چند بخشی را دریافت و سپس بارگذاری مورد نظر که به اتمام نرسیده است را لغو کنید.
- NET.
- PHP
- Python
- Javascript
- GO
using Amazon;
using Amazon.S3;
using Amazon.S3.Model;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Reflection;
using System.Collections;
using Newtonsoft.Json;
namespace ListMultipartUploadExample
{
class ListMultipartUpload
{
private const string bucketName = "<BUCKET_NAME>";
private static IAmazonS3 _s3Client;
public static void Main()
{
var awsCredentials = new Amazon.Runtime.BasicAWSCredentials("<ACCESS-KEY>", "<SECRET-KEY>");
var config = new AmazonS3Config { ServiceURL = "<ENDPOINT>" };
_s3Client = new AmazonS3Client(awsCredentials, config);
ListMultipartUploadAsync().Wait();
}
private static async Task ListMultipartUploadAsync()
{
try
{
ListMultipartUploadsRequest request = new()
{
BucketName = bucketName,
};
ListMultipartUploadsResponse response = await _s3Client.ListMultipartUploadsAsync(request);
Console.WriteLine(JsonConvert.SerializeObject(response, Formatting.Indented));
}
catch (AmazonS3Exception amazonS3Exception)
{
Console.WriteLine("An AmazonS3Exception was thrown. Exception: " + amazonS3Exception.ToString());
}
catch (Exception e)
{
Console.WriteLine("Exception: " + e.ToString());
}
}
}
}
اگر در خروجی کد بالا مقادیر بارگذاری چند بخشی پرینت شد میتوانید به کمک نمونه کد زیر بارگذاری(ها) را لغو کنید:
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX - License - Identifier: Apache - 2.0
namespace AbortMultipartUploadExample
{
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Amazon;
using Amazon.S3;
using Amazon.S3.Model;
using System.Reflection;
/// <summary>
/// This example shows how to configure your bucket to allow aborting
/// multipart upload. This example was
/// created using the AWS SDK for .NET 3.7 and .NET Core 5.0.
/// </summary>
public class AbortMultipartUpload
{
// Remember to change the bucket name to the name of an Amazon Simple
// Storage Service (Amazon S3) bucket that exists on your account.
private const string BucketName = "<BUCKET_NAME>";
private const string OBJECT_NAME = "<OBJECT_NAME>";
/// <summary>
/// The Main method creates the the bucket to be able to abort multipart
/// uploads.
/// </summary>
public static async Task Main()
{
var awsCredentials = new Amazon.Runtime.BasicAWSCredentials("<ACCESS-KEY>", "<SECRET-KEY>");
var config = new AmazonS3Config { ServiceURL = "<ENDPOINT>" };
var _s3Client = new AmazonS3Client(awsCredentials, config);
await AbortMultipartUploadAsync(_s3Client);
}
/// <summary>
///
/// </summary>
/// <param name="client"></param>
/// <returns></returns>
private static async Task AbortMultipartUploadAsync(AmazonS3Client client)
{
try
{
var uploadId = "<UPLOAD-ID>";
AbortMultipartUploadRequest request = new()
{
BucketName = BucketName,
Key = OBJECT_NAME,
UploadId = uploadId
};
AbortMultipartUploadResponse response = await client.AbortMultipartUploadAsync(request);
Console.WriteLine($"Multipart upload with ID {uploadId} aborted");
}
catch (AmazonS3Exception amazonS3Exception)
{
Console.WriteLine("An AmazonS3Exception was thrown. Exception: " + amazonS3Exception.ToString());
}
catch (Exception e)
{
Console.WriteLine("Exception: " + e.ToString());
}
}
}
}
require('client.php');
$result = $client->listMultipartUploads([
'Bucket' => 'Your_Bucket_Name',
])
if $result['Uploads'] {
foreach ($result['Uploads'] as $upload) {
echo "Key: {$upload['Key']}, UploadId: {$upload['UploadId']}"
}
}
اگر در خروجی کد بالا مقادیر بارگذاری چند بخشی پرینت شد میتوانید به کمک نمونه کد زیر بارگذاری(ها) را لغو کنید:
require('client.php');
$client->abortMultipartUpload([
'Bucket' => 'Your_Bucket_Name',
'Key' => 'Key_In_Previous_Code_Example',
'UploadId' => 'UploadId_In_previous_Code_Example',
])
import logging
import boto3
# Configure logging
logging.basicConfig(level=logging.INFO)
# S3 client instance
s3_client = boto3.client(
's3',
endpoint_url='endpoint_url',
aws_access_key_id='access_key',
aws_secret_access_key='secret_key]
)
multiple_uploads_list = s3_client.list_multipart_uploads(Bucket='Your_Bucket_name')
uploads = multiple_uploads_list.get('Uploads')
if not uploads:
# there is no multiple upload inprogress
logging.info('no un-finished multiple uploads found')
return
# prints out each unfinished mulipart upload
for upload in uploads:
logging.info(f'UploadId: {upload['UploadId']}, Key: {upload['Key']}')
اگر در خروجی کد بالا مقادیر بارگذاری چند بخشی پرینت شد میتوانید به کمک نمونه کد زیر بارگذاری(ها) را لغو کنید:
import logging
import boto3
# Configure logging
logging.basicConfig(level=logging.INFO)
# S3 client instance
s3_client = boto3.client(
's3',
endpoint_url='endpoint_url',
aws_access_key_id='access_key',
aws_secret_access_key='secret_key]
)
s3_client.abort_multipart_upload(
Bucket='Your_Bucket_Name',
Key='Key_In_Previous_Code_Example',
UploadId='UploadId_In_previous_Code_Example'
)
const { S3Client } = require('@aws-sdk/client-s3');
// Create an S3 client service object
const s3 = new S3Client({
region: 'default',
endpoint: 'endpoint_url',
credentials: {
accessKeyId: 'access_key',
secretAccessKey: 'secret_key',
},
});
const params = {
Bucket: "Your_Bucket_name"
};
s3.listMultipartUploads(params, function(err, data) {
if (err) {
console.log(err, err.stack); // an error occurred
} else {
uploads = data['Uploads']
if Array.isArray(uploads) {
uploads.forEach(upload => {
console.log(`Key: ${upload['Key']}, UploadId: ${upload['UploadId']}`)
});
} else {
console.log('no inprogress multipart upload');
}
}
})
اگر در خروجی کد بالا مقادیر بارگذاری چند بخشی پرینت شد میتوانید به کمک نمونه کد زیر بارگذاری(ها) را لغو کنید:
const { S3Client } = require('@aws-sdk/client-s3');
// Create an S3 client service object
const s3 = new S3Client({
region: 'default',
endpoint: 'endpoint_url',
credentials: {
accessKeyId: 'access_key',
secretAccessKey: 'secret_key',
},
});
const params = {
Bucket: "Your_Bucket_Name",
Key: "Key_In_Previous_Code_Example",
UploadId: "UploadId_In_previous_Code_Example"
};
s3.abortMultipartUpload(params, function(err, data) {
if (err) {
console.log(err, err.stack); // an error occurred
} else {
console.log('successful response');
}
});
package main
import (
"bytes"
"fmt"
"net/http"
"os"
"github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/aws/awserr"
"github.com/aws/aws-sdk-go/aws/credentials"
"github.com/aws/aws-sdk-go/aws/session"
"github.com/aws/aws-sdk-go/service/s3"
)
const (
awsAccessKeyID = "<ACCESS_KEY>"
awsSecretAccessKey = "<SECRET_KEY>"
awsBucketRegion = "default"
awsBucketEndpoint = "<ENDPOINT_URL>"
awsBucketName = "<BUCKET_NAME>"
)
func main() {
creds := credentials.NewStaticCredentials(awsAccessKeyID, awsSecretAccessKey, "")
_, err := creds.Get()
if err != nil {
fmt.Printf("bad credentials: %s \n", err)
}
cfg := aws.NewConfig().WithRegion(awsBucketRegion).WithCredentials(creds).WithEndpoint(awsBucketEndpoint)
svc := s3.New(session.New(), cfg)
multipartOutput, err := svc.ListMultipartUploads(&s3.ListMultipartUploadsInput{
Bucket: &awsBucketName,
})
if err != nil {
fmt.Printf("error getting list of multipart uploads: %s \n", err)
}
if multipartOutput.Uploads != nil {
for _, upload := range multipartOutput.Uploads {
fmt.Printf("Key: %s, UploadId: %s", upload.Key, upload.UploadId)
}
}
}
اگر در خروجی کد بالا مقادیر بارگذاری چند بخشی پرینت شد میتوانید به کمک نمونه کد زیر بارگذاری(ها) را لغو کنید:
const { S3Client } = require('@aws-sdk/client-s3');
// Create an S3 client service object
const s3 = new S3Client({
region: 'default',
endpoint: 'endpoint_url',
credentials: {
accessKeyId: 'access_key',
secretAccessKey: 'secret_key',
},
});
const params = {
Bucket: "Your_Bucket_Name",
Key: "Key_In_Previous_Code_Example",
UploadId: "UploadId_In_previous_Code_Example"
};
s3.abortMultipartUpload(params, function(err, data) {
if (err) {
console.log(err, err.stack); // an error occurred
} else {
console.log('successful response');
}
});