Mengonfigurasi notifikasi email

Gemini Enterprise Agent Platform Pipelines dapat memberi tahu Anda terkait keberhasilan atau kegagalan operasi pipeline. Saat pipeline dihentikan, Google Cloud akan mengirimkan email notifikasi status akhir ke alamat email yang Anda tentukan.

Panduan ini menunjukkan cara mengonfigurasi notifikasi email dari pipeline menggunakan Komponen notifikasi email di Google Cloud SDK.

Sebelum memulai

Sebelum Anda mem-build pipeline yang mengirimkan notifikasi, gunakan petunjuk berikut untuk menyiapkan project dan lingkungan pengembangan Anda Google Cloud .

  1. Agar Google Cloud project Anda siap menjalankan pipeline ML, ikuti petunjuk dalam panduan untuk mengonfigurasi Google Cloud project.

  2. Instal Kubeflow Pipelines SDK v2 atau yang lebih baru.

    pip install --upgrade "kfp>=2,<3"

  1. Untuk menggunakan klien Python Gemini Enterprise Agent Platform di pipeline Anda, instal library klien Gemini Enterprise Agent Platform v1.7 atau yang lebih baru.

  2. Untuk menggunakan layanan Gemini Enterprise Agent Platform di pipeline Anda, instal Google Cloud Komponen Pipeline.

Mengirim notifikasi dari pipeline

Contoh berikut menunjukkan cara mengonfigurasi notifikasi email dengan menentukan tugas notifikasi email (notify_email_task) dan menambahkannya ke pengendali penghentian pipeline (dsl.ExitHandler). Tugas notifikasi ini memanggil operator VertexNotificationEmailOp di komponen notifikasi email saat pipeline dihentikan.

from kfp import dsl
from kfp import compiler
from google_cloud_pipeline_components.v1.vertex_notification_email import VertexNotificationEmailOp

@dsl.pipeline(
    name='PIPELINE_NAME',
    pipeline_root=PIPELINE_ROOT_PATH,
)
def TASK_NAME():
    notify_email_task = VertexNotificationEmailOp(recipients=RECIPIENTS_LIST)

    with dsl.ExitHandler(notify_email_task):
        # Add your pipeline tasks here.

compiler.Compiler().compile(pipeline_func=notification_email_pipeline,
        package_path='notification_email_pipeline.yaml')

Ganti kode berikut:

  • PIPELINE_NAME: Nama pipeline.

  • PIPELINE_ROOT_PATH: Menentukan Cloud Storage URI yang dapat diakses oleh akun layanan pipeline. Artefak operasi pipeline disimpan di dalam root pipeline.

    Root pipeline dapat ditetapkan sebagai argumen anotasi @kfp.dsl.pipeline pada fungsi pipeline, atau dapat ditetapkan saat Anda memanggil create_run_from_job_spec untuk membuat operasi pipeline.

  • TASK_NAME: Nama tugas pipeline tempat Anda mengonfigurasi notifikasi email.

  • RECIPIENTS_LIST: Daftar yang dipisahkan koma yang berisi maksimum tiga alamat email yang akan dikirimi email notifikasi.

Tambahkan tugas pipeline dalam isi fungsi pengendali penghentian dsl.ExitHandler. Dengan menggabungkan tugas di fungsi pengendali penghentian menggunakan cara ini, Anda menentukan bahwa komponen email notifikasi harus melaporkan status tugas ini saat pipeline dihentikan. Misalnya, jika tugas dalam konten pengendali penghentian gagal, notifikasi akan melaporkan statusnya sebagai gagal.

Contoh email notifikasi

Jika Anda mengonfigurasi notifikasi email untuk pipeline menggunakan contoh kode di bagian Mengirim notifikasi dari pipeline, Gemini Enterprise Agent Platform akan mengirimkan notifikasi email seperti berikut ini saat pipeline dihentikan:

Subject: Vertex Pipelines job "PIPELINE_NAME" task "TASK_NAME"
From: Google Notifications <notify-noreply@google.com>

Hello Agent Platform Customer,

Gemini Enterprise Agent Platform Pipelines job "PIPELINE_NAME" task "TASK_NAME" ended with the following state: {status}.

Additional details:
- Project: {project}
- Pipeline name: PIPELINE_NAME
- Pipeline job ID: {pipeline_job_id}
- Start time: {start_time}

To view this pipeline job in Cloud Console, use the following link: {console_link}

Sincerely,
The Google Cloud AI Team

Dalam contoh ini:

  • {status} menunjukkan status akhir tugas, yang dapat berupa SUCCEEDED, FAILED, atau CANCELLED.
  • {project} adalah nama project.
  • {pipeline_job_id} adalah ID tugas pipeline unik.
  • {start_time} menunjukkan waktu mulai untuk pipeline.
  • {console_link} adalah hyperlink ke tugas pipeline di Google Cloud konsol.