Amazon Simple Storage Service (S3) 已成為基于 Web 的文件存儲的行業(yè)標準。它的設(shè)計具有高達 99.999999999% 的耐用性和安全性。它還具有靈活的存儲類別、數(shù)據(jù)管理和分析功能。

您是否正在使用 Go 為您的項目構(gòu)建服務(wù)器端應(yīng)用程序并需要存儲選項？本文假設(shè)您是 AWS 初學者，將引導(dǎo)您完成從 Go 應(yīng)用程序使用 S3 進行存儲的過程。

AWS 和 Go 入門

使用正確的權(quán)限和參數(shù)設(shè)置 AWS S3 存儲桶可能會令人望而生畏。您必須創(chuàng)建一個存儲桶，創(chuàng)建一個 IAM 用戶，向 IAM 用戶授予在存儲桶上執(zhí)行操作的權(quán)限，并在您的環(huán)境中設(shè)置訪問密鑰。

首先，創(chuàng)建一個 Amazon AWS 帳戶并登錄（如果您還沒有帳戶）。然后，像這樣搜索S3。

現(xiàn)在，點擊“創(chuàng)建存儲桶”。系統(tǒng)會提示您根據(jù)項目的規(guī)格配置存儲桶。

現(xiàn)在您已經(jīng)創(chuàng)建了存儲桶，下一步是設(shè)置一個 IAM 用戶，您將向該用戶授予訪問 S3 存儲桶的權(quán)限。

前往您的個人資料的安全憑證部分并創(chuàng)建一個用戶。

然后，為用戶創(chuàng)建訪問密鑰并檢索訪問密鑰和秘密密鑰。

在您計算機的根目錄中，創(chuàng)建一個 .aws 文件夾和一個名為credentials（不帶擴展名）的文件；然后像這樣添加鍵：

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

現(xiàn)在，向用戶頒發(fā)這些權(quán)限以允許 S3 上傳。

最后，初始化Go項目并安裝AWS Go SDK。

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

您已完成所有設(shè)置，現(xiàn)在，您可以開始使用 AWS S3 存儲桶上傳、下載和管理文件。

將文件上傳到 S3 存儲桶

首先，您必須從AWS SDK包中導(dǎo)入必要的包。

將這些模塊添加到 main.go 文件或您正在使用的任何文件的頂部：

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"
)

要上傳文件，您必須創(chuàng)建一個新會話，打開文件，然后使用會話實例來上傳文件。

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

UploadFile 函數(shù)接收存儲桶名稱、AWS 區(qū)域、文件密鑰和 ACL（訪問控制列表），并使用指定密鑰將指定文件上傳到 S3。

session.NewSession 函數(shù)創(chuàng)建一個新的 AWS 會話，s3.New 創(chuàng)建一個新的 S3 會話。 PutObject 函數(shù)使用文件 Bucket、Key、文件正文和 ACL 接收對 PutObjectInput 的引用。

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

當我使用參數(shù)調(diào)用 UploadFile 函數(shù)時，這是文件已上傳到我的 S3 存儲桶的證據(jù)。

您隨時可以通過在 AWS S3 控制臺上單擊文件名來瀏覽文件的更多詳細信息。

從 S3 存儲桶下載文件

現(xiàn)在，您可以嘗試使用指定的密鑰檢索文件。

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"
)

創(chuàng)建客戶端實例后，GetObject函數(shù)接收&s3.GetObjectInput實例中的文件參數(shù)。您現(xiàn)在可以使用 io.Copy 函數(shù)將文件流復(fù)制到您的首選目的地。

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
}

使用 DownloadFile 函數(shù)執(zhí)行程序時，應(yīng)將文件下載到您指定的目標路徑。

您還需要在目標路徑中的密鑰中指定密鑰。

從 S3 存儲桶中刪除文件

要從 S3 存儲桶中刪除文件，您將使用 AWS 開發(fā)工具包的 DeleteObject 函數(shù)來刪除該文件。您必須指定 S3 存儲桶名稱和要刪除的文件密鑰。

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)
    }
}

DeleteFile 函數(shù)首先創(chuàng)建一個會話，就像上傳和下載示例中一樣。 s3Client.DeleteObject 使用 DeleteObjectInput 結(jié)構(gòu)進行調(diào)用，您將在其中指定 Bucket 和 Key 參數(shù)。

您可以使用WaitUntilObjectNotExists函數(shù)來確認該文件不存在。

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
}

執(zhí)行DeleteFile函數(shù)時，可以看到我的S3存儲桶中不再存在Makefile。

結(jié)論

您已了解如何為 IAM 用戶設(shè)置 S3 存儲桶（也適用于 root 用戶）以及如何從 S3 存儲桶上傳、下載和刪除文件。

您可以使用 AWS S3 存儲桶執(zhí)行更多功能。我希望這篇文章能為您提供進一步的基礎(chǔ)，具體取決于您的項目的用例。

以上是在 Amazon Sith Go 中管理文件的初學者指南的詳細內(nèi)容。更多信息請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！