ביטול הרצות של צינורות עיבוד נתונים

המסוף

כדי לבטל הפעלה של צינור נתונים שמתבצעת כרגע במסוף Cloud de Confiance :

1. בקטע Agent Platform, עוברים לכרטיסייה Runs בדף Pipelines.

   לדף Runs

2. בעמודה Run (הרצה), לוחצים על השם של הרצת צינור הנתונים שרוצים לבטל.
3. בדף שבו מוצגים פרטי ההרצה של צינור הנתונים, לוחצים על עצירה. האפשרות הזו זמינה רק אם הסטטוס של הפעלת צינור העיבוד הוא Running.

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

REST

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

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

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

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

POST https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/pipelineJobs/PIPELINE_RUN_ID:cancel

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

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/pipelineJobs/PIPELINE_RUN_ID:cancel"

$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/pipelineJobs/PIPELINE_RUN_ID:cancel" | Select-Object -Expand Content

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

Python

בדוגמה הבאה מוצג איך לבטל הפעלה של צינור נתונים שמתבצעת או מתוזמנת, באמצעות השיטה PipelineJob.cancel:

from google.cloud import aiplatform
aiplatform.init(project=PROJECT_ID, location=LOCATION)
pipeline_job = aiplatform.PipelineJob.get(resource_name="PIPELINE_RUN_ID")
pipeline_job.cancel()

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

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

REST

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

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

• ‫LOCATION: האזור שבו נמצאים ההרצות של צינור עיבוד הנתונים. מידע נוסף על האזורים שבהם זמין Agent Platform Pipelines מופיע במדריך למיקומים של Agent Platform של Gemini Enterprise.
• ‫PROJECT_ID: הפרויקט Cloud de Confiance by S3NS שמכיל את ההרצות של צינורות הנתונים.
• ‫PIPELINE_RUN_ID_1, ‏PIPELINE_RUN_ID_2: המזהים של משימות הצינור שרוצים לבטל. מזהה העבודה מופיע בכרטיסייה Runs בדף Pipelines במסוף Cloud de Confiance .

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

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

גוף בקשת JSON:

{
  "names": [
    "projects/PROJECT_ID/locations/LOCATION/pipelineJobs/PIPELINE_RUN_ID_1",
    "projects/PROJECT_ID/locations/LOCATION/pipelineJobs/PIPELINE_RUN_ID_2"
  ]
}

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

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/pipelineJobs:batchCancel"

$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/pipelineJobs:batchCancel" | Select-Object -Expand Content

אתם אמורים לקבל תגובת JSON שדומה לזו:

{
  "name": "projects/PROJECT_NUMBER/locations/LOCATION/operations/OPERATION_ID",
  "metadata": {
    "@type": "type.googleapis.com/google.cloud.aiplatform.v1.BatchCancelPipelineJobsOperationMetadata",
    "genericMetadata": {
      "createTime": "2025-05-25T16:11:21.011113Z",
      "updateTime": "2025-05-25T16:11:21.011113Z"
    }
  }
}

Python

אפשר להשתמש בדוגמה הבאה כדי לבטל כמה הפעלות של צינורות שמתבצעות כרגע או מתוזמנות, באמצעות השיטה PipelineJob.batch_cancel:

from google.cloud import aiplatform_v1
from google.api_core.client_options import ClientOptions
pipeline_run_ids_to_cancel = [
  "PIPELINE_RUN_ID_1",
  "PIPELINE_RUN_ID_2",
]
client_options = ClientOptions(api_endpoint=f"LOCATION-aiplatform.googleapis.com")
pipeline_job_client = aiplatform_v1.PipelineServiceClient(client_options=client_options)
pipeline_resource_names_to_cancel = []
for run_id in pipeline_run_ids_to_cancel:
  full_resource_name = f"projects/PROJECT_NUMBER/locations/LOCATION/pipelineJobs/{run_id.strip()}"
  pipeline_resource_names_to_cancel.append(full_resource_name)
parent = f"projects/PROJECT_ID/locations/LOCATION"
pipeline_job_client.batch_cancel_pipeline_jobs(parent=parent, names=pipeline_resource_names_to_cancel)

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

• ‫PROJECT_ID: מזהה הפרויקט.
• ‫LOCATION: האזור שבו נוצרו הרצות של הפייפליין.
• ‫PROJECT_NUMBER: מספר הפרויקט. אפשר למצוא את מספר הפרויקט במסוף Cloud de Confiance .למידע נוסף, אפשר לעיין במאמר איפה מוצאים את השם, המספר והמזהה של הפרויקט.
• ‫PIPELINE_RUN_ID_1 ו-PIPELINE_JOB_ID_2: המזהים הייחודיים של הפעלות צינורות שרוצים לבטל. מזהי ההרצה של צינורות העיבוד מוצגים בכרטיסייה Runs בדף Pipelines במסוף Cloud de Confiance .