Coba Gemini 1.5 Pro, model multimodal kami yang paling canggih di Vertex AI, dan lihat apa yang dapat Anda bangun dengan jendela konteks token 1 juta. Coba Gemini 1.5 Pro, model multimodal kami yang paling canggih di Vertex AI, dan lihat apa yang dapat Anda bangun dengan jendela konteks token 1 juta.

Menjadwalkan proses pipeline dengan scheduler API

Anda dapat menjadwalkan proses pipeline satu kali atau berulang di Vertex AI menggunakan scheduler API. Dengan demikian, Anda dapat menerapkan pelatihan berkelanjutan pada project Anda.

Setelah Anda membuatnya, jadwal dapat memiliki salah satu status berikut:

ACTIVE: Jadwal aktif secara terus-menerus membuat proses pipeline sesuai dengan frekuensi yang dikonfigurasi menggunakan ekspresi jadwal cron. Jadwal akan aktif pada waktu mulainya dan tetap dalam status tersebut hingga waktu berakhir yang ditentukan, atau hingga Anda menjedanya.
PAUSED: Jadwal yang dijeda tidak akan membuat proses pipeline. Anda dapat melanjutkan jadwal yang dijeda untuk mengaktifkannya kembali. Saat melanjutkan jadwal yang dijeda, Anda dapat menggunakan parameter catch_up untuk menentukan apakah proses yang dilewati (proses yang semestinya dijadwalkan jika jadwal aktif) harus dijadwalkan ulang dan dikirim sesegera mungkin.
COMPLETED: Jadwal yang sudah selesai tidak lagi membuat proses pipeline baru. Jadwal selesai sesuai dengan waktu berakhir yang ditentukan.

Anda dapat menggunakan scheduler API untuk melakukan hal berikut:

Membuat jadwal
Membuat daftar jadwal
Mengambil jadwal
Menjeda jadwal
Memperbarui jadwal
Melanjutkan jadwal
Menghapus jadwal

Sebelum memulai

Sebelum menjadwalkan proses pipeline menggunakan scheduler API, gunakan petunjuk berikut untuk menyiapkan project Google Cloud dan lingkungan pengembangan Anda di konsol Google Cloud.

Berikan setidaknya satu izin IAM berikut kepada pengguna atau akun layanan untuk menggunakan scheduler API:
- roles/aiplatform.admin
- roles/aiplatform.user
Bangun dan kompilasi pipeline. Untuk mengetahui informasi selengkapnya, lihat Membangun Pipeline.

Membuat jadwal

Anda dapat membuat jadwal satu kali atau berulang.

Konsol

Gunakan petunjuk berikut untuk membuat jadwal menggunakan konsol Google Cloud. Jika jadwal untuk project dan region sudah ada, gunakan petunjuk di Membuat proses pipeline.

Gunakan petunjuk berikut untuk membuat jadwal pipeline:

Di konsol Google Cloud, di bagian Vertex AI, buka tab Jadwal di halaman Pipeline.

Buka Jadwal
Klik Buat proses jadwal untuk membuka panel Buat proses pipeline.
Tentukan Detail proses berikut dengan memilih salah satu opsi berikut:
- Untuk membuat proses pipeline berdasarkan template pipeline yang ada, klik Pilih dari pipeline yang ada dan masukkan detail berikut:
  1. Pilih Repositori yang berisi file definisi pipeline atau komponen.
  2. Pilih Pipeline atau komponen dan Versi.
- Untuk mengupload definisi pipeline yang dikompilasi, klik Upload file dan masukkan detail berikut:
  1. Klik Telusuri untuk membuka pemilih file. Buka file YAML pipeline yang dikompilasi yang ingin Anda jalankan, pilih pipeline, lalu klik Buka.
  2. Nama pipeline atau komponen menampilkan nama yang ditentukan dalam definisi pipeline secara default. Atau, tentukan nama Pipeline yang berbeda.
