יצירת תורי משימות ב-Cloud Tasks

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

שימו לב לנקודות הבאות:

• שמות של תורים מורכבים משלושה חלקים: מזהה פרויקט, מיקום ומזהה תור. צריך להיות לכם Google Cloud פרויקט שמספק את מזהה הפרויקט.

• אם אתם משתמשים במשימות עם יעד ב-App Engine, אתם צריכים גם אפליקציה ב-App Engine שנמצאת באזור ספציפי, שבו פועלים התור וה-handlers שלכם. כשמוסיפים את האפליקציה, חשוב לשים לב לאזור.

  הערה: שני מיקומים שנקראים europe-west ו-us-central בפקודות של App Engine, נקראים בהתאמה europe-west1 ו-us-central1 בפקודות של Cloud Tasks.

• כדי להשתמש במשימות עם יעד HTTP, לא צריך אפליקציית App Engine. פשוט בוחרים מיקום של Google Cloud כשיוצרים את התור.

יצירת תור

אפשר ליצור תור בדרכים הבאות:

• במסוף Google Cloud
• באמצעות Google Cloud CLI בטרמינל או ב-Cloud Shell
• שליחת בקשה ישירה ל-Cloud Tasks API

הערה: אם אתם מגדירים ניתוב לתור של App Engine ולא מגדירים במפורש את השירות שמכיל את ה-worker המתאים, המערכת תשתמש בשירות ברירת המחדל. מידע נוסף זמין במאמר הגדרת הניתוב, המגבלות וניסיונות החזרה של תורים.

המסוף

1. במסוף Google Cloud , נכנסים לדף Cloud Tasks > Queues.

   מעבר לתורים

2. לוחצים על Create queue.

3. מזינים שם לתור, לדוגמה my-queue.

4. ברשימה Region, בוחרים מיקום נתמך שבו התור יפעל, לדוגמה asia-south1.

   אם הארגון שלכם מגביל את מיקום המשאבים ואתם רוצים ליצור את התור ב-us-central1 או ב-us-central2, מדיניות הארגון צריכה לאפשר יצירת תורים גם ב-us-central1 וגם ב-us-central2 (גם אם אתם צריכים תור רק באחד מהאזורים האלה).

5. אם רוצים, אפשר להגדיר את התור.

6. לוחצים על יצירה.

gcloud

משתמשים בפקודה gcloud tasks queues create כדי ליצור את התור:

  gcloud tasks queues create QUEUE_ID \
      --location=LOCATION

מחליפים את מה שכתוב בשדות הבאים:

• ‫QUEUE_ID: המזהה שאתם מקצים לתור. לדוגמה: my-queue.

• ‫LOCATION: אזור נתמך שבו התור יפעל, לדוגמה asia-south1.

  אם הארגון שלכם מגביל את מיקום המשאבים ואתם רוצים ליצור את התור ב-us-central1 או ב-us-central2, מדיניות הארגון צריכה לאפשר יצירת תורים גם ב-us-central1 וגם ב-us-central2 (גם אם אתם צריכים תור רק באחד מהאזורים האלה).

דגלים אחרים לפקודה של ה-CLI של gcloud מאפשרים להגדיר מגבלות קצב, אפשרויות לניסיון חוזר, סוגי תורים ועוד.

‫API בארכיטקטורת REST

כדי ליצור תור, משתמשים ב-method‏ projects.locations.queues.create.

לפני שמשתמשים בנתוני הבקשה, צריך להחליף את הנתונים הבאים:

• ‫PROJECT_ID: מזהה הפרויקט ב- Google Cloud .
• ‫LOCATION: אזור נתמך שבו התור יפעל, לדוגמה asia-south1.

  אם בארגון שלכם מיקום המשאבים מוגבל ואתם רוצים ליצור את התור ב-us-central1 או ב-us-central2, מדיניות הארגון צריכה לאפשר יצירת תורים גם ב-us-central1 וגם ב-us-central2 (גם אם אתם צריכים תור רק באחד מהאזורים האלה).

• ‫QUEUE_ID: המזהה שאתם מקצים לתור, לדוגמה my-queue.

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

תוכן בקשת JSON:

{
  "name": "projects/PROJECT_ID/locations/LOCATION/queues/QUEUE_ID"
}

כדי לשלוח את הבקשה צריך להרחיב אחת מהאפשרויות הבאות:

‫Curl (Linux,‏ macOS או Cloud Shell)

