Heim > Artikel > Backend-Entwicklung > Einsteigerhandbuch zum Verwalten von Dateien in Amazon Sith Go
Amazon Simple Storage Service (S3) ist zum Industriestandard für webbasierte Dateispeicherung geworden. Es ist auf eine Haltbarkeit und Sicherheit von bis zu 99,999999999 % ausgelegt. Es verfügt außerdem über flexible Speicherklassen, Datenverwaltung und Analysefunktionen.
Erstellen Sie die serverseitige App für Ihr Projekt in Go und benötigen eine Speicheroption? In diesem Artikel wird davon ausgegangen, dass Sie ein AWS-Anfänger sind, und er führt Sie durch die Prozesse zur Verwendung von S3 für die Speicherung Ihrer Go-Apps.
Das Einrichten eines AWS S3-Buckets mit den richtigen Berechtigungen und Parametern kann entmutigend sein. Sie müssen einen Bucket erstellen, einen IAM-Benutzer erstellen, dem IAM-Benutzer Berechtigungen zum Ausführen von Vorgängen auf dem Bucket erteilen und die Zugriffsschlüssel in Ihrer Umgebung einrichten.
Erstellen Sie zunächst ein Amazon AWS-Konto und melden Sie sich an, falls Sie noch keins haben. Suchen Sie dann wie folgt nach S3.
Klicken Sie nun auf „Bucket erstellen“. Sie werden aufgefordert, den Bucket gemäß den Spezifikationen Ihres Projekts zu konfigurieren.
Da Sie nun einen Bucket erstellt haben, besteht der nächste Schritt darin, einen IAM-Benutzer einzurichten, dem Sie die Berechtigung zum Zugriff auf den S3-Bucket erteilen.
Gehen Sie zum Abschnitt „Sicherheitsanmeldeinformationen“ Ihres Profils und erstellen Sie einen Benutzer.
Erstellen Sie dann einen Zugriffsschlüssel für den Benutzer und rufen Sie die Zugriffs- und Geheimschlüssel ab.
Erstellen Sie auf Ihrem Computer im Stammverzeichnis einen .aws-Ordner und eine Datei mit dem Namen credentials ohne Erweiterung; Fügen Sie dann die Schlüssel wie folgt hinzu:
[default] aws_access_key_id = <aws_access_key_id here> aws_secret_access_key = <aws_secret_access_key here>
Erteilen Sie dem Benutzer nun diese Berechtigungen, um S3-Uploads zuzulassen.
Zuletzt initialisieren Sie ein Go-Projekt und installieren das AWS Go SDK.
go mod tidy go get github.com/aws/aws-sdk-go
Sie sind nun fertig und können jetzt mit dem Hochladen, Herunterladen und Verwalten von Dateien mit AWS S3 Buckets beginnen.
Zuerst müssen Sie die erforderlichen Pakete aus dem AWS SDK-Paket importieren.
Fügen Sie diese Module oben in Ihrer main.go-Datei oder der von Ihnen verwendeten Datei hinzu:
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" )
Um eine Datei hochzuladen, müssen Sie eine neue Sitzung erstellen, eine Datei öffnen und die Sitzungsinstanz zum Hochladen der Datei verwenden.
[default] aws_access_key_id = <aws_access_key_id here> aws_secret_access_key = <aws_secret_access_key here>
Die UploadFile-Funktion übernimmt den Bucket-Namen, die AWS-Region, den Dateischlüssel und die ACL (Zugriffskontrollliste) und lädt die angegebene Datei mit dem angegebenen Schlüssel auf S3 hoch.
Die Funktion session.NewSession erstellt eine neue AWS-Sitzung und s3.New erstellt eine neue S3-Sitzung. Die PutObject-Funktion nimmt einen Verweis auf den PutObjectInput mit dem Datei-Bucket, dem Schlüssel, dem Dateitext und der ACL auf.
go mod tidy go get github.com/aws/aws-sdk-go
Als ich die UploadFile-Funktion mit den Parametern aufgerufen habe, ist hier der Beweis, dass die Datei in meinen S3-Bucket hochgeladen wurde.
Sie können jederzeit weitere Details zu Dateien durchsuchen, indem Sie in der AWS S3-Konsole auf den Dateinamen klicken.
Jetzt können Sie versuchen, die Datei mit dem von Ihnen angegebenen Schlüssel abzurufen.
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" )
Nach dem Erstellen der Client-Instanz empfängt die GetObject-Funktion die Dateiparameter in der &s3.GetObjectInput-Instanz. Sie können den Dateistream jetzt mit der Funktion io.Copy an Ihr bevorzugtes Ziel kopieren.
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 }
Die Datei sollte in den von Ihnen angegebenen Zielpfad heruntergeladen werden, wenn Sie ein Programm mit der DownloadFile-Funktion ausführen.
Sie müssen den Schlüssel auch im Zielpfad angeben.
Um eine Datei aus einem S3-Bucket zu löschen, verwenden Sie die Funktion „DeleteObject“ des AWS SDK, um die Datei zu entfernen. Sie müssen den S3-Bucket-Namen und den Dateischlüssel angeben, den Sie löschen möchten.
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) } }
Die Funktion „DeleteFile“ beginnt mit der Erstellung einer Sitzung, wie in den Upload- und Download-Beispielen. Das s3Client.DeleteObject wird mit einer DeleteObjectInput-Struktur aufgerufen, in der Sie die Bucket- und Key-Parameter angeben.
Sie können die Funktion „WaitUntilObjectNotExists“ verwenden, um zu bestätigen, dass die Datei nicht existiert.
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 }
Beim Ausführen der Funktion „DeleteFile“ können Sie sehen, dass das Makefile in meinem S3-Bucket nicht mehr vorhanden ist.
Sie haben gelernt, wie Sie einen S3-Bucket für einen IAM-Benutzer einrichten (funktioniert auch für Root) und Dateien aus S3-Buckets hochladen, herunterladen und löschen.
Mit AWS S3 Buckets können Sie noch viel mehr Funktionen nutzen. Ich hoffe, dass dieser Artikel Ihnen die Grundlage dafür gegeben hat, je nach Anwendungsfall Ihres Projekts weiterzumachen.
Das obige ist der detaillierte Inhalt vonEinsteigerhandbuch zum Verwalten von Dateien in Amazon Sith Go. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!