Guide du débutant sur la gestion des fichiers dans Amazon Sith Go

Amazon Simple Storage Service (S3) est devenu la norme industrielle en matière de stockage de fichiers sur le Web. Il est conçu pour une durabilité et une sécurité allant jusqu'à 99,999999999 %. Il dispose également de classes de stockage flexibles, de fonctionnalités de gestion des données et d'analyse.

Vous créez l'application côté serveur pour votre projet dans Go et avez besoin d'une option de stockage ? Cet article suppose que vous êtes un débutant AWS et vous guide à travers les processus d'utilisation de S3 pour le stockage à partir de vos applications Go.

Premiers pas avec AWS et Go

Configurer un compartiment AWS S3 avec les autorisations et paramètres appropriés peut être intimidant. Vous devrez créer un bucket, créer un utilisateur IAM, accorder des autorisations à l'utilisateur IAM pour exécuter des opérations sur le bucket et configurer les clés d'accès dans votre environnement.

Tout d’abord, créez un compte Amazon AWS et connectez-vous si vous n’en avez pas encore. Ensuite, recherchez S3 comme ceci.

Maintenant, cliquez sur « Créer un bucket ». Vous serez invité à configurer le bucket en fonction des spécifications de votre projet.

Maintenant que vous avez créé un compartiment, l'étape suivante consiste à configurer un utilisateur IAM à qui vous accorderez l'autorisation d'accéder au compartiment S3.

Accédez à la section des informations d'identification de sécurité de votre profil et créez un utilisateur.

Ensuite, créez une clé d'accès pour l'utilisateur et récupérez les clés d'accès et secrètes.

Sur votre ordinateur, dans le répertoire racine, créez un dossier .aws et un fichier nommé identifiants sans extension ; puis ajoutez les clés comme ceci :

[default]
aws_access_key_id = <aws_access_key_id here>
aws_secret_access_key = <aws_secret_access_key here>

Maintenant, accordez ces autorisations à l'utilisateur pour autoriser les téléchargements S3.

Enfin, initialisez un projet Go et installez le SDK AWS Go.

go mod tidy
go get github.com/aws/aws-sdk-go

Vous êtes tous configurés et vous pouvez maintenant commencer à charger, télécharger et gérer des fichiers avec AWS S3 Buckets.

Téléchargement de fichiers vers un compartiment S3

Tout d'abord, vous devez importer les packages nécessaires à partir du package AWS SDK.

Ajoutez ces modules en haut de votre fichier main.go ou quel que soit le fichier que vous utilisez :

package main

import (
    "bytes"
    "fmt"
    "io"
    "os"

    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/service/s3"
)

Pour télécharger un fichier, vous devez créer une nouvelle session, ouvrir un fichier et utiliser l'instance de session pour télécharger le fichier.

[default]
aws_access_key_id = <aws_access_key_id here>
aws_secret_access_key = <aws_secret_access_key here>

La fonction UploadFile prend le nom du bucket, la région AWS, la clé du fichier et l'ACL (liste de contrôles d'accès) et télécharge le fichier spécifié sur S3 avec la clé spécifiée.

La fonction session.NewSession crée une nouvelle session AWS et s3.New crée une nouvelle session S3. La fonction PutObject prend une référence au PutObjectInput avec le fichier Bucket, la clé, le corps du fichier et l'ACL.

go mod tidy
go get github.com/aws/aws-sdk-go

Lorsque j'ai appelé la fonction UploadFile avec les paramètres, voici la preuve que le fichier a été téléchargé dans mon bucket S3.

Vous pouvez toujours parcourir plus de détails sur les fichiers en cliquant sur le nom du fichier sur la console AWS S3.

Téléchargement de fichiers à partir d'un compartiment S3

Maintenant, vous pouvez tenter de récupérer le fichier avec la clé que vous avez spécifiée.

package main

