Amazon Sith Go でのファイル管理の初心者ガイド

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

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

AWS と Go の入門

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

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

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

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

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

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

コンピューターのルート ディレクトリに、.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 バケットを使用してファイルのアップロード、ダウンロード、管理を開始できます。

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 バケットにアップロードされたことがわかります。

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

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

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 バケットに存在しないことがわかります。

結論

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

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

以上がAmazon Sith Go でのファイル管理の初心者ガイドの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。