Amazon Simple Storage Service (S3) 已成為基於 Web 的檔案儲存的業(yè)界標準。它的設計具有高達 99.999999999% 的耐用性和安全性。它還具有靈活的儲存類別、資料管理和分析功能。

您是否正在使用 Go 為您的專案建立伺服器端應用程式並需要儲存選項？本文假設您是 AWS 初學者，將引導您完成從 Go 應用程式使用 S3 進行儲存的過程。

AWS 和 Go 入門

使用正確的權限和參數(shù)設定 AWS S3 儲存桶可能會令人望而生畏。您必須建立一個儲存桶，建立一個 IAM 用戶，向 IAM 用戶授予在儲存桶上執(zhí)行操作的權限，並在您的環(huán)境中設定存取金鑰。

首先，建立一個 Amazon AWS 帳戶並登入（如果您還沒有帳戶）。然後，像這樣搜尋S3。

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

現(xiàn)在您已經(jīng)建立了儲存桶，下一步是設定一個 IAM 用戶，您將向該用戶授予存取 S3 儲存桶的權限。

前往您的個人資料的安全憑證部分並建立一個使用者。

然後，為使用者建立存取金鑰並檢索存取金鑰和秘密金鑰。

在您電腦的根目錄中，建立一個 .aws 資料夾和一個名為credentials（不含副檔名）的檔案；然後像這樣新增鍵：

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

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

最後，初始化Go專案並安裝AWS Go SDK。

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

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

將檔案上傳到 S3 儲存桶

首先，您必須從AWS SDK套件中匯入必要的套件。

將這些模組新增至 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"
)

要上傳文件，您必須建立一個新會話，開啟文件，然後使用會話實例來上傳文件。

[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ù)會建立一個新的 AWS 會話，s3.New 會建立一個新的 S3 會話。 PutObject 函數(shù)使用檔案 Bucket、Key、檔案正文和 ACL 接收對 PutObjectInput 的引用。

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

當我使用參數(shù)呼叫 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"
)

建立客戶端實例後，GetObject函數(shù)接收&s3.GetObjectInput實例中的檔案參數(shù)。現(xiàn)在您可以使用 io.Copy 函數(shù)將檔案流複製到您的首選目的地。

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í)行程式時，應將檔案下載到您指定的目標路徑。

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

從 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ù)首先建立一個會話，就像上傳和下載範例一樣。 s3Client.DeleteObject 使用 DeleteObjectInput 結構進行調用，您將在其中指定 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。

結論

您已了解如何為 IAM 使用者設定 S3 儲存桶（也適用於 root 使用者）以及如何從 S3 儲存桶上傳、下載和刪除檔案。

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

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