פיתוח ויצירה של משימת Go ב-Cloud Run

כתיבת המשימה לדוגמה

כדי לכתוב משימה ב-Go:

1. יוצרים ספרייה חדשה בשם jobs ועוברים אליה:

   mkdir jobs
   cd jobs
   

2. באותה ספרייה, יוצרים קובץ main.go לקוד המשימה בפועל. מעתיקים את שורות הדוגמה הבאות:

   package main
   
   import (
   	"fmt"
   	"log"
   	"math/rand"
   	"os"
   	"strconv"
   	"time"
   )
   
   type Config struct {
   	// Job-defined
   	taskNum    string
   	attemptNum string
   
   	// User-defined
   	sleepMs  int64
   	failRate float64
   }
   
   func configFromEnv() (Config, error) {
   	// Job-defined
   	taskNum := os.Getenv("CLOUD_RUN_TASK_INDEX")
   	attemptNum := os.Getenv("CLOUD_RUN_TASK_ATTEMPT")
   	// User-defined
   	sleepMs, err := sleepMsToInt(os.Getenv("SLEEP_MS"))
   	failRate, err := failRateToFloat(os.Getenv("FAIL_RATE"))
   
   	if err != nil {
   		return Config{}, err
   	}
   
   	config := Config{
   		taskNum:    taskNum,
   		attemptNum: attemptNum,
   		sleepMs:    sleepMs,
   		failRate:   failRate,
   	}
   	return config, nil
   }
   
   func sleepMsToInt(s string) (int64, error) {
   	sleepMs, err := strconv.ParseInt(s, 10, 64)
   	return sleepMs, err
   }
   
   func failRateToFloat(s string) (float64, error) {
   	// Default empty variable to 0
   	if s == "" {
   		return 0, nil
   	}
   
   	// Convert string to float
   	failRate, err := strconv.ParseFloat(s, 64)
   
   	// Check that rate is valid
   	if failRate < 0 || failRate > 1 {
   		return failRate, fmt.Errorf("Invalid FAIL_RATE value: %f. Must be a float between 0 and 1 inclusive.", failRate)
   	}
   
   	return failRate, err
   }
   
   func main() {
   	config, err := configFromEnv()
   	if err != nil {
   		log.Fatal(err)
   	}
   
   	log.Printf("Starting Task #%s, Attempt #%s ...", config.taskNum, config.attemptNum)
   
   	// Simulate work
   	if config.sleepMs > 0 {
   		time.Sleep(time.Duration(config.sleepMs) * time.Millisecond)
   	}
   
   	// Simulate errors
   	if config.failRate > 0 {
   		if failure := randomFailure(config); failure != nil {
   			log.Fatalf("%v", failure)
   		}
   	}
   
   	log.Printf("Completed Task #%s, Attempt #%s", config.taskNum, config.attemptNum)
   }
   
   // Throw an error based on fail rate
   func randomFailure(config Config) error {
   	rand.Seed(time.Now().UnixNano())
   	randomFailure := rand.Float64()
   
   	if randomFailure < config.failRate {
   		return fmt.Errorf("Task #%s, Attempt #%s failed.", config.taskNum, config.attemptNum)
   	}
   	return nil
   }
   

   במשימות ב-Cloud Run, המשתמשים יכולים לציין את מספר המשימות שהמשימה צריכה לבצע. הקוד לדוגמה הזה מראה איך להשתמש במשתנה הסביבה המובנה CLOUD_RUN_TASK_INDEX. כל משימה מייצגת עותק אחד של הקונטיינר שפועל. חשוב לזכור שהמשימות בדרך כלל מבוצעות במקביל. השימוש בכמה משימות שימושי אם כל משימה יכולה לעבד באופן עצמאי קבוצת משנה של הנתונים.

   כל משימה מודעת לאינדקס שלה, שמאוחסן במשתנה הסביבה CLOUD_RUN_TASK_INDEX. משתנה הסביבה המובנה CLOUD_RUN_TASK_COUNT מכיל את מספר המשימות שסופקו בזמן ביצוע המשימה באמצעות הפרמטר --tasks.

   הקוד שמוצג גם מראה איך לנסות שוב משימות, באמצעות משתנה הסביבה המובנה CLOUD_RUN_TASK_ATTEMPT, שמכיל את מספר הפעמים שהמשימה הזו נוסתה שוב, החל מ-0 בניסיון הראשון וגדל ב-1 בכל ניסיון חוזר, עד --max-retries.

   הקוד גם מאפשר ליצור כשלים כדי לבדוק ניסיונות חוזרים, וליצור יומני שגיאות כדי לראות איך הם נראים.

3. יוצרים קובץ go.mod עם התוכן הבא:

   module github.com/GoogleCloudPlatform/golang-samples/run/jobs
   
   go 1.25.0
   

הקוד שלכם מוכן לאריזה בקונטיינר.

יצירת קונטיינר של משימות, שליחה שלו ל-Artifact Registry ופריסה ב-Cloud Run

במדריך למתחילים הזה משתמשים בפריסה מהמקור, שיוצרת את הקונטיינר, מעלה אותו ל-Artifact Registry ופורסת את המשימה ב-Cloud Run:

gcloud run jobs deploy job-quickstart \
    --source . \
    --tasks 50 \
    --set-env-vars SLEEP_MS=10000 \
    --set-env-vars FAIL_RATE=0.1 \
    --max-retries 5 \
    --region REGION \
    --project=PROJECT_ID

כאשר PROJECT_ID הוא מזהה הפרויקט ו-REGION הוא האזור, לדוגמה europe-west1. שימו לב שאפשר לשנות את הפרמטרים השונים לכל ערך שרוצים להשתמש בו למטרות בדיקה. הפונקציה SLEEP_MS מדמה עבודה, והפונקציה FAIL_RATE גורמת ל-X% מהמשימות להיכשל, כדי שתוכלו להתנסות בהקבלה ובניסיון חוזר של משימות שנכשלו.

הפעלת משימה ב-Cloud Run

כדי להריץ את המשימה שיצרתם:

gcloud run jobs execute job-quickstart --region REGION

מחליפים את REGION באזור שבו יצרתם ופרסתם את המשימה, לדוגמה europe-west1.