Some or all of the information on this page might not apply to Cloud de Confiance by S3NS. See Differences from Google Cloud for more details.

‫Google משתמשת בטכנולוגיית AI כדי לתרגם תוכן לשפה המועדפת עליך. בתרגומים כאלו עשויות להיות שגיאות.

תזמון הרצת צינור באמצעות scheduler API

אתם יכולים לתזמן הפעלות חד-פעמיות או חוזרות של צינורות עיבוד נתונים ב-Vertex AI באמצעות Scheduler API. כך תוכלו להטמיע אימון מתמשך בפרויקט.

אחרי שיוצרים לוח זמנים, הוא יכול להיות באחד מהסטטוסים הבאים:

‫ACTIVE: תזמון פעיל יוצר באופן רציף הפעלות של צינורות עיבוד נתונים בהתאם לתדירות שהוגדרה באמצעות ביטוי התזמון של cron. לוח זמנים הופך לפעיל בשעת ההתחלה שלו ונשאר במצב הזה עד לשעת הסיום שצוינה, או עד שמשהים אותו.
‫PAUSED: לוח זמנים מושהה לא יוצר הרצות של צינורות עיבוד נתונים. אפשר להפעיל מחדש לוח זמנים שהושהה. כשמפעילים מחדש תזמון שהושהה, אפשר להשתמש בפרמטר catch_up כדי לציין אם צריך לתזמן מחדש ולשלוח את ההרצות שדילגו עליהן (הרצות שהיו אמורות להיות מתוזמנות אם התזמון היה פעיל) בתזמון המוקדם ביותר האפשרי.
‫COMPLETED: פרומפט מתוזמן שההפעלה שלו הסתיימה לא יוצר יותר הפעלות חדשות של פייפליין. לוח זמנים מסתיים בהתאם לשעת הסיום שצוינה.

אתם יכולים להשתמש ב-API של הכלי לתזמון כדי:

יצירת לוח זמנים
List schedules
שליפת לוח זמנים
השהיית לוח זמנים
עדכון של לוח זמנים
המשך ההפעלה של לוח הזמנים
מחיקת פרומפט מתוזמן

לפני שמתחילים

לפני שתתזמנו הפעלה של צינור באמצעות ה-API של מתזמן הפעולות, תצטרכו להגדיר את פרויקט Cloud de Confiance by S3NS וסביבת הפיתוח במסוף Cloud de Confiance .

כדי להשתמש ב-Scheduler API, צריך לתת למשתמש או לחשבון השירות לפחות אחת מההרשאות הבאות ב-IAM:
- roles/aiplatform.admin
- roles/aiplatform.user
פיתוח והידור של צינור עיבוד נתונים. מידע נוסף זמין במאמר יצירת צינור נתונים.

יצירת לוח זמנים

אתם יכולים ליצור לוח זמנים חד-פעמי או להגדיר שהוא יחזור על עצמו.

המסוף

כדי ליצור תזמון באמצעות מסוף Cloud de Confiance : אם כבר קיים לוח זמנים לפרויקט ולאזור, פועלים לפי ההוראות במאמר יצירת הפעלה של צינור.

כדי ליצור תזמון של צינור נתונים:

במסוף Cloud de Confiance , בקטע Agent Platform, עוברים לכרטיסייה Schedules בדף Pipelines.

מעבר ללוחות זמנים
לוחצים על Create scheduled run (יצירת הפעלה מתוזמנת) כדי לפתוח את החלונית Create pipeline run (יצירת הפעלת צינור).
מציינים את פרטי ההפעלה על ידי בחירה באחת מהאפשרויות הבאות:
- כדי ליצור הרצת צינור נתונים על סמך תבנית קיימת של צינור נתונים, לוחצים על בחירה מתוך צינורות נתונים קיימים ומזינים את הפרטים הבאים:
  1. בוחרים את המאגר שמכיל את קובץ ההגדרה של הצינור או הרכיב.
  2. בוחרים את הצינור או הרכיב ואת הגרסה.
- כדי להעלות הגדרה של צינורות מעובדים, לוחצים על העלאת קובץ ומזינים את הפרטים הבאים:
  1. לוחצים על עיון כדי לפתוח את בורר הקבצים. עוברים אל קובץ ה-YAML של צינור העברת הנתונים שרוצים להפעיל, בוחרים את צינור העברת הנתונים ולוחצים על פתיחה.
  2. שם הצינור או הרכיב מציג כברירת מחדל את השם שצוין בהגדרת הצינור. אפשר גם לציין שם אחר לצינור.
