Perkhidmatan Storan Mudah Amazon (S3) telah menjadi standard industri untuk storan fail berasaskan web. Ia direka untuk ketahanan dan keselamatan sehingga 99.999999999%. Ia juga mempunyai kelas storan yang fleksibel, pengurusan data dan ciri analitis.

Adakah anda membina apl sebelah pelayan untuk projek anda dalam Go dan memerlukan pilihan storan? Artikel ini menganggap bahawa anda seorang pemula AWS dan membimbing anda melalui proses menggunakan S3 untuk storan daripada apl Go anda.

Bermula dengan AWS dan Go

Menyediakan baldi AWS S3 dengan kebenaran dan parameter yang betul boleh menjadi menakutkan. Anda perlu membuat baldi, mencipta pengguna IAM, mengeluarkan kebenaran kepada pengguna IAM untuk melaksanakan operasi pada baldi dan menyediakan kunci akses dalam persekitaran anda.

Mula-mula, buat akaun Amazon AWS dan log masuk jika anda belum memilikinya. Kemudian, cari S3 seperti ini.

Sekarang, Klik pada "Buat baldi." Anda akan digesa untuk mengkonfigurasi baldi mengikut spesifikasi projek anda.

Sekarang anda telah mencipta baldi, langkah seterusnya ialah menyediakan pengguna IAM yang akan anda berikan kebenaran untuk mengakses baldi S3.

Pergi ke bahagian bukti kelayakan keselamatan profil anda dan buat pengguna.

Kemudian, cipta kunci akses untuk pengguna dan dapatkan akses dan kunci rahsia.

Pada komputer anda, dalam direktori akar, buat folder .aws dan fail bernama kelayakan tanpa sambungan; kemudian tambah kekunci seperti ini:

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

Sekarang, Keluarkan kebenaran ini kepada pengguna untuk membenarkan muat naik S3.

Akhir sekali, mulakan projek Go dan pasang AWS Go SDK.

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

Anda sudah bersedia, dan kini, anda boleh mula memuat naik, memuat turun dan mengurus fail dengan Baldi AWS S3.

Memuat naik Fail ke Baldi S3

Pertama, anda mesti mengimport pakej yang diperlukan daripada pakej AWS SDK.

Tambahkan modul ini pada bahagian atas fail main.go anda atau mana-mana fail yang anda gunakan:

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

Untuk memuat naik fail, anda mesti membuat sesi baharu, membuka fail dan menggunakan contoh sesi untuk memuat naik fail.

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

Fungsi UploadFile mengambil nama baldi, rantau AWS, kunci fail dan ACL (senarai kawalan akses) dan memuat naik fail yang ditentukan ke S3 dengan kunci yang ditentukan.

Fungsi session.NewSession mencipta sesi AWS baharu dan s3.New mencipta sesi S3 baharu. Fungsi PutObject mengambil rujukan kepada PutObjectInput dengan Baldi fail, Kunci, badan fail dan ACL.

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

Apabila saya memanggil fungsi UploadFile dengan parameter, inilah bukti bahawa fail itu telah dimuat naik ke baldi S3 saya.

Anda sentiasa boleh menyemak imbas lebih banyak butiran fail dengan mengklik nama fail pada konsol AWS S3.

Memuat turun Fail dari Baldi S3

Kini, anda boleh cuba mendapatkan semula fail dengan kunci yang telah anda tentukan.

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

Selepas mencipta contoh klien, fungsi GetObject menerima parameter fail dalam contoh &s3.GetObjectInput. Anda kini boleh menyalin strim fail ke destinasi pilihan anda dengan fungsi 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
}

Fail hendaklah dimuat turun ke laluan destinasi yang anda tentukan apabila melaksanakan program dengan fungsi Muat Turun Fail.

Anda perlu menentukan kunci dalam kekunci dalam laluan destinasi juga.

Memadam Fail daripada Baldi S3

Untuk memadamkan fail daripada baldi S3, anda akan menggunakan fungsi DeleteObject AWS SDK untuk mengalih keluar fail. Anda mesti menyatakan nama baldi S3 dan kunci fail yang ingin anda padamkan.

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

Fungsi DeleteFile bermula dengan mencipta sesi, seperti dalam contoh muat naik dan muat turun. s3Client.DeleteObject dipanggil dengan struct DeleteObjectInput, di mana anda akan menentukan parameter Baldi dan Kunci.

Anda boleh menggunakan fungsi WaitUntilObjectNotExists untuk mengesahkan bahawa fail itu tidak wujud.

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
}

Apabila melaksanakan fungsi DeleteFile, anda dapat melihat bahawa Makefile tidak lagi wujud dalam baldi S3 saya.

Kesimpulan

Anda telah mempelajari cara menyediakan baldi S3 untuk pengguna IAM (ia juga berfungsi untuk root) dan memuat naik, memuat turun dan memadam fail daripada baldi S3.

Terdapat banyak lagi fungsi yang boleh anda lakukan dengan Baldi AWS S3. Saya harap artikel ini telah menyediakan asas untuk anda melangkah lebih jauh, bergantung pada kes penggunaan projek anda.

Atas ialah kandungan terperinci Panduan Pemula untuk Mengurus Fail dalam Amazon Sith Go. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!