Управление метаданными объектов

1
aws s3api put-object \
2
 --bucket <имя бакета> \
3
 --key <ключ объекта> \
4
 --body <путь к локальному файлу \
5
 --metadata "<ключ 1>"="<значение 1>","<ключ 2>"="<значение 2>"

1
import boto3
2
from botocore.exceptions import ClientError
3

4
session = boto3.session.Session(profile_name='default')
5
s3 = session.client(
6
   service_name='s3',
7
   endpoint_url='https://storage.mwsapis.ru/'
8
)
9

10
FILE_NAME = 'file.txt'
11
BUCKET_NAME = 'bucket'
12
OBJECT_NAME = 'file.txt'
13

14
try:
15
    with open(FILE_NAME, 'rb') as file_data:
16
        metadata = {
17
            'Metadata': {
18
                'x-amz-meta-key1': 'value1',
19
                'x-am-meta-key2': 'value2'
20
            }
21
        }
22
        s3.upload_fileobj(
23
            file_data,
24
            BUCKET_NAME,
25
            OBJECT_NAME,
26
            ExtraArgs=metadata
27
        )
28
    print(f'File {FILE_NAME} uploaded to {BUCKET_NAME}/{OBJECT_NAME} with metadata')
29
except ClientError as e:
30
    print(f'Error uploading file: {e}'

1
import (
2
    "context"
3
    "fmt"
4
    "log"
5
    "os"
6
    "path/filepath"
7

8
    "github.com/aws/aws-sdk-go-v2/aws"
9
    "github.com/aws/aws-sdk-go-v2/config"
10
    "github.com/aws/aws-sdk-go-v2/service/s3"
11
)
12

13
func main() {
14
    var (
15
        bucketName = "bucket"
16
        filePath   = "file.txt"
17
    )
18

19
    // Подгружаем конфигурацию из ~/.aws/*
20
    cfg, err := config.LoadDefaultConfig(context.TODO())
21
    if err != nil {
22
        log.Fatal(err)
23
    }
24

25
    // Создаем клиент для доступа к хранилищу S3
26
    client := s3.NewFromConfig(cfg)
27

28
    file, err := os.Open(filePath)
29
    if err != nil {
30
        log.Fatalf("Unable to open file %q, %v", filePath, err)
31
    }
32
    defer file.Close()
33

34
    // Создаем метаданные для объекта
35
    metadata := map[string]string{
36
        "x-amz-meta-key1": "value1",
37
        "x-amz-meta-key2": "value2",
38
    }
39

40
    uploadInput := &s3.PutObjectInput{
41
        Bucket:   aws.String(bucketName),
42
        Key:      aws.String(filepath.Base(filePath)), // Имя файла в S3
43
        Body:     file,
44
        Metadata: metadata, // Добавляем метаданные
45
    }
46

47
    _, err = client.PutObject(context.TODO(), uploadInput)
48
    if err != nil {
49
        log.Fatalf("Unable to upload %q to %q, %v", filePath, bucketName, err)
50
    }
51

52
    fmt.Printf("Successfully uploaded %q to %q with metadata\n", filePath, bucketName)
53
}

1
aws s3api head-object \
2
  --bucket <имя_бакета> \
3
  --key <ключ_объекта> \

1
{
2
    "AcceptRanges": "bytes",
3
    "LastModified": "2024-12-02T09:01:52+00:00",
4
    "ContentLength": 143,
5
    "ETag": "\"2b605dba83a2be027b3ebcee1033b950\"",
6
    "ServerSideEncryption": "AES256",
7
    "Metadata": {
8
        "x-am-meta-key2": "value2",
9
        "x-amz-meta-key1": "value1"
10
    }
11
}

1
mport boto3
2

3

4
s3 = boto3.client('s3')
5

6

7
bucket_name = 'bucket'
8
object_key = 'file.txt'
9

10

11
response = s3.head_object(Bucket=bucket_name, Key=object_key)
12

13
print('Metadata:')
14
for key, value in response['Metadata'].items():
15
    print(f'{key}: {value}')

1
package main
2

3
import (
4
    "context"
5
    "fmt"
6
    "log"
7

8
    "github.com/aws/aws-sdk-go-v2/config"
9
    "github.com/aws/aws-sdk-go-v2/service/s3"
10
)
11

12
func main() {
13
    // Подгружаем конфигурацию из ~/.aws/*
14
    cfg, err := config.LoadDefaultConfig(context.TODO())
15
    if err != nil {
16
        log.Fatal(err)
17
    }
18

19
    // Создаем клиент для доступа к Object Storage
20
    client := s3.NewFromConfig(cfg)
21

22
    // Укажите имя бакета и ключ объекта
23
    bucketName := "newbucket"
24
    objectKey := "file.txt"
25

26
    // Получаем метаданные объекта
27
    headOutput, err := client.HeadObject(context.TODO(), &s3.HeadObjectInput{
28
        Bucket: &bucketName,
29
        Key:    &objectKey,
30
    })
31
    if err != nil {
32
        log.Fatalf("Unable to get object metadata for %q in bucket %q, %v", objectKey, bucketName, err)
33
    }
34

35
    // Выводим метаданные
36
    fmt.Println("Metadata:")
37
    for key, values := range headOutput.Metadata {
38
            fmt.Printf("%s: %s\n", key, string(values))
39
        }
40
    }

1
aws s3api copy-object \
2
  --bucket <имя_бакета> \
3
  --key <ключ_объекта> \
4
  --copy-source <имя_бакета>/<ключ_объекта> \
5
  --metadata "<ключ_1>"="<значение_1>","<ключ_2>"="<значение_2>" \
6
  --metadata-directive REPLACE \

1
import boto3
2

3
s3 = boto3.client('s3')
4

5
bucket_name = 'bucket'
6
object_key = 'file.txt'
7

8
# Получаем текущие метаданные
9
response = s3.head_object(Bucket=bucket_name, Key=object_key)
10
current_metadata = response.get('Metadata', {})
11

12
# Создаем новые метаданные
13
new_metadata = {
14
    'key1': 'value1',
15
    'key2': 'value2'
16
    #
17
}
18

19
# Делаем копию объекта: с таким же именем, но с новыми метаданными
20
s3.copy_object(
21
    Bucket=bucket_name,
22
    CopySource={'Bucket': bucket_name, 'Key': object_key},
23
    Key=object_key,
24
    Metadata=new_metadata,
25
    MetadataDirective='REPLACE'
26
)
27

28
# Проверяем и выводим обновленные метаданные
29
response = s3.head_object(Bucket=bucket_name, Key=object_key)
30
print('Updated Metadata:')
31
for key, value in response['Metadata'].items():
32
    print(f'{key}: {value}')

1
package main
2

3
import (
4
    "context"
5
    "fmt"
6
    "log"
7

8
    "github.com/aws/aws-sdk-go-v2/config"
9
    "github.com/aws/aws-sdk-go-v2/service/s3"
10
)
11

12
func main() {
13
    // Подгружаем конфигурацию из ~/.aws/*
14
    cfg, err := config.LoadDefaultConfig(context.TODO())
15
    if err != nil {
16
        log.Fatal(err)
17
    }
18

19
    // Создаем клиент для доступа к хранилищу Object Storage
20
    client := s3.NewFromConfig(cfg)
21

22
    // Указываем имя бакета и ключ объекта
23
    bucketName := "newbucket"
24
    objectKey := "file.txt"
25

26
    // Получаем текущие метаданные объекта
27
    headOutput, err := client.HeadObject(context.TODO(), &s3.HeadObjectInput{
28
        Bucket: &bucketName,
29
        Key:    &objectKey,
30
    })
31
    if err != nil {
32
        log.Fatalf("Unable to get object metadata for %q in bucket %q, %v", objectKey, bucketName, err)
33
    }
34

35
    // Выводим текущие метаданные
36
    fmt.Println("Current Metadata:")
37
    for key, value := range headOutput.Metadata {
38
        fmt.Printf("%s: %s\n", key, value)
39
    }
40

41
    // Создаем новые метаданные
42
    newMetadata := map[string]string{
43
        "x-amz-meta-key1": "value7",
44
        "x-amz-meta-key2": "value8",
45
    }
46

47

48
    // Делаем копию объекта с новыми метаданными
49
    copySource := fmt.Sprintf("%s/%s", bucketName, objectKey)
50
    _, err = client.CopyObject(context.TODO(), &s3.CopyObjectInput{
51
        Bucket:            &bucketName,
52
        CopySource:        &copySource,
53
        Key:              &objectKey,
54
        Metadata:         newMetadata,
55
        MetadataDirective: "REPLACE",
56
    })
57

58
    if err != nil {
59
        log.Fatalf("Unable to update object metadata for %q in bucket %q, %v", objectKey, bucketName, err)
60
    }
61

62
    // Проверяем обновленные метаданные
63
    updatedOutput, err := client.HeadObject(context.TODO(), &s3.HeadObjectInput{
64
        Bucket: &bucketName,
65
        Key:    &objectKey,
66
    })
67
    if err != nil {
68
        log.Fatalf("Unable to get updated object metadata for %q in bucket %q, %v", objectKey, bucketName, err)
69
    }
70

71
    fmt.Println("\nUpdated Metadata:")
72
    for key, value := range updatedOutput.Metadata {
73
        fmt.Printf("%s: %s\n", key, value)
74
    }
75
}