- כדי לייבא קובץ הגדרת צינור מ-Cloud Storage, לוחצים על ייבוא מ-Cloud Storage ומזינים את הפרטים הבאים:
  1. לוחצים על Browse כדי לעבור אל קטגוריית Cloud Storage שמכילה את אובייקט ההגדרה של צינור הנתונים, בוחרים את הקובץ ולוחצים על Select.
  2. מציינים את שם הצינור או הרכיב.
מציינים שם הפעלה כדי לזהות באופן ייחודי את ההפעלה של צינור עיבוד הנתונים.
מציינים את לוח הזמנים להפעלה באופן הבא:
1. בוחרים באפשרות תשלום חוזר.
2. בקטע שעת התחלה, מציינים מתי לוח הזמנים יהפוך לפעיל.
  - כדי לתזמן את ההרצה הראשונה כך שתתבצע מיד אחרי יצירת התזמון, בוחרים באפשרות מיד.
  - כדי לתזמן את ההרצה הראשונה כך שתתרחש בשעה ובתאריך ספציפיים, בוחרים באפשרות בתאריך.
3. בשדה תדירות, מציינים את התדירות לתזמון ולהפעלה של צינורות עיבוד הנתונים, באמצעות ביטוי לתזמון cron שמבוסס על unix-cron.
4. בקטע סיום, מציינים מתי התזמון מסתיים.
  - כדי לציין שהתזמון יוצר הפעלות של צינורות ללא הגבלת זמן, בוחרים באפשרות אף פעם.
  - כדי לציין שהתזמון מסתיים בתאריך ובשעה ספציפיים, בוחרים באפשרות בתאריך ומציינים את תאריך הסיום ואת שעת הסיום של התזמון.
אופציונלי: כדי לציין חשבון שירות מותאם אישית, מפתח הצפנה בניהול הלקוח (CMEK) או רשת VPC עם שותפות, לוחצים על אפשרויות מתקדמות ומציינים חשבון שירות, CMEK או שם של רשת VPC עם שותפות.
לוחצים על המשך ומציינים את הגדרת זמן הריצה של צינור הנתונים.
לוחצים על שליחה כדי ליצור את לוח הזמנים להפעלת צינור הנתונים.

REST

כדי ליצור לוח זמנים להרצת צינור, שולחים בקשת POST באמצעות השיטה projects.locations.schedules.create.

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

‫LOCATION: האזור שבו רוצים להריץ את צינור העיבוד. מידע נוסף על האזורים שבהם זמינים צינורות של Agent Platform זמין במדריך מיקומים של Agent Platform ב-Gemini Enterprise.
‫PROJECT_ID: Cloud de Confiance by S3NS הפרויקט שבו רוצים להריץ את צינור העיבוד.
‫DISPLAY_NAME: השם של תזמון צינור הנתונים. אפשר לציין שם באורך של עד 128 תווים בתקן UTF-8.
‫START_TIME: חותמת זמן שאחריה אפשר לתזמן את ההרצה הראשונה. לדוגמה: 2045-07-26T00:00:00Z. אם לא מציינים את הפרמטר הזה, חותמת הזמן שמתאימה לתאריך ולשעה שבהם יוצרים את התזמון משמשת כערך ברירת המחדל.
‫END_TIME: חותמת זמן שאחריה לא מתוזמנים יותר הפעלות של צינור עיבוד הנתונים. אחרי שמגיעים ל-END_TIME, המצב של לוח הזמנים משתנה ל-COMPLETED. אם לא מציינים את הפרמטר הזה, התזמון ממשיך להפעיל משימות חדשות של צינורות ללא הגבלה, עד שמשהים או מוחקים את התזמון.
‫CRON_EXPRESSION: ביטוי לתזמון cron שמייצג את התדירות לתזמון ולהרצה של צינורות. מידע נוסף זמין במאמר בנושא cron.
‫MAX_CONCURRENT_RUN_COUNT: המספר המקסימלי של הרצות מקבילות ללוח הזמנים.

‫API_REQUEST_TEMPLATE: תבנית של בקשת API‏ PipelineService.CreatePipelineJob שמשמשת להפעלת צינורות העברת הנתונים המתוזמנים. מידע נוסף על הפרמטרים בתבנית של בקשת ה-API זמין במסמכי העזרה בנושא pipelineJobs.create. שימו לב שאי אפשר לציין את הפרמטר pipelineJobId בתבנית הזו, כי Scheduler API לא תומך בפרמטר הזה.

כאן אפשר לראות תבנית לדוגמה של בקשת API, שבה gs://gcs_directory הוא קטגוריה של Cloud Storage עבור פלט של פריטי מידע שנוצרו בתהליך פיתוח של פייפליינים.

