feat(jobs): add database backup example

Author: thomas-tacquet

jobs/databases-backup/Dockerfile

@@ -0,0 +1,14 @@
+FROM golang:1.23-alpine
+
+# Set destination for COPY
+WORKDIR /app
+
+COPY go.mod ./
+COPY go.sum ./
+COPY *.go ./
+
+# Build
+RUN go build -o /server-image
+
+# Run
+CMD [ "/server-image" ]

jobs/databases-backup/go.mod

@@ -0,0 +1,7 @@
+module gitlab.infra.online.net/ttacquet/jobs-demo
+
+go 1.23
+
+require github.com/scaleway/scaleway-sdk-go v1.0.0-beta.30
+
+require gopkg.in/yaml.v2 v2.4.0 // indirect

jobs/databases-backup/go.sum

@@ -0,0 +1,6 @@
+github.com/scaleway/scaleway-sdk-go v1.0.0-beta.30 h1:yoKAVkEVwAqbGbR8n87rHQ1dulL25rKloGadb3vm770=
+github.com/scaleway/scaleway-sdk-go v1.0.0-beta.30/go.mod h1:sH0u6fq6x4R5M7WxkoQFY/o7UaiItec0o1LinLCJNq8=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=
+gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=

jobs/databases-backup/main.go

@@ -0,0 +1,133 @@
+package main
+
+import (
+	"fmt"
+	"os"
+	"strconv"
+	"time"
+
+	"github.com/scaleway/scaleway-sdk-go/api/rdb/v1"
+	"github.com/scaleway/scaleway-sdk-go/scw"
+)
+
+const (
+	// Defining variable or secret readings.
+	VAR_ORG_ID = "SCW_DEFAULT_ORGANIZATION_ID"
+	VAR_AK     = "SCW_ACCESS_KEY"
+	VAR_SK     = "SCW_SECRET_KEY"
+	VAR_REGION = "REGION"
+	VAR_RDB_ID = "INSTANCE_ID"
+
+	// optional, never expires if not definied.
+	VAR_EXPIRE_AT_DAYS = "EXPIRE_AT_DAYS"
+)
+
+func main() {
+	fmt.Println("creating backup of managed database...")
+
+	// Create a Scaleway client with credentials from environment variables.
+	client, err := scw.NewClient(
+		// Get your organization ID at https://console.scaleway.com/organization/settings
+		scw.WithDefaultOrganizationID(os.Getenv(VAR_ORG_ID)),
+
+		// Get your credentials at https://console.scaleway.com/iam/api-keys
+		scw.WithAuth(os.Getenv(VAR_AK), os.Getenv(VAR_SK)),
+
+		// Get more about our availability zones at https://www.scaleway.com/en/docs/console/my-account/reference-content/products-availability/
+		scw.WithDefaultRegion(scw.RegionFrPar),
+	)
+	if err != nil {
+		panic(err)
+	}
+
+	rdbAPI := rdb.NewAPI(client)
+
+	if err := createRdbSnapshot(rdbAPI); err != nil {
+		panic(err)
+	}
+}
+
+func createRdbSnapshot(rdbAPI *rdb.API) error {
+	rdbInstance, err := rdbAPI.GetInstance(&rdb.GetInstanceRequest{
+		Region:     scw.Region(os.Getenv(VAR_REGION)),
+		InstanceID: os.Getenv(VAR_RDB_ID),
+	})
+	if err != nil {
+		return fmt.Errorf("error while getting database instance %w", err)
+	}
+
+	databasesList, err := rdbAPI.ListDatabases(&rdb.ListDatabasesRequest{
+		Region:     scw.Region(os.Getenv(VAR_REGION)),
+		InstanceID: rdbInstance.ID,
+	})
+	if err != nil {
+		return fmt.Errorf("error while listing databases %w", err)
+	}
+
+	expiresAt, err := getExpirationDate()
+	if err != nil {
+		return fmt.Errorf("error while getting expiration date %w", err)
+	}
+
+	tn := time.Now()
+	backupName := fmt.Sprintf("backup_%s_%d%d%d", rdbInstance.Name, tn.Year(), tn.Month(), tn.Day())
+
+	for _, database := range databasesList.Databases {
+
+		backup, err := rdbAPI.CreateDatabaseBackup(&rdb.CreateDatabaseBackupRequest{
+			Region:       scw.Region(os.Getenv(VAR_REGION)),
+			InstanceID:   rdbInstance.ID,
+			Name:         backupName,
+			DatabaseName: database.Name,
+			ExpiresAt:    expiresAt,
+		})
+		if err != nil {
+			return fmt.Errorf("error while creating database backup request %w", err)
+		}
+
+		fmt.Println("Created backup ", backup.Name)
+	}
+
+	return nil
+}
+
+func getExpirationDate() (*time.Time, error) {
+	var expiresAt *time.Time
+	expireDays := os.Getenv(VAR_EXPIRE_AT_DAYS)
+
+	if expireDays != "" {
+		expireDaysInt, err := strconv.Atoi(expireDays)
+		if err != nil {
+			return nil, fmt.Errorf("error while getting %w", err)
+		}
+
+		if expireDaysInt > 0 {
+			expiration := time.Now().AddDate(0, 0, expireDaysInt)
+			expiresAt = &expiration
+		}
+	}
+
+	return expiresAt, nil
+}
+
+func init() {
+	if os.Getenv(VAR_ORG_ID) == "" {
+		panic("missing " + VAR_ORG_ID)
+	}
+
+	if os.Getenv(VAR_AK) == "" {
+		panic("missing " + VAR_AK)
+	}
+
+	if os.Getenv(VAR_SK) == "" {
+		panic("missing " + VAR_SK)
+	}
+
+	if os.Getenv(VAR_RDB_ID) == "" {
+		panic("missing " + VAR_RDB_ID)
+	}
+
+	if os.Getenv(VAR_REGION) == "" {
+		panic("missing " + VAR_REGION)
+	}
+}