Amazon Sith Go에서 파일 관리를 위한 초보자 가이드-Golang-php.cn

Amazon Sith Go에서 파일 관리를 위한 초보자 가이드

Mary-Kate Olsen

풀어 주다： 2024-11-05 02:19:02

원래의

251명이 탐색했습니다.

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 폴더와 확장자가 없는 자격 증명이라는 파일을 생성합니다. 그런 다음 다음과 같이 키를 추가하세요.

[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 함수는 파일 버킷, 키, 파일 본문 및 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 구조체와 함께 호출됩니다.

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 기능을 실행하면 내 S3 버킷에 Makefile이 더 이상 존재하지 않는 것을 확인할 수 있습니다.

Beginner