{
  "parent":"projects//locations/us-central1",
  "pipelineJob": {
    "displayName": "hello-world",
    "pipelineSpec": {
      "deploymentConfig": {
        "@type": "type.googleapis.com/ml_pipelines.PipelineDeploymentConfig",
        "executors": {
          "HelloWorld_executor": {
            "container": {
              "command": ["sleep", "1"],
              "image": "google/cloud-sdk:latest"
            }
          }
        }
      },
      "pipelineInfo": {
        "name": "hello-world"
      },
      "root": {
        "dag": {
          "tasks": {
            "task-test-hello-world": {
              "taskInfo": {"name": "HelloWorld"},
              "componentRef": {"name": "HelloWorld"},
              "cachingOptions": {}
            }
          }
        }
      },
      "components": {
        "HelloWorld": {
          "executorLabel": "HelloWorld_executor"
        }
      },
      "schemaVersion": "2.0.0"
    },
    "runtimeConfig": {
      "gcsOutputDirectory": "gs://gcs_directory"
    }
  }
}

ה-method של ה-HTTP וכתובת ה-URL:

POST https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules

גוף בקשת JSON:

{
  "display_name":"DISPLAY_NAME",
  "start_time": "START_TIME",
  "end_time": "END_TIME",
  "cron": "CRON_EXPRESSION",
  "max_concurrent_run_count": "MAX_CONCURRENT_RUN_COUNT",
  "create_pipeline_job_request": API_REQUEST_TEMPLATE
}

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

curl

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

שומרים את גוף הבקשה בקובץ בשם request.json ומריצים את הפקודה הבאה:

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

PowerShell

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

שומרים את גוף הבקשה בקובץ בשם request.json ומריצים את הפקודה הבאה:

$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://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules" | Select-Object -Expand Content

הפלט שיוצג אמור להיות דומה לזה שמופיע בהמשך. אפשר להשתמש ב-SCHEDULE_ID מהתשובה כדי לאחזר, להשהות, להמשיך או למחוק את הפעולה המתוזמנת. ‫PIPELINE_JOB_CREATION_REQUEST מייצג את בקשת ה-API ליצירת משימת צינור העיבוד.

{
  "name": "projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID",
  "displayName": "DISPLAY_NAME",
  "startTime": "START_TIME",
  "state": "ACTIVE",
  "createTime": "2025-01-01T00:00:00.000000Z",
  "nextRunTime": "2045-08-01T00:00:00Z",
  "cron": "CRON_EXPRESSION",
  "maxConcurrentRunCount": "MAX_CONCURRENT_RUN_COUNT",
  "createPipelineJobRequest": PIPELINE_JOB_CREATION_REQUEST
}

Python

אפשר ליצור תזמון להרצת צינור בדרכים הבאות:

יוצרים פרומפט מתוזמן על סמך PipelineJob באמצעות ה-method‏ PipelineJob.create_schedule.
יצירת לוח זמנים באמצעות ה-method‏ PipelineJobSchedule.create.

במהלך יצירת לוח זמנים להרצת צינור, אפשר גם להעביר את ה-placeholders הבאים שנתמכים על ידי KFP SDK כקלט:

{{$.pipeline_job_name_placeholder}}
{{$.pipeline_job_resource_name_placeholder}}
{{$.pipeline_job_id_placeholder}}
{{$.pipeline_task_name_placeholder}}
{{$.pipeline_task_id_placeholder}}
{{$.pipeline_job_create_time_utc_placeholder}}
{{$.pipeline_job_schedule_time_utc_placeholder}}
{{$.pipeline_root_placeholder}}

מידע נוסף זמין במאמר בנושא סוגי קלט מיוחדים במאמרי העזרה של Kubeflow Pipelines v2.

יצירת לוח זמנים מ`PipelineJob`

בדוגמה הבאה מוסבר איך לתזמן הפעלות של צינורות באמצעות השיטה PipelineJob.create_schedule:

from google.cloud import aiplatform

pipeline_job = aiplatform.PipelineJob(
  template_path="COMPILED_PIPELINE_PATH",
  pipeline_root="PIPELINE_ROOT_PATH",
  display_name="DISPLAY_NAME",
)

pipeline_job_schedule = pipeline_job.create_schedule(
  display_name="SCHEDULE_NAME",
  cron="TZ=CRON",
  max_concurrent_run_count=MAX_CONCURRENT_RUN_COUNT,
  max_run_count=MAX_RUN_COUNT,
)

‫COMPILED_PIPELINE_PATH: הנתיב לקובץ ה-YAML של צינור העיבוד שעבר קומפילציה. זה יכול להיות נתיב מקומי או URI של Cloud Storage.

