Amazon Simple Storage Service (S3) は、ウェブベースのファイルストレージの業(yè)界標(biāo)準(zhǔn)になっています。最大 99.999999999% の耐久性とセキュリティを?qū)g現(xiàn)するように設(shè)計(jì)されています。また、柔軟なストレージ クラス、データ管理、分析機(jī)能も備えています。

Go でプロジェクトのサーバー側(cè)アプリを構(gòu)築していて、ストレージ オプションが必要ですか?この記事では、あなたが AWS の初心者であることを前提として、Go アプリのストレージとして S3 を使用するプロセスについて説明します。

AWS と Go の入門

適切な権限とパラメータを使用して AWS S3 バケットを設(shè)定するのは、困難な場(chǎng)合があります。バケットを作成し、IAM ユーザーを作成し、バケット上で操作を?qū)g行する権限を IAM ユーザーに発行し、環(huán)境內(nèi)にアクセス キーを設(shè)定する必要があります。

まず、Amazon AWS アカウントを作成し、まだお持ちでない場(chǎng)合はサインインします。次に、このように S3 を検索します。

次に、「バケットの作成」をクリックします。プロジェクトの仕様に従ってバケットを構(gòu)成するように求められます。

バケットを作成したので、次のステップは、S3 バケットへのアクセス許可を発行する IAM ユーザーを設(shè)定することです。

プロファイルのセキュリティ認(rèn)証情報(bào)セクションに移動(dòng)し、ユーザーを作成します。

次に、ユーザーのアクセス キーを作成し、アクセス キーと秘密キーを取得します。

コンピューターのルート ディレクトリに、.aws フォルダーと、拡張子のない credentials という名前のファイルを作成します。次に、次のようにキーを追加します:

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

次に、これらの権限をユーザーに発行して、S3 アップロードを許可します。

最後に、Go プロジェクトを初期化し、AWS Go SDK をインストールします。

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

これでセットアップは完了です。AWS S3 バケットを使用してファイルのアップロード、ダウンロード、管理を開(kāi)始できます。

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

ファイルをアップロードするには、新しいセッションを作成し、ファイルを開(kāi)き、セッション インスタンスを使用してファイルをアップロードする必要があります。

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

UploadFile 関數(shù)は、バケット名、AWS リージョン、ファイルキー、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

パラメータを指定して UploadFile 関數(shù)を呼び出したとき、ファイルが S3 バケットにアップロードされたことがわかります。

AWS S3 コンソールでファイル名をクリックすると、いつでもファイルの詳細(xì)を參照できます。

S3 バケットからのファイルのダウンロード

これで、指定したキーを使用してファイルの取得を試みることができます。

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 インスタンス內(nèi)のファイル パラメーターを受け取ります。 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ù)を使用してプログラムを?qū)g行すると、ファイルは指定した宛先パスにダウンロードされる必要があります。

宛先パスのキーにもキーを指定する必要があります。

S3 バケットからのファイルの削除

S3 バケットからファイルを削除するには、AWS SDK の 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 構(gòu)造體で呼び出され、ここで Bucket パラメーターと Key パラメーターを指定します。

WaitUntilObjectNotExists 関數(shù)を使用して、ファイルが存在しないことを確認(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
}

DeleteFile 関數(shù)を?qū)g行すると、Makefile が S3 バケットに存在しないことがわかります。

結(jié)論

IAM ユーザー用に S3 バケットを設(shè)定し (root でも機(jī)能します)、S3 バケットからファイルをアップロード、ダウンロード、削除する方法を?qū)W習(xí)しました。

AWS S3 バケットを使用して実行できる機(jī)能は他にもたくさんあります。この記事が、プロジェクトのユースケースに応じてさらに先に進(jìn)むための基礎(chǔ)となれば幸いです。

以上がAmazon Sith Go でのファイル管理の初心者ガイドの詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國(guó)語(yǔ) Web サイトの他の関連記事を參照してください。