Amazon Sith Go でのファイル管理の初心者ガイド-Golang-php.cn

Amazon Simple Storage Service (S3) は、ウェブベースのファイルストレージの業界標準になっています。最大 99.999999999% の耐久性とセキュリティを実現するように設計されています。また、柔軟なストレージクラス、データ管理、分析機能も備えています。

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

AWS と Go の入門

適切な権限とパラメータを使用して AWS S3 バケットを設定するのは、困難な場合があります。バケットを作成し、IAM ユーザーを作成し、バケット上で操作を実行する権限を IAM ユーザーに発行し、環境内にアクセスキーを設定する必要があります。

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

Beginner

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

Beginner

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

プロファイルのセキュリティ認証情報セクションに移動し、ユーザーを作成します。

Beginner

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

Beginner

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

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

ログイン後にコピー

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

Beginner

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

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

ログイン後にコピー

これでセットアップは完了です。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 関数は、バケット名、AWS リージョン、ファイルキー、ACL (アクセス制御リスト) を取得し、指定されたファイルを指定されたキーで S3 にアップロードします。

session.NewSession 関数は新しい AWS セッションを作成し、s3.New は新しい S3 セッションを作成します。 PutObject 関数は、ファイル Bucket、Key、ファイル本体、および ACL を含む PutObjectInput への参照を受け取ります。

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

ログイン後にコピー

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

Beginner

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

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 関数は &s3.GetObjectInput インスタンス内のファイルパラメーターを受け取ります。 io.Copy 関数を使用して、ファイルストリームを任意の宛先にコピーできるようになりました。

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 関数を使用してプログラムを実行すると、ファイルは指定した宛先パスにダウンロードされる必要があります。

Beginner

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

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

S3 バケットからファイルを削除するには、AWS SDK の DeleteObject 関数を使用してファイルを削除します。削除する 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 関数は、アップロードおよびダウンロードの例のように、セッションを作成することから始まります。 s3Client.DeleteObject は DeleteObjectInput 構造体で呼び出され、ここで Bucket パラメーターと Key パラメーターを指定します。

WaitUntilObjectNotExists 関数を使用して、ファイルが存在しないことを確認できます。

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 関数を実行すると、Makefile が S3 バケットに存在しないことがわかります。

Beginner