אופציונלי: כדי לציין גרסה מסוימת של תבנית, מוסיפים את תג הגרסה לצד הנתיב באחד מהפורמטים הבאים:
- ‫COMPILED_PIPELINE_PATH:TAG, כאשר TAG הוא תג הגרסה.
- ‫COMPILED_PIPELINE_PATH@SHA256_TAG, כאשר SHA256_TAG הוא ערך הגיבוב sha256 של גרסת צינור העיבוד.
‫PIPELINE_ROOT_PATH: (אופציונלי) כדי לשנות את נתיב הבסיס של צינור עיבוד הנתונים שצוין בהגדרת צינור עיבוד הנתונים, מציינים נתיב שלמשימת צינור עיבוד הנתונים יש גישה אליו, כמו URI של קטגוריה של Cloud Storage.
‫DISPLAY_NAME: השם של צינור העברת הנתונים. המידע הזה יוצג במסוף Cloud de Confiance .
‫SCHEDULE_NAME: השם של תזמון צינור הנתונים. אפשר לציין שם באורך של עד 128 תווים בתקן UTF-8.
‫CRON: ביטוי לתזמון cron שמייצג את התדירות לתזמון ולהרצה של צינורות. מידע נוסף זמין במאמר בנושא Cron.
‫MAX_CONCURRENT_RUN_COUNT: המספר המקסימלי של הרצות מקבילות ללוח הזמנים.
‫MAX_RUN_COUNT: המספר המקסימלי של הפעלות צינורות שהתזמון יוצר, שאחריו הוא מסתיים.

יצירת לוח זמנים באמצעות `PipelineJobSchedule.create`

בדוגמה הבאה מוסבר איך לתזמן הפעלות של צינורות באמצעות השיטה PipelineJobSchedule.create:

from google.cloud import aiplatform

pipeline_job = aiplatform.PipelineJob(
  template_path="COMPILED_PIPELINE_PATH",
  pipeline_root="PIPELINE_ROOT_PATH",
  display_name="DISPLAY_NAME",
)

pipeline_job_schedule = aiplatform.PipelineJobSchedule(
  pipeline_job=pipeline_job,
  display_name="SCHEDULE_NAME"
)

pipeline_job_schedule.create(
  cron="TZ=CRON",
  max_concurrent_run_count=MAX_CONCURRENT_RUN_COUNT,
  max_run_count=MAX_RUN_COUNT,
)

‫COMPILED_PIPELINE_PATH: הנתיב לקובץ ה-YAML של צינור העיבוד שעבר קומפילציה. זה יכול להיות נתיב מקומי או URI של Cloud Storage.

אופציונלי: כדי לציין גרסה מסוימת של תבנית, מוסיפים את תג הגרסה לצד הנתיב באחד מהפורמטים הבאים:
- ‫COMPILED_PIPELINE_PATH:TAG, כאשר TAG הוא תג הגרסה.
- ‫COMPILED_PIPELINE_PATH@SHA256_TAG, כאשר SHA256_TAG הוא ערך הגיבוב (hash) מסוג sha256 של גרסת צינור העיבוד.
‫PIPELINE_ROOT_PATH: (אופציונלי) כדי לשנות את נתיב הבסיס של צינור עיבוד הנתונים שצוין בהגדרת צינור עיבוד הנתונים, מציינים נתיב שלמשימת צינור עיבוד הנתונים יש גישה אליו, כמו URI של קטגוריה של Cloud Storage.
‫DISPLAY_NAME: השם של צינור העברת הנתונים. המידע הזה יוצג במסוף Cloud de Confiance .
‫SCHEDULE_NAME: השם של תזמון צינור הנתונים. אפשר לציין שם באורך של עד 128 תווים בתקן UTF-8.
‫CRON: ביטוי לתזמון cron שמייצג את התדירות לתזמון ולהרצה של צינורות. מידע נוסף זמין במאמר בנושא Cron.
‫MAX_CONCURRENT_RUN_COUNT: המספר המקסימלי של הרצות מקבילות ללוח הזמנים.
‫MAX_RUN_COUNT: המספר המקסימלי של הפעלות צינורות שהתזמון יוצר, שאחריו הוא מסתיים.

הצגת רשימת לוחות זמנים

אפשר לראות את רשימת הפרומפטים המתוזמנים של Cloud de Confiance by S3NS הפרויקט.

המסוף

אפשר לראות את רשימת לוחות הזמנים של צינורות העיבוד בכרטיסייה Schedules (לוחות זמנים) במסוף Cloud de Confiance באזור שנבחר.

כדי לראות את רשימת התזמונים של צינורות הנתונים, במסוף Cloud de Confiance , בקטע Agent Platform, עוברים לכרטיסייה Schedules בדף Pipelines.

מעבר ללוחות זמנים

REST

כדי להציג רשימה של תזמוני הפעלות של צינורות עיבוד נתונים בפרויקט, שולחים בקשת GET באמצעות השיטה projects.locations.schedules.list.

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