הערה: הפקודה הבאה מבוססת על ההנחה שנכנסתם ל-CLI של gcloud באמצעות חשבון המשתמש שלכם, על ידי הרצת gcloud init או gcloud auth login, או באמצעות Cloud Shell שמחבר אתכם אוטומטית ל-CLI של gcloud. כדי לבדוק איזה חשבון פעיל, אפשר להריץ את הפקודה gcloud auth list.

שומרים את גוף הבקשה בקובץ בשם request.json. כדי ליצור או להחליף את הקובץ הזה בספרייה הנוכחית, מריצים את הפקודה הבאה בטרמינל:

cat > request.json << 'EOF'
{
  "name": "projects/PROJECT_ID/locations/LOCATION/queues/QUEUE_ID"
}
EOF

לאחר מכן מבצעים את הפקודה הבאה כדי לשלוח את בקשת ה-REST:

curl -X POST \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     -H "Content-Type: application/json; charset=utf-8" \
     -d @request.json \
     "https://cloudtasks.googleapis.com/v2/projects/PROJECT_ID/locations/LOCATION/queues"

‎PowerShell (Windows)

הערה: הפקודה הבאה מבוססת על ההנחה שנכנסתם ל-CLI של gcloud באמצעות חשבון המשתמש שלכם, על ידי הרצת gcloud init או gcloud auth login. כדי לבדוק איזה חשבון פעיל, אפשר להריץ את הפקודה gcloud auth list.

שומרים את גוף הבקשה בקובץ בשם request.json. כדי ליצור או להחליף את הקובץ הזה בספרייה הנוכחית, מריצים את הפקודה הבאה בטרמינל:

@'
{
  "name": "projects/PROJECT_ID/locations/LOCATION/queues/QUEUE_ID"
}
'@  | Out-File -FilePath request.json -Encoding utf8

לאחר מכן מבצעים את הפקודה הבאה כדי לשלוח את בקשת ה-REST:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method POST `
    -Headers $headers `
    -ContentType: "application/json; charset=utf-8" `
    -InFile request.json `
    -Uri "https://cloudtasks.googleapis.com/v2/projects/PROJECT_ID/locations/LOCATION/queues" | Select-Object -Expand Content

‫APIs Explorer (דפדפן)

מעתיקים את גוף הבקשה ופותחים את דף העזר של השיטה. החלונית של APIs Explorer תיפתח בצד ימין של הדף. אפשר להשתמש בכלי הזה כדי לשלוח בקשות. מדביקים את גוף הבקשה בכלי הזה, ממלאים את כל שדות החובה ולוחצים על Execute.

אם הפעולה בוצעה בהצלחה, גוף התשובה יכיל מופע חדש של Queue:

{
  "name": "projects/PROJECT_ID/locations/LOCATION/queues/QUEUE_ID",
  "rateLimits": {
    "maxDispatchesPerSecond": 500,
    "maxBurstSize": 100,
    "maxConcurrentDispatches": 1000
  },
  "retryConfig": {
    "maxAttempts": 100,
    "minBackoff": "0.100s",
    "maxBackoff": "3600s",
    "maxDoublings": 16
  },
  "state": "RUNNING"
}

יכול להיות שיעברו כמה דקות עד שתור חדש יהיה זמין.

תיאור התור

כדי לוודא שהתור נוצר בהצלחה, אפשר לבצע את הפעולות הבאות:

• במסוף Google Cloud
• באמצעות ה-CLI של gcloud בטרמינל או ב-Cloud Shell

• שליחת בקשה ישירה ל-Cloud Tasks API

המסוף

1. במסוף Google Cloud , נכנסים לדף Cloud Tasks > Queues.

   מעבר לתורים

   סימן וי ירוק מציין שהתור פועל.

2. כדי לראות פרטים נוספים, לוחצים על שם התור ואז על הכרטיסייה Configuration.

gcloud

כדי לוודא שהתור נוצר בהצלחה, משתמשים בפקודה gcloud tasks queues describe:

gcloud tasks queues describe QUEUE_ID \
    --location=LOCATION

מחליפים את מה שכתוב בשדות הבאים:

• ‫QUEUE_ID: מזהה התור (השם המקוצר שלו)
• ‫LOCATION: המיקום של התור

הפלט אמור להיראות כך:

name: projects/PROJECT_ID/locations/LOCATION/queues/QUEUE_ID
rateLimits:
  maxBurstSize: 100
  maxConcurrentDispatches: 1000
  maxDispatchesPerSecond: 500.0
retryConfig:
  maxAttempts: 100
  maxBackoff: 3600s
  maxDoublings: 16
  minBackoff: 0.100s
state: RUNNING

‫API בארכיטקטורת REST

כדי לאחזר תור, משתמשים ב-method‏ projects.locations.queues.get.

לפני שמשתמשים בנתוני הבקשה, צריך להחליף את הנתונים הבאים:

• ‫PROJECT_ID: מזהה הפרויקט ב- Google Cloud .
• ‫LOCATION: האזור שבו נפרס התור, לדוגמה us-central1.
• ‫QUEUE_ID: המזהה הקצר של התור, לדוגמה my-queue.

כדי לשלוח את הבקשה צריך להרחיב אחת מהאפשרויות הבאות:

‫Curl (Linux,‏ macOS או Cloud Shell)

הערה: הפקודה הבאה מבוססת על ההנחה שנכנסתם ל-CLI של gcloud באמצעות חשבון המשתמש שלכם, על ידי הרצת gcloud init או gcloud auth login, או באמצעות Cloud Shell שמחבר אתכם אוטומטית ל-CLI של gcloud. כדי לבדוק איזה חשבון פעיל, אפשר להריץ את הפקודה gcloud auth list.

מריצים את הפקודה הבאה:

curl -X GET \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     "https://cloudtasks.googleapis.com/v2/projects/PROJECT_ID/locations/LOCATION/queues/QUEUE_ID"

‎PowerShell (Windows)

הערה: הפקודה הבאה מבוססת על ההנחה שנכנסתם ל-CLI של gcloud באמצעות חשבון המשתמש שלכם, על ידי הרצת gcloud init או gcloud auth login. כדי לבדוק איזה חשבון פעיל, אפשר להריץ את הפקודה gcloud auth list.

מריצים את הפקודה הבאה:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method GET `
    -Headers $headers `
    -Uri "https://cloudtasks.googleapis.com/v2/projects/PROJECT_ID/locations/LOCATION/queues/QUEUE_ID" | Select-Object -Expand Content

‫APIs Explorer (דפדפן)

פותחים את דף העזר של ה-method. החלונית של APIs Explorer תיפתח בצד ימין של הדף. אפשר להשתמש בכלי הזה כדי לשלוח בקשות. ממלאים את כל שדות החובה ולוחצים על Execute.

אם הפעולה בוצעה ללא שגיאות, גוף התשובה יכיל מופע של Queue:

{
  "name": "projects/PROJECT_ID/locations/LOCATION/queues/QUEUE_ID",
  "rateLimits": {
    "maxDispatchesPerSecond": 500,
    "maxBurstSize": 100,
    "maxConcurrentDispatches": 1000
  },
  "retryConfig": {
    "maxAttempts": 100,
    "minBackoff": "0.100s",
    "maxBackoff": "3600s",
    "maxDoublings": 16
  },
  "state": "RUNNING"
}

פתרון בעיות ביצירת תור

הערה: רישום ביומן של התור לא מופעל כברירת מחדל. איך משתמשים ב-Cloud Logging עם תורים?

אם אתם לא רואים את הפלט שציפיתם לו, אתם יכולים לנסות את הפעולות הבאות:

• ממתינים לפחות דקה עד שהתור יתחיל לפעול.

• צריך לוודא שאין כבר תור עם אותו מזהה. כדי לראות את התורים בפרויקט, משתמשים בפקודה gcloud tasks queues list:

  gcloud tasks queues list \
      --location=LOCATION

  כדי לחפש בכמה מיקומים, צריך לשלוח כמה בקשות.

• בודקים אם הגעתם למכסה של התור:

  1. במסוף Google Cloud , נכנסים לדף API/Service Details של Cloud Tasks API.

     כניסה לדף API/Service Details

  2. לוחצים על הכרטיסייה Quotas & System limits.

  3. כדי להגדיל מכסה, בשורה של המכסה לוחצים על סמל האפשרויות הנוספות > Edit quota.

     איך שולחים בקשה לשינוי המכסות

• מריצים מחדש את הפקודות ליצירת התור ומוודאים שכל שלב הושלם כמו שצריך.

המאמרים הבאים

• הגדרת ניתוב, מגבלות וניסיונות חוזרים בתור
• יצירת משימות ב-Cloud Tasks
• הגדרת פרמטרים לניסיון חוזר של משימה
• ניהול תורים ומשימות