import (
    "bytes"
    "fmt"
    "io"
    "os"

    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/service/s3"
)

Après avoir créé l'instance client, la fonction GetObject reçoit les paramètres du fichier dans l'instance &s3.GetObjectInput. Vous pouvez maintenant copier le flux de fichiers vers votre destination préférée avec la fonction io.Copy.

func UploadFile(bucket, region, filePath, key, acl string) error {
    sess, err := session.NewSession(&aws.Config{
        Region: aws.String(region),
    })
    if err != nil {
        return fmt.Errorf("error creating session: %w", err)
    }
    file, err := os.Open(filePath)
    if err != nil {
        return fmt.Errorf("error opening file: %w", err)
    }
    defer file.Close()

    var buf bytes.Buffer
    if _, err := io.Copy(&buf, file); err != nil {
        return fmt.Errorf("error reading file: %w", err)
    }

    _, err = s3.New(sess).PutObject(&s3.PutObjectInput{
        Bucket: aws.String(bucket), 
        Key:    aws.String(key),          
        Body:   bytes.NewReader(buf.Bytes()), 
        ACL: aws.String(acl),     
    })
    if err != nil {
        return fmt.Errorf("error uploading file: %w", err)
    }

    fmt.Println("File uploaded successfully:", filePath, "to key:", key)
    return nil
}

Le fichier doit être téléchargé vers le chemin de destination spécifié lors de l'exécution d'un programme avec la fonction DownloadFile.

Vous devrez également spécifier la clé dans la clé du chemin de destination.

Suppression de fichiers des compartiments S3

Pour supprimer un fichier d'un compartiment S3, vous utiliserez la fonction DeleteObject du SDK AWS pour supprimer le fichier. Vous devez spécifier le nom du bucket S3 et la clé du fichier que vous souhaitez supprimer.

func main() {
    bucket := "cloudboxbucket"  
    region := "eu-north-1"      
    filePath := "Makefile"     
    key := "Makefile"           
    acl := "private"         

    if err := UploadFile(bucket, region, filePath, key, acl); err != nil {
        fmt.Println("Error uploading file:", err)
    }
}

La fonction DeleteFile commence par créer une session, comme dans les exemples de téléchargement et de téléchargement. Le s3Client.DeleteObject est appelé avec une structure DeleteObjectInput, où vous spécifierez les paramètres Bucket et Key.

Vous pouvez utiliser la fonction WaitUntilObjectNotExists pour confirmer que le fichier n'existe pas.

func DownloadFile(bucket, region, key, destPath string) error {
    sess, err := session.NewSession(&aws.Config{
        Region: aws.String(region),
    })
    if err != nil {
        return fmt.Errorf("error creating session: %w", err)
    }

    s3Client := s3.New(sess)

    output, err := s3Client.GetObject(&s3.GetObjectInput{
        Bucket: aws.String(bucket),
        Key:    aws.String(key),
    })
    if err != nil {
        return fmt.Errorf("error downloading file: %w", err)
    }
    defer output.Body.Close()

    destFile, err := os.Create(destPath)
    if err != nil {
        return fmt.Errorf("error creating destination file: %w", err)
    }
    defer destFile.Close()

    if _, err := io.Copy(destFile, output.Body); err != nil {
        return fmt.Errorf("error saving file: %w", err)
    }

    fmt.Println("File downloaded successfully:", key, "to", destPath)
    return nil
}

Lors de l'exécution de la fonction DeleteFile, vous pouvez constater que le Makefile n'existe plus dans mon bucket S3.

Conclusion

Vous avez appris à configurer un compartiment S3 pour un utilisateur IAM (cela fonctionne également pour root) et à télécharger et supprimer des fichiers des compartiments S3.

Vous pouvez réaliser bien plus de fonctionnalités avec les compartiments AWS S3. J'espère que cet article vous a fourni les bases pour aller plus loin, en fonction du cas d'utilisation de votre projet.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!