‫LOCATION: האזור שבו רוצים להריץ את צינור העיבוד. מידע נוסף על האזורים שבהם זמינים צינורות של Agent Platform זמין במדריך מיקומים של Agent Platform ב-Gemini Enterprise.
‫PROJECT_ID: Cloud de Confiance by S3NS הפרויקט שבו רוצים להריץ את צינור העיבוד.
‫FILTER: (אופציונלי) ביטוי לסינון רשימת התזמונים. מידע נוסף זמין במאמר בנושא ...
‫PAGE_SIZE: (אופציונלי) מספר התזמונים שיוצגו בכל דף.
‫PAGE_TOKEN: (אופציונלי) הטוקן של דף הרשימה הרגיל, בדרך כלל מתקבל דרך ListSchedulesResponse.next_page_token[] מקריאה קודמת של ScheduleService.ListSchedules[].
‫ORDER_BY: (אופציונלי) רשימה מופרדת בפסיקים של שדות, שמציינת את סדר המיון של לוחות הזמנים בתשובה.

ה-method של ה-HTTP וכתובת ה-URL:

GET https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules?FILTER&PAGE_SIZE&PAGE_TOKEN&ORDER_BY

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

curl

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

curl -X GET \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules?FILTER&PAGE_SIZE&PAGE_TOKEN&ORDER_BY"

PowerShell

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

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

Invoke-WebRequest `
    -Method GET `
    -Headers $headers `
    -Uri "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules?FILTER&PAGE_SIZE&PAGE_TOKEN&ORDER_BY" | Select-Object -Expand Content

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

{
  "schedules": [
    SCHEDULE_ENTITY_OBJECT_1,
    SCHEDULE_ENTITY_OBJECT_2,
    ...
  ],
}

Python

בדוגמה הבאה מוצגת רשימה של כל התזמונים בפרויקט בסדר יורד לפי שעת היצירה שלהם:

from google.cloud import aiplatform

aiplatform.PipelineJobSchedule.list(
  filter='display_name="DISPLAY_NAME"',
  order_by='create_time desc'
)

‫DISPLAY_NAME: השם של תזמון צינור הנתונים. אפשר לציין שם באורך של עד 128 תווים בתקן UTF-8.

אחזור לוח זמנים

אפשר לאחזר תזמון של הפעלת צינור עיבוד נתונים באמצעות מזהה התזמון.

REST

כדי לאחזר לוח זמנים להרצת צינור עיבוד נתונים, שולחים בקשת GET באמצעות השיטה projects.locations.schedules.get ומזהה לוח הזמנים.

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

‫LOCATION: האזור שבו רוצים להריץ את צינור העיבוד. מידע נוסף על האזורים שבהם זמינים צינורות של Agent Platform זמין במדריך מיקומים של Agent Platform ב-Gemini Enterprise.
‫PROJECT_ID: Cloud de Confiance by S3NS הפרויקט שבו רוצים להריץ את צינור העיבוד.
‫SCHEDULE_ID: מזהה ייחודי של לוח הזמנים שנוצר בזמן יצירת לוח הזמנים.

ה-method של ה-HTTP וכתובת ה-URL:

GET https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID

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

curl

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

curl -X GET \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID"

PowerShell

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

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

Invoke-WebRequest `
    -Method GET `
    -Headers $headers `
    -Uri "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID" | Select-Object -Expand Content

הפלט שיוצג אמור להיות דומה לזה שמופיע בהמשך. ‫PIPELINE_JOB_CREATION_REQUEST מייצג את בקשת ה-API ליצירת משימת צינור העיבוד.

{
  "name": "projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID",
  "displayName": "schedule_display_name",
  "startTime": "2045-07-26T06:59:59Z",
  "state": "ACTIVE",
  "createTime": "20xx-01-01T00:00:00.000000Z",
  "nextRunTime": "2045-08-01T00:00:00Z",
  "cron": "TZ=America/New_York 0 0 1 * *",
  "maxConcurrentRunCount": "10",
  "createPipelineJobRequest": PIPELINE_JOB_CREATION_REQUEST
}

Python

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

from google.cloud import aiplatform

pipeline_job_schedule = aiplatform.PipelineJobSchedule.get(schedule_id=SCHEDULE_ID)

‫SCHEDULE_ID: מזהה ייחודי של לוח הזמנים שנוצר בזמן יצירת לוח הזמנים.

השהיית לוח זמנים

אפשר להשהות תזמון פעיל של צינור נתונים על ידי ציון מזהה התזמון. כשמשהים לוח זמנים, המצב שלו משתנה מACTIVE לPAUSED.

המסוף

אפשר להשהות תזמון של הרצת צינורות שפעיל כרגע.

