Amazon Simple Storage Service (S3) 已成為基於 Web 的檔案儲(chǔ)存的業(yè)界標(biāo)準(zhǔn)。它的設(shè)計(jì)具有高達(dá) 99.999999999% 的耐用性和安全性。它還具有靈活的儲(chǔ)存類(lèi)別、資料管理和分析功能。

您是否正在使用 Go 為您的專(zhuān)案建立伺服器端應(yīng)用程式並需要儲(chǔ)存選項(xiàng)？本文假設(shè)您是 AWS 初學(xué)者，將引導(dǎo)您完成從 Go 應(yīng)用程式使用 S3 進(jìn)行儲(chǔ)存的過(guò)程。

AWS 和 Go 入門(mén)

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

首先，建立一個(gè) Amazon AWS 帳戶(hù)並登入（如果您還沒(méi)有帳戶(hù)）。然後，像這樣搜尋S3。

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

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

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

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

在您電腦的根目錄中，建立一個(gè) .aws 資料夾和一個(gè)名為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專(zhuān)案並安裝AWS Go SDK。

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

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

將檔案上傳到 S3 儲(chǔ)存桶

首先，您必須從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"
)

要上傳文件，您必須建立一個(gè)新會(huì)話，開(kāi)啟文件，然後使用會(huì)話實(shí)例來(lái)上傳文件。

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

UploadFile 函數(shù)接收儲(chǔ)存桶名稱(chēng)、AWS 區(qū)域、檔案金鑰和 ACL（存取控制清單），並使用指定金鑰將指定檔案上傳至 S3。

session.NewSession 函數(shù)會(huì)建立一個(gè)新的 AWS 會(huì)話，s3.New 會(huì)建立一個(gè)新的 S3 會(huì)話。 PutObject 函數(shù)使用檔案 Bucket、Key、檔案正文和 ACL 接收對(duì) PutObjectInput 的引用。

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

當(dāng)我使用參數(shù)呼叫 UploadFile 函數(shù)時(shí)，這是檔案已上傳到我的 S3 儲(chǔ)存桶的證據(jù)。

您隨時(shí)可以透過(guò)在 AWS S3 控制臺(tái)上按一下檔案名稱(chēng)來(lái)瀏覽檔案的更多詳細(xì)資訊。

從 S3 儲(chǔ)存桶下載文件

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

建立客戶(hù)端實(shí)例後，GetObject函數(shù)接收&s3.GetObjectInput實(shí)例中的檔案參數(shù)?，F(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í)行程式時(shí)，應(yīng)將檔案下載到您指定的目標(biāo)路徑。

您還需要在目標(biāo)路徑中的金鑰中指定金鑰。

從 S3 儲(chǔ)存桶中刪除文件

要從 S3 儲(chǔ)存桶中刪除文件，您將使用 AWS 開(kāi)發(fā)工具包的 DeleteObject 函數(shù)來(lái)刪除該文件。您必須指定 S3 儲(chǔ)存桶名稱(chēng)和要?jiǎng)h除的檔案金鑰。

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ù)首先建立一個(gè)會(huì)話，就像上傳和下載範(fàn)例一樣。 s3Client.DeleteObject 使用 DeleteObjectInput 結(jié)構(gòu)進(jìn)行調(diào)用，您將在其中指定 Bucket 和 Key 參數(shù)。

您可以使用WaitUntilObjectNotExists函數(shù)來(lái)確認(rèn)該檔案不存在。

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ù)時(shí)，可以看到我的S3儲(chǔ)存桶中不再存在Makefile。

結(jié)論

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

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

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