- Untuk mengimpor file definisi pipeline dari Cloud Storage, klik Impor dari Cloud Storage, lalu masukkan detail berikut:
  1. Klik Telusuri untuk membuka bucket Cloud Storage yang berisi objek definisi pipeline, pilih file, lalu klik Pilih.
  2. Tentukan Nama pipeline atau komponen.
Tentukan Nama proses untuk mengidentifikasi secara unik proses pipeline.
Tentukan Jadwal proses, sebagai berikut:
1. Pilih Berulang.
2. Di bagian Waktu mulai, tentukan kapan jadwal akan aktif.
  - Untuk menjadwalkan proses pertama agar segera dilakukan setelah pembuatan jadwal, pilih Segera.
  - Untuk menjadwalkan proses pertama agar dilakukan pada waktu dan tanggal tertentu, pilih Aktif.
3. Di kolom Frequency, tentukan frekuensi untuk menjadwalkan dan menjalankan operasi pipeline, menggunakan ekspresi jadwal cron berdasarkan unix-cron.
4. Di bagian Berakhir, tentukan waktu berakhir jadwal.
  - Untuk menunjukkan bahwa jadwal membuat operasi pipeline tanpa batas waktu, pilih Never.
  - Untuk menunjukkan bahwa jadwal berakhir pada tanggal dan waktu tertentu, pilih Aktif, lalu tentukan tanggal dan waktu berakhir untuk jadwal tersebut.
Opsional: Untuk menentukan akun layanan kustom, kunci enkripsi yang dikelola pelanggan (CMEK), atau jaringan VPC yang di-peering, klik Opsi lanjutan, lalu tentukan nama akun layanan, CMEK, atau jaringan VPC yang di-peering.
Klik Lanjutkan, lalu tentukan Konfigurasi waktu proses untuk pipeline.
Klik Kirim untuk membuat jadwal proses pipeline.

REST

Untuk membuat jadwal proses pipeline, kirim permintaan POST menggunakan metode projects.locations.schedules.create.

Sebelum menggunakan data permintaan mana pun, lakukan penggantian berikut:

LOCATION: Region tempat Anda ingin menjalankan pipeline. Untuk mengetahui informasi selengkapnya tentang region yang menyediakan Vertex AI Pipelines, lihat panduan lokasi Vertex AI.
PROJECT_ID: Project Google Cloud tempat Anda ingin menjalankan pipeline.
DISPLAY_NAME: Nama jadwal pipeline. Anda dapat menentukan nama yang memiliki panjang maksimum 128 karakter UTF-8.
START_TIME: Stempel waktu saat proses pertama dapat dijadwalkan, misalnya, 2045-07-26T00:00:00Z. Jika Anda tidak menentukan parameter ini, stempel waktu yang sesuai dengan tanggal dan waktu pembuatan jadwal akan digunakan sebagai nilai default.
END_TIME: Stempel waktu saat proses pipeline tidak lagi dijadwalkan. Setelah END_TIME tercapai, status jadwal akan berubah menjadi COMPLETED. Jika Anda tidak menentukan parameter ini, jadwal akan terus menjalankan tugas pipeline baru tanpa batas waktu hingga Anda menjeda atau menghapus jadwal.
CRON_EXPRESSION: Ekspresi jadwal cron yang merepresentasikan frekuensi untuk menjadwalkan dan menjalankan proses pipeline. Untuk mengetahui informasi selengkapnya, lihat cron.
MAX_CONCURRENT_RUN_COUNT: Jumlah maksimum proses serentak untuk jadwal.

API_REQUEST_TEMPLATE: Template permintaan API PipelineService.CreatePipelineJob yang digunakan untuk menjalankan proses pipeline terjadwal. Untuk mengetahui informasi selengkapnya tentang parameter dalam template permintaan API, lihat dokumentasi untuk pipelineJobs.create. Perlu diingat bahwa Anda tidak dapat menentukan parameter pipelineJobId dalam template ini karena scheduler API tidak mendukung parameter ini.

Klik di sini untuk melihat contoh template permintaan API, dengan gs://gcs_directory sebagai bucket Cloud Storage untuk artefak output pipeline.

{
  "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"
    }
  }
}

Metode HTTP dan URL:

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

Isi JSON permintaan:

{
  "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
}

Untuk mengirim permintaan Anda, pilih salah satu opsi berikut:

curl

Catatan: Perintah berikut mengasumsikan bahwa Anda telah login ke CLI gcloud dengan akun pengguna Anda dengan menjalankan gcloud init atau gcloud auth login, atau menggunakan Cloud Shell, yang secara otomatis membuat Anda login ke CLI gcloud. Anda dapat memeriksa akun yang aktif saat ini dengan menjalankan gcloud auth list.

Simpan isi permintaan dalam file bernama request.json, dan jalankan perintah berikut:

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

Catatan: Perintah berikut mengasumsikan bahwa Anda telah login ke CLI gcloud dengan akun pengguna Anda dengan menjalankan gcloud init atau gcloud auth login. Anda dapat memeriksa akun yang aktif saat ini dengan menjalankan gcloud auth list.

Simpan isi permintaan dalam file bernama request.json, dan jalankan perintah berikut:

$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

Anda akan melihat output yang mirip dengan berikut ini. Anda dapat menggunakan SCHEDULE_ID dari respons untuk mengambil, menjeda, melanjutkan, atau menghapus jadwal. PIPELINE_JOB_CREATION_REQUEST merepresentasikan permintaan API untuk membuat tugas pipeline.

{
  "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

Anda dapat membuat jadwal proses pipeline dengan cara berikut:

Membuat jadwal berdasarkan PipelineJob menggunakan metode PipelineJob.create_schedule.
Membuat jadwal menggunakan metode PipelineJobSchedule.create.

Saat membuat jadwal operasi pipeline, Anda juga dapat meneruskan placeholder berikut yang didukung oleh SDK KFP sebagai input:

{{$.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}}

Untuk informasi selengkapnya, lihat Jenis input khusus dalam dokumentasi Kubeflow Pipelines v2.

Membuat jadwal dari `PipelineJob`

Gunakan contoh berikut untuk menjadwalkan proses pipeline menggunakan metode 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: Jalur ke file YAML pipeline yang dikompilasi. Ini dapat berupa jalur lokal atau Cloud Storage URI.

Opsional: Untuk menentukan versi template tertentu, sertakan tag versi beserta jalur dalam salah satu format berikut:
- COMPILED_PIPELINE_PATH:TAG, dengan TAG adalah tag versi.
- COMPILED_PIPELINE_PATH@SHA256_TAG, dengan SHA256_TAG adalah nilai hash sha256 dari versi pipeline.
PIPELINE_ROOT_PATH: (opsional) Untuk mengganti jalur root pipeline yang ditentukan dalam definisi pipeline, tentukan jalur yang dapat diakses tugas pipeline Anda, seperti URI bucket Cloud Storage.
DISPLAY_NAME: Nama pipeline. Nama ini akan muncul di konsol Google Cloud.
SCHEDULE_NAME: Nama jadwal pipeline. Anda dapat menentukan nama yang memiliki panjang maksimum 128 karakter UTF-8.
CRON: Ekspresi jadwal cron yang merepresentasikan frekuensi untuk menjadwalkan dan menjalankan proses pipeline. Untuk mengetahui informasi selengkapnya, lihat Cron.
MAX_CONCURRENT_RUN_COUNT: Jumlah maksimum proses serentak untuk jadwal.
MAX_RUN_COUNT: Jumlah maksimum proses pipeline yang dibuat oleh jadwal dan kemudian dijalankan.

Membuat jadwal menggunakan `PipelineJobSchedule.create`

Gunakan contoh berikut untuk menjadwalkan proses pipeline menggunakan metode 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: Jalur ke file YAML pipeline yang dikompilasi. Ini dapat berupa jalur lokal atau Cloud Storage URI.

Opsional: Untuk menentukan versi template tertentu, sertakan tag versi beserta jalur dalam salah satu format berikut:
- COMPILED_PIPELINE_PATH:TAG, dengan TAG adalah tag versi.
- COMPILED_PIPELINE_PATH@SHA256_TAG, dengan SHA256_TAG adalah nilai hash sha256 dari versi pipeline.
PIPELINE_ROOT_PATH: (opsional) Untuk mengganti jalur root pipeline yang ditentukan dalam definisi pipeline, tentukan jalur yang dapat diakses tugas pipeline Anda, seperti URI bucket Cloud Storage.
DISPLAY_NAME: Nama pipeline. Nama ini akan muncul di konsol Google Cloud.
SCHEDULE_NAME: Nama jadwal pipeline. Anda dapat menentukan nama yang memiliki panjang maksimum 128 karakter UTF-8.
CRON: Ekspresi jadwal cron yang merepresentasikan frekuensi untuk menjadwalkan dan menjalankan proses pipeline. Untuk mengetahui informasi selengkapnya, lihat Cron.
MAX_CONCURRENT_RUN_COUNT: Jumlah maksimum proses serentak untuk jadwal.
MAX_RUN_COUNT: Jumlah maksimum proses pipeline yang dibuat oleh jadwal dan kemudian dijalankan.

Membuat daftar jadwal

Anda dapat melihat daftar jadwal pipeline yang dibuat untuk project Google Cloud Anda.

Konsol

Anda dapat melihat daftar jadwal pipeline pada tab Jadwal di konsol Google Cloud untuk region yang dipilih.

Untuk melihat daftar jadwal pipeline, di konsol Google Cloud, di bagian Vertex AI, buka tab Jadwal di halaman Pipeline.

Buka Jadwal

REST

Untuk membuat daftar jadwal proses pipeline dalam project Anda, kirim permintaan GET menggunakan metode projects.locations.schedules.list.

Sebelum menggunakan salah satu data permintaan, lakukan penggantian berikut:

LOCATION: Region tempat Anda ingin menjalankan pipeline. Untuk mengetahui informasi selengkapnya tentang region yang menyediakan Vertex AI Pipelines, lihat panduan lokasi Vertex AI.
PROJECT_ID: Project Google Cloud tempat Anda ingin menjalankan pipeline.
FILTER: (opsional) Ekspresi untuk memfilter daftar jadwal. Untuk mengetahui informasi selengkapnya, lihat ...
PAGE_SIZE: (opsional) Jumlah jadwal yang akan dicantumkan per halaman.
PAGE_TOKEN: (opsional) Token halaman daftar standar, biasanya diperoleh melalui ListSchedulesResponse.next_page_token[] dari panggilan ScheduleService.ListSchedules[] sebelumnya.
ORDER_BY: (opsional) Daftar kolom yang dipisahkan koma, yang menunjukkan tata urutan jadwal dalam respons.

Metode HTTP dan URL:

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

Untuk mengirim permintaan Anda, pilih salah satu opsi berikut:

curl

Jalankan perintah berikut:

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

Jalankan perintah berikut:

$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

Anda akan melihat output yang mirip dengan berikut ini:

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

Python

Gunakan contoh berikut untuk menampilkan semua jadwal di project Anda dalam urutan menurun menurut waktu pembuatannya:

from google.cloud import aiplatform

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

DISPLAY_NAME: Nama jadwal pipeline. Anda dapat menentukan nama yang memiliki panjang maksimum 128 karakter UTF-8.

Mengambil jadwal

Anda dapat mengambil jadwal proses pipeline menggunakan ID jadwal.

REST

Untuk mengambil jadwal proses pipeline, kirim permintaan GET menggunakan metode projects.locations.schedules.get dan ID jadwal.

Sebelum menggunakan salah satu data permintaan, lakukan penggantian berikut:

LOCATION: Region tempat Anda ingin menjalankan pipeline. Untuk mengetahui informasi selengkapnya tentang region yang menyediakan Vertex AI Pipelines, lihat panduan lokasi Vertex AI.
PROJECT_ID: Project Google Cloud tempat Anda ingin menjalankan pipeline.
SCHEDULE_ID: ID jadwal unik yang dibuat saat membuat jadwal.

Metode HTTP dan URL:

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

Untuk mengirim permintaan Anda, pilih salah satu opsi berikut:

curl

Jalankan perintah berikut:

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

Jalankan perintah berikut:

$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

Anda akan melihat output yang mirip dengan berikut ini. PIPELINE_JOB_CREATION_REQUEST merepresentasikan permintaan API untuk membuat tugas pipeline.

{
  "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

Gunakan contoh berikut untuk mengambil jadwal proses pipeline menggunakan ID jadwal:

from google.cloud import aiplatform

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

SCHEDULE_ID: ID jadwal unik yang dibuat saat membuat jadwal.

Menjeda jadwal

Anda dapat menjeda jadwal pipeline yang aktif dengan menentukan ID jadwal. Saat Anda menjeda jadwal, statusnya akan berubah dari ACTIVE menjadi PAUSED.

Konsol

Anda dapat menjeda jadwal proses pipeline yang sedang aktif.

Gunakan petunjuk berikut untuk menjeda jadwal:

Di konsol Google Cloud, di bagian Vertex AI, buka tab Jadwal di halaman Pipeline.

Buka Jadwal
Buka menu opsi yang ada di baris yang sama dengan jadwal yang ingin Anda jeda, lalu klik Jeda. Anda dapat menjeda jadwal saat kolom Status menampilkan Aktif.

REST

Untuk menjeda jadwal proses pipeline dalam project Anda, kirim permintaan POST menggunakan metode projects.locations.schedules.pause.

Sebelum menggunakan salah satu data permintaan, lakukan penggantian berikut:

LOCATION: Region tempat jadwal proses pipeline sedang aktif. Untuk mengetahui informasi selengkapnya tentang region yang menyediakan Vertex AI Pipelines, lihat panduan lokasi Vertex AI.
PROJECT_ID: Project Google Cloud tempat jadwal proses pipeline sedang aktif.
SCHEDULE_ID: ID jadwal unik yang dibuat saat membuat jadwal.

Metode HTTP dan URL:

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

Untuk mengirim permintaan Anda, pilih salah satu opsi berikut:

curl

Jalankan perintah berikut:

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

Jalankan perintah berikut:

$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

Anda akan menerima kode status yang berhasil (2xx), serta respons yang kosong.

Python

Gunakan contoh berikut untuk menjeda jadwal proses pipeline:

from google.cloud import aiplatform

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

pipeline_job_schedule.pause()

SCHEDULE_ID: ID jadwal unik yang dibuat saat membuat jadwal.

Memperbarui jadwal

Anda dapat memperbarui jadwal pipeline yang ada yang telah dibuat untuk project Google Cloud Anda.

Memperbarui jadwal mirip dengan menghapus dan membuat ulang jadwal. Saat Anda memperbarui jadwal, proses baru akan dijadwalkan berdasarkan frekuensi pada jadwal yang diperbarui. Proses baru tidak lagi dibuat berdasarkan jadwal lama dan semua proses dalam antrean akan dihapus. Proses pipeline yang sudah dibuat oleh jadwal lama tidak dijeda atau dibatalkan.

REST

Untuk memperbarui jadwal proses pipeline dalam project Anda, kirim permintaan PATCH menggunakan metode projects.locations.schedules.patch.

Sebelum menggunakan data permintaan mana pun, lakukan penggantian berikut:

LOCATION: Region tempat Anda ingin menjalankan pipeline. Untuk mengetahui informasi selengkapnya tentang region yang menyediakan Vertex AI Pipelines, lihat panduan lokasi Vertex AI.
PROJECT_ID: Project Google Cloud tempat Anda ingin menjalankan pipeline.
DISPLAY_NAME: Nama jadwal pipeline. Anda dapat menentukan nama yang memiliki panjang maksimum 128 karakter UTF-8.
MAX_CONCURRENT_RUN_COUNT: Jumlah maksimum proses serentak untuk jadwal.

Metode HTTP dan 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}'

Untuk mengirim permintaan Anda, pilih salah satu opsi berikut:

curl

Jalankan perintah berikut:

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

Jalankan perintah berikut:

$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

Anda akan melihat output yang mirip dengan berikut ini. Berdasarkan update, NEXT_RUN_TIME dihitung ulang. Saat Anda memperbarui jadwal, START_TIME tidak akan berubah.

{
  "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

Gunakan contoh berikut untuk menjadwalkan proses pipeline menggunakan metode 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: ID jadwal unik yang dibuat saat membuat jadwal.
DISPLAY_NAME: Nama jadwal pipeline. Anda dapat menentukan nama yang memiliki panjang maksimum 128 karakter UTF-8.
MAX_CONCURRENT_RUN_COUNT: Jumlah maksimum proses serentak untuk jadwal.

Melanjutkan jadwal

Anda dapat melanjutkan jadwal pipeline yang dijeda dengan menentukan ID jadwal. Saat Anda melanjutkan jadwal, statusnya akan berubah dari PAUSED menjadi ACTIVE.

Konsol

Anda dapat melanjutkan jadwal proses pipeline yang sedang dijeda.

Gunakan petunjuk berikut untuk melanjutkan jadwal:

Di konsol Google Cloud, di bagian Vertex AI, buka tab Jadwal di halaman Pipeline.

Buka Jadwal
Buka menu opsi yang ada di baris yang sama dengan jadwal yang ingin Anda lanjutkan, lalu klik Lanjutkan. Anda dapat melanjutkan jadwal saat kolom Status menampilkan Dijeda.

REST

Untuk melanjutkan jadwal proses pipeline dalam project Anda, kirim permintaan POST menggunakan metode projects.locations.schedules.resume.

Sebelum menggunakan salah satu data permintaan, lakukan penggantian berikut:

LOCATION: Region tempat jadwal proses pipeline sedang dijeda. Untuk mengetahui informasi selengkapnya tentang region yang menyediakan Vertex AI Pipelines, lihat panduan lokasi Vertex AI.
PROJECT_ID: Project Google Cloud tempat jadwal proses pipeline sedang dijeda.
SCHEDULE_ID: ID jadwal unik yang dibuat saat membuat jadwal.
CATCH_UP: (Opsional) Menunjukkan apakah jadwal yang dijeda harus mengisi ulang proses pipeline yang dilewati. Untuk mengisi ulang dan menjadwalkan ulang proses pipeline yang dilewati, masukkan parameter berikut:
{ "catch_up":true } Secara default, parameter ini disetel ke `false`.

Metode HTTP dan URL:

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

Untuk mengirim permintaan Anda, pilih salah satu opsi berikut:

curl

Jalankan perintah berikut:

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

Jalankan perintah berikut:

$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

Anda akan menerima kode status yang berhasil (2xx), serta respons yang kosong.

Python

Gunakan contoh berikut untuk melanjutkan jadwal proses pipeline yang dijeda:

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: ID jadwal unik yang dibuat saat membuat jadwal.
CATCH_UP: (Opsional) Menunjukkan apakah jadwal yang dijeda harus mengisi ulang proses pipeline yang dilewati. Untuk mengisi ulang dan menjadwalkan ulang proses pipeline yang dilewati, masukkan parameter berikut:
{ "catch_up":true }

Menghapus jadwal

Anda dapat menghapus jadwal pipeline dengan menentukan ID jadwal.

Konsol

Anda dapat menghapus jadwal proses pipeline, apa pun statusnya.

Gunakan petunjuk berikut untuk menghapus jadwal:

Di konsol Google Cloud, di bagian Vertex AI, buka tab Jadwal di halaman Pipeline.

Buka Jadwal
Buka menu opsi yang ada di baris yang sama dengan jadwal yang ingin Anda hapus, lalu klik Hapus.
Untuk mengonfirmasi penghapusan, klik Hapus.

REST

Untuk menghapus jadwal proses pipeline dalam project Anda, kirim permintaan DELETE menggunakan metode projects.locations.schedules.delete.

Sebelum menggunakan data permintaan mana pun, lakukan penggantian berikut:

LOCATION: Region tempat Anda ingin menghapus jadwal pipeline. Untuk mengetahui informasi selengkapnya tentang region yang menyediakan Vertex AI Pipelines, lihat panduan lokasi Vertex AI.
PROJECT_ID: Project Google Cloud yang ingin Anda hapus jadwalnya.
SCHEDULE_ID: ID jadwal unik yang dibuat saat membuat jadwal.

Metode HTTP dan URL:

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

Untuk mengirim permintaan Anda, pilih salah satu opsi berikut:

curl

Jalankan perintah berikut:

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

Jalankan perintah berikut:

$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

Anda akan melihat output yang mirip dengan berikut ini. OPERATION_ID merepresentasikan operasi penghapusan.

{
  "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

Gunakan contoh berikut untuk menghapus jadwal proses pipeline:

from google.cloud import aiplatform

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

pipeline_job_schedule.delete()

SCHEDULE_ID: ID jadwal unik yang dibuat saat membuat jadwal.

Menampilkan semua tugas pipeline yang dibuat berdasarkan jadwal

Anda dapat melihat daftar semua tugas pipeline yang dibuat berdasarkan jadwal dengan menentukan ID jadwal.

REST

Untuk menampilkan semua proses pipeline yang telah dibuat berdasarkan jadwal pipeline, kirim permintaan GET menggunakan metode projects.locations.pipelineJobs.

Sebelum menggunakan salah satu data permintaan, lakukan penggantian berikut:

LOCATION: Region tempat Anda ingin menjalankan pipeline. Untuk mengetahui informasi selengkapnya tentang region yang menyediakan Vertex AI Pipelines, lihat panduan lokasi Vertex AI.
PROJECT_ID: Project Google Cloud tempat Anda ingin menjalankan pipeline.
SCHEDULE_ID: ID jadwal unik yang dibuat saat membuat jadwal.

Metode HTTP dan URL:

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

Untuk mengirim permintaan Anda, pilih salah satu opsi berikut:

curl

Jalankan perintah berikut:

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

Jalankan perintah berikut:

$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

Anda akan melihat output yang mirip dengan berikut ini.

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

Python

Gunakan contoh berikut untuk menampilkan semua tugas pipeline yang dibuat berdasarkan jadwal dalam urutan menurun menurut waktu pembuatannya:

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: ID jadwal unik yang dibuat saat membuat jadwal.

Menjadwalkan proses pipeline dengan scheduler API

Sebelum memulai

Membuat jadwal

Konsol

REST

curl

PowerShell

Python

Membuat jadwal dari PipelineJob

Membuat jadwal menggunakan PipelineJobSchedule.create

Membuat daftar jadwal

Konsol

REST

curl

PowerShell

Python

Mengambil jadwal

REST

curl

PowerShell

Python

Menjeda jadwal

Konsol

REST

curl

PowerShell

Python

Memperbarui jadwal

REST

curl

PowerShell

Python

Melanjutkan jadwal

Konsol

REST

curl

PowerShell

Python

Menghapus jadwal

Konsol

REST

curl

PowerShell

Python

Menampilkan semua tugas pipeline yang dibuat berdasarkan jadwal

REST

curl

PowerShell

Python

Membuat jadwal dari `PipelineJob`

Membuat jadwal menggunakan `PipelineJobSchedule.create`