כדי להשהות תזמון:

במסוף Cloud de Confiance , בקטע Agent Platform, עוברים לכרטיסייה Schedules בדף Pipelines.

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

REST

כדי להשהות את לוח הזמנים של הרצת צינור עיבוד נתונים בפרויקט, שולחים בקשת POST באמצעות השיטה projects.locations.schedules.pause.

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

‫LOCATION: האזור שבו התזמון של הפעלת צינור הנתונים פעיל כרגע. מידע נוסף על האזורים שבהם זמינים צינורות של Agent Platform זמין במדריך מיקומים של Agent Platform ב-Gemini Enterprise.
‫PROJECT_ID: הפרויקט Cloud de Confiance by S3NS שבו לוח הזמנים של הפעלת צינור הנתונים פעיל כרגע.
‫SCHEDULE_ID: מזהה ייחודי של לוח הזמנים שנוצר בזמן יצירת לוח הזמנים.

ה-method של ה-HTTP וכתובת ה-URL:

POST https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID:pause

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

curl

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

curl -X POST \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     -H "Content-Type: application/json; charset=utf-8" \
     -d "" \
     "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID:pause"

PowerShell

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

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

Invoke-WebRequest `
    -Method POST `
    -Headers $headers `
    -Uri "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID:pause" | Select-Object -Expand Content

אמורים לקבל קוד סטטוס של הצלחה (2xx) ותגובה ריקה.

Python

בדוגמה הבאה מוצג איך להשהות תזמון של הפעלת צינור:

from google.cloud import aiplatform

pipeline_job_schedule = aiplatform.PipelineJobSchedule.get(schedule_id=SCHEDULE_ID)

pipeline_job_schedule.pause()

‫SCHEDULE_ID: מזהה ייחודי של לוח הזמנים שנוצר בזמן יצירת לוח הזמנים.

עדכון לוח זמנים

אפשר לעדכן תזמון קיים של צינור עיבוד נתונים שנוצר עבור הפרויקט.Cloud de Confiance by S3NS

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

REST

כדי לעדכן את לוח הזמנים של הרצת צינור בפרויקט, שולחים בקשת PATCH באמצעות השיטה projects.locations.schedules.patch.

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

‫LOCATION: האזור שבו רוצים להריץ את צינור העיבוד. מידע נוסף על האזורים שבהם זמינים צינורות של Agent Platform זמין במדריך מיקומים של Agent Platform ב-Gemini Enterprise.
‫PROJECT_ID: Cloud de Confiance by S3NS הפרויקט שבו רוצים להריץ את צינור העיבוד.
‫DISPLAY_NAME: השם של תזמון צינור הנתונים. אפשר לציין שם באורך של עד 128 תווים בתקן UTF-8.
‫MAX_CONCURRENT_RUN_COUNT: המספר המקסימלי של הרצות מקבילות ללוח הזמנים.

ה-method של ה-HTTP וכתובת ה-URL:

POST https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID?updateMask=display_name,max_run_count -d '{"display_name":"DISPLAY_NAME", "max_concurrent_run_count": MAX_CONCURRENT_RUN_COUNT}'

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

curl

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

curl -X POST \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     -H "Content-Type: application/json; charset=utf-8" \
     -d "" \
     "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID?updateMask=display_name,max_run_count -d '{"display_name":"DISPLAY_NAME", "max_concurrent_run_count": MAX_CONCURRENT_RUN_COUNT}'"

PowerShell

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

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

Invoke-WebRequest `
    -Method POST `
    -Headers $headers `
    -Uri "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID?updateMask=display_name,max_run_count -d '{"display_name":"DISPLAY_NAME", "max_concurrent_run_count": MAX_CONCURRENT_RUN_COUNT}'" | Select-Object -Expand Content

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

{
  "name": "projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID",
  "displayName": "DISPLAY_NAME",
  "startTime": "START_TIME",
  "state": "ACTIVE",
  "createTime": "2025-01-01T00:00:00.000000Z",
  "nextRunTime": NEXT_RUN_TIME,
  "maxConcurrentRunCount": "MAX_CONCURRENT_RUN_COUNT",
}

Python

בדוגמה הבאה מוסבר איך לתזמן הפעלות של צינורות באמצעות השיטה PipelineJobSchedule.update:

from google.cloud import aiplatform

pipeline_job_schedule = aiplatform.PipelineJobSchedule.get(schedule_id=SCHEDULE_ID)

pipeline_job_schedule.update(
  display_name='DISPLAY_NAME',
  max_concurrent_run_count=MAX_CONCURRENT_RUN_COUNT,
)

‫SCHEDULE_ID: מזהה ייחודי של לוח הזמנים שנוצר בזמן יצירת לוח הזמנים.
‫DISPLAY_NAME: השם של תזמון צינור הנתונים. אפשר לציין שם באורך של עד 128 תווים בתקן UTF-8.
‫MAX_CONCURRENT_RUN_COUNT: המספר המקסימלי של הרצות מקבילות ללוח הזמנים.

המשך הפעלה של לוח זמנים

כדי להמשיך הפעלה של לוח זמנים של צינור נתונים שהושהה, מציינים את מזהה לוח הזמנים. כשמפעילים מחדש לוח זמנים, הסטטוס שלו משתנה מPAUSED לACTIVE.

המסוף

אפשר להמשיך את ההפעלה של לוח זמנים של צינורות שהושהה.

כדי להפעיל מחדש תזמון:

במסוף Cloud de Confiance , בקטע Agent Platform, עוברים לכרטיסייה Schedules בדף Pipelines.

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

REST

כדי להפעיל מחדש תזמון של הרצת צינור בפרויקט, שולחים בקשת POST באמצעות השיטה projects.locations.schedules.resume.

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

‫LOCATION: האזור שבו לוח הזמנים של הפעלת צינור עיבוד הנתונים מושהה כרגע. מידע נוסף על האזורים שבהם זמינים צינורות של Agent Platform זמין במדריך מיקומים של Agent Platform ב-Gemini Enterprise.
‫PROJECT_ID: הפרויקט Cloud de Confiance by S3NS שבו ההפעלה המתוזמנת של צינור העברת הנתונים מושהית כרגע.
‫SCHEDULE_ID: מזהה ייחודי של לוח הזמנים שנוצר בזמן יצירת לוח הזמנים.
‫CATCH_UP: (אופציונלי) מציינים אם לוח הזמנים המושהה צריך למלא מחדש את הפעלות צינור הנתונים שדילג עליהן. כדי להפעיל מחדש את צינורות הנתונים שהדילוג עליהם בוצע, מזינים את הפקודה הבאה:
{ "catch_up":true } כברירת מחדל, הערך של הפרמטר הזה הוא false.

ה-method של ה-HTTP וכתובת ה-URL:

POST https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID:resume -d 'CATCH_UP'

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

curl

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

curl -X POST \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     -H "Content-Type: application/json; charset=utf-8" \
     -d "" \
     "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID:resume -d 'CATCH_UP'"

PowerShell

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

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

Invoke-WebRequest `
    -Method POST `
    -Headers $headers `
    -Uri "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID:resume -d 'CATCH_UP'" | Select-Object -Expand Content

אמורים לקבל קוד סטטוס של הצלחה (2xx) ותגובה ריקה.

Python

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

from google.cloud import aiplatform

pipeline_job_schedule = aiplatform.PipelineJobSchedule.get(schedule_id=SCHEDULE_ID)

pipeline_job_schedule.resume(catch_up=CATCH_UP)

‫SCHEDULE_ID: מזהה ייחודי של לוח הזמנים שנוצר בזמן יצירת לוח הזמנים.
‫CATCH_UP: (אופציונלי) מציינים אם לוח הזמנים המושהה צריך למלא מחדש את הפעלות צינור הנתונים שדילג עליהן. כדי להפעיל מחדש את הצינורות שהדילוג עליהם בוצע ולתזמן אותם מחדש, מזינים את הפקודה הבאה:
{ "catch_up":true }

מחיקת פרומפט מתוזמן

כדי למחוק תזמון של צינור, צריך לציין את מזהה התזמון.

המסוף

אתם יכולים למחוק לוח זמנים להרצת צינור, לא משנה מה הסטטוס שלו.

כדי למחוק תזמון:

במסוף Cloud de Confiance , בקטע Agent Platform, עוברים לכרטיסייה Schedules בדף Pipelines.

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

REST

כדי למחוק תזמון של הפעלת צינור בפרויקט, שולחים בקשת DELETE באמצעות השיטה projects.locations.schedules.delete.

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

‫LOCATION: האזור שבו רוצים למחוק את התזמון של צינור הנתונים. מידע נוסף על האזורים שבהם זמינים צינורות של Agent Platform זמין במדריך מיקומים של Agent Platform ב-Gemini Enterprise.
‫PROJECT_ID: הפרויקט Cloud de Confiance by S3NS שבו רוצים למחוק את לוח הזמנים.
‫SCHEDULE_ID: המזהה הייחודי של התזמון שנוצר בזמן יצירת התזמון.

ה-method של ה-HTTP וכתובת ה-URL:

DELETE https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID

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

curl

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

curl -X DELETE \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID"

PowerShell

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

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

Invoke-WebRequest `
    -Method DELETE `
    -Headers $headers `
    -Uri "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/schedules/SCHEDULE_ID" | Select-Object -Expand Content

הפלט שיוצג אמור להיות דומה לזה שמופיע בהמשך. ‫OPERATION_ID מייצג את פעולת המחיקה.

{
  "name": "projects/PROJECT_ID/locations/LOCATION/operations/OPERATION_ID",
  "metadata": {
    "@type": "type.googleapis.com/google.cloud.aiplatform.v1.DeleteOperationMetadata",
    "genericMetadata": {
      "createTime": "20xx-01-01T00:00:00.000000Z",
      "updateTime": "20xx-01-01T00:00:00.000000Z"
    }
  },
  "done": true,
  "response": {
    "@type": "type.googleapis.com/google.protobuf.Empty"
  }
}

Python

בדוגמה הבאה מוסבר איך למחוק תזמון של הפעלת צינור:

from google.cloud import aiplatform

pipeline_job_schedule = aiplatform.PipelineJobSchedule.get(schedule_id=SCHEDULE_ID)

pipeline_job_schedule.delete()

‫SCHEDULE_ID: מזהה ייחודי של לוח הזמנים שנוצר בזמן יצירת לוח הזמנים.

הצגת רשימה של כל המשימות בצינור עיבוד הנתונים שנוצרו על ידי לוח זמנים

אפשר לציין את מזהה הפרומפט המתוזמן כדי לראות רשימה של כל המשימות בצינור שנוצרו על ידי פרומפט מתוזמן.

REST

כדי להציג רשימה של כל ההרצות של צינורות עיבוד הנתונים שנוצרו על ידי תזמון של צינור עיבוד נתונים, שולחים בקשת GET באמצעות השיטה projects.locations.pipelineJobs.

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

‫LOCATION: האזור שבו רוצים להריץ את צינור העיבוד. מידע נוסף על האזורים שבהם זמינים צינורות של Agent Platform זמין במדריך מיקומים של Agent Platform ב-Gemini Enterprise.
‫PROJECT_ID: Cloud de Confiance by S3NS הפרויקט שבו רוצים להריץ את צינור העיבוד.
‫SCHEDULE_ID: מזהה ייחודי של לוח הזמנים שנוצר בזמן יצירת לוח הזמנים.

ה-method של ה-HTTP וכתובת ה-URL:

GET https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/pipelineJobs?filter=schedule_name=projects/PROJECT/locations/LOCATION/schedules/SCHEDULE_ID

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

curl

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

curl -X GET \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/pipelineJobs?filter=schedule_name=projects/PROJECT/locations/LOCATION/schedules/SCHEDULE_ID"

PowerShell

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

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

Invoke-WebRequest `
    -Method GET `
    -Headers $headers `
    -Uri "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/pipelineJobs?filter=schedule_name=projects/PROJECT/locations/LOCATION/schedules/SCHEDULE_ID" | Select-Object -Expand Content

הפלט שיוצג אמור להיות דומה לזה שמופיע בהמשך.

{
  "pipelineJobs": [
    PIPELINE_JOB_ENTITY_1,
    PIPELINE_JOB_ENTITY_2,
    ...
  ],
}

Python

בדוגמה הבאה מוצגת רשימה של כל המשימות בצינור שנוצרו על ידי תזמון, בסדר יורד של זמני היצירה שלהן:

from google.cloud import aiplatform

pipeline_job_schedule = aiplatform.PipelineJobSchedule.get(schedule_id=SCHEDULE_ID)

pipeline_job_schedule.list_jobs(order_by='create_time_desc')

‫SCHEDULE_ID: מזהה ייחודי של לוח הזמנים שנוצר בזמן יצירת לוח הזמנים.

תזמון הרצת צינור באמצעות scheduler API

לפני שמתחילים

יצירת לוח זמנים

המסוף

REST

curl

PowerShell

Python

יצירת לוח זמנים מPipelineJob

יצירת לוח זמנים באמצעות PipelineJobSchedule.create

הצגת רשימת לוחות זמנים

המסוף

REST

curl

PowerShell

Python

אחזור לוח זמנים

REST

curl

PowerShell

Python

השהיית לוח זמנים

המסוף

REST

curl

PowerShell

Python

עדכון לוח זמנים

REST

curl

PowerShell

Python

המשך הפעלה של לוח זמנים

המסוף

REST

curl

PowerShell

Python

מחיקת פרומפט מתוזמן

המסוף

REST

curl

PowerShell

Python

הצגת רשימה של כל המשימות בצינור עיבוד הנתונים שנוצרו על ידי לוח זמנים

REST

curl

PowerShell

Python

יצירת לוח זמנים מ`PipelineJob`

יצירת לוח זמנים באמצעות `PipelineJobSchedule.create`