Membuat Penyimpanan Objek Vultr Dengan Klien Vultr Go

• pengantar
• Prasyarat
• Membuat Penyimpanan Objek dengan Klien Vultr Go
• Buat Folder Proyek
• Inisialisasi modul
• Unduh Perpustakaan
• Setel Variabel Lingkungan Kunci API
• Buat Program Go
• Contoh Output

pengantar

Panduan ini menjelaskan cara membuat Penyimpanan Objek Vultr di aplikasi Go Anda dengan klien Vultr Go . Penyimpanan Objek Vultr kompatibel dengan S3 API.

Prasyarat

• Komputer yang menjalankan Windows, Linux, atau macOS dengan Go 1.12+ terinstal.
• Pengetahuan pemrograman dasar.
• Opsional: IDE yang mendukung Go (misalnya Visual Studio Code, emacs, atau Atom).

Membuat Penyimpanan Objek dengan Klien Vultr Go

The Vultr Go klien digunakan untuk berinteraksi dengan API Vultr . API Vultr memungkinkan Anda untuk mengontrol sumber daya yang terkait dengan akun Anda, termasuk Penyimpanan Objek Vultr. Informasi terperinci tentang klien Vultr Go tersedia di artikel ini .

Buat Folder Proyek

Buat folder di direktori saat ini.

$ mkdir vultr_demo

Masukkan folder baru.

$ cd vultr_demo

Inisialisasi modul

$ go mod init vultr_demo

Unduh Perpustakaan

$ go get github.com/vultr/govultr

Setel Variabel Lingkungan Kunci API

Setel variabel lingkungan VULTR_API_KEY ke kunci API Anda. Kunci API Anda ditemukan di sini: https://my.vultr.com/settings/#settingsapi

Peringatan: Lindungi kunci API Anda seperti Anda akan melindungi kata sandi Anda. Kunci API memiliki akses ke seluruh akun Anda, termasuk penagihan, server, dan penyimpanan.

Misalnya, di Ubuntu Linux, tambahkan baris ini ke ~/.profile.

export VULTR_API_KEY=YOUR_API_KEY_HERE

Buat Program Go

Rekatkan masing-masing fragmen kode berikut ke dalam file baru bernama main.go. File lengkap juga tersedia untuk diunduh .

Atur paket dan impor pustaka yang diperlukan.

package main

import (
    "context"
    "log"
    "os"
    "time"

    "github.com/vultr/govultr"
)

Mulai main()fungsinya.

func main() {

Baca variabel lingkungan kunci API.

var (
    // Get our Vultr API Key from an environment variable.
    VultrAPIKey = os.Getenv("VULTR_API_KEY")
)

Buat klien Vultr.

// Create a Vultr client with our API Key.
vultr := govultr.NewClient(nil, VultrAPIKey)

Tentukan lokasi untuk membuat Object Storage. Ambil lokasi cluster, verifikasi ada, pilih satu cluster, dan tampilkan.

// Find the clusters we can create our Object Storage in.
clusters, err := vultr.ObjectStorage.ListCluster(ctx)
if err != nil {
    log.Fatalf("Error listing clusters: %s", err)
}

// Verify there's at least one cluster.
if len(clusters) < 1 {
    log.Fatal("Could not find any clusters to create our Object Storage")
}

// Choose the first cluster, and print it.
cluster := clusters[0]
log.Printf("Chosen cluster: %+v", cluster)

Buat Object Storage di cluster yang dipilih.

// Create our Object Storage in the first cluster listed with our custom label.
label := "my-object-storage"
storageID, err := vultr.ObjectStorage.Create(ctx, cluster.ObjectStoreClusterID, label)
if err != nil {
    log.Fatalf("Error creating storage: %s", err)
}

log.Printf("Created our Object Storage with the ID: %d", storageID.ID)

Tunggu hingga Object Storage aktif.

var storage govultr.ObjectStorage

// Query the API every five seconds to until our server is ready.
for {
    // List all of the Object Storage containers with our label and include the S3 credentials.
    list, err := vultr.ObjectStorage.List(ctx, &govultr.ObjectListOptions{
        Label:     label,
        IncludeS3: true,
    })
    if err != nil {
        log.Fatalf("Error listing storage with label \"%s\": %s", label, err)
    }

    // Make sure we found one (and only one) Object Storage container.
    if len(list) != 1 {
        log.Fatalf("%d object storage containers exist with the label \"%s\"; we need 1", len(list), label)
    }

    storage = list[0]

    // If the server is active, break out of this loop.
    if storage.Status == "active" {
        break
    }

    // Wait for five seconds before querying the API again.
    log.Printf("The Object Storage's status is currently \"%s\", waiting for another five seconds to check if it's \"active\".", storage.Status)
    time.Sleep(time.Second * 5)
}

Menampilkan nama titik akhir dan kredensial koneksi.

// Print the information of our new Object Storage.
log.Print("Successfully created and listed our Object Storage!")
log.Printf("Object Storage: %+v", storage)

// We also have S3 credentials here now, so we could open an S3 compatible client.
log.Printf("S3 credentials: %s - %s - %s", storage.S3Hostname, storage.S3AccessKey, storage.S3SecretKey)

Akhiri fungsi utama.

// end main()
}

Simpan dan jalankan main.gofile yang sudah selesai .

go run main.go

Contoh Output

2020/03/03 13:05:48 Chosen cluster: {ObjectStoreClusterID:2 RegionID:1 Location:New Jersey Hostname:ewr1.vultrobjects.com Deploy:yes}
2020/03/03 13:05:48 Created our Object Storage with the ID: xxxxxxxx
2020/03/03 13:05:49 The Object Storage's status is currently pending, waiting for another five seconds to check if it's active.
2020/03/03 13:06:06 Object Storage: {ID:34214512 DateCreated:2020-03-03 13:05:47 ObjectStoreClusterID:2 RegionID:1 Location:New Jersey Label:my-object-storage Status:active S3Keys:{S3Hostname:ewr1.vultrobjects.com S3AccessKey:[REDACTED ACCESS KEY] S3SecretKey:[REDACTED SECRET KEY]}}
2020/03/03 13:06:06 S3 credentials: ewr1.vultrobjects.com - [REDACTED ACCESS KEY] - [REDACTED SECRET KEY]

Dalam contoh ini, nama titik akhir adalah ewr1.vultrobjects.com, dan kunci dihapus. Akses penyimpanan objek baru Anda dengan klien S3 yang kompatibel menggunakan nama titik akhir, kunci akses dan kunci rahasia yang ditunjukkan oleh program Go Anda.