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

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

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

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

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

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

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

יצירת רשימת 'הבאים בתור'

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

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

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

המסוף

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

   כניסה לדף Queues

2. לוחצים על יצירת תור.

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 (דפדפן)

מעתיקים את גוף הבקשה ופותחים את דף העזר של השיטה. החלונית של API 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.

   כניסה לדף 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

כדי לאחזר תור, משתמשים בשיטה 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. החלונית של API 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. כדי להגדיל את המכסה, בשורה של המכסה, לוחצים על סמל האליפסה > עריכת המכסה.

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

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

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

• הגדרת תורי משימות ב-Cloud Tasks
• הפניית API בארכיטקטורת REST
• הפניית API ל-RPC
• פקודות של Cloud Tasks gcloud