הגדרת התראות באימייל

צינורות של Gemini Enterprise Agent Platform יכולים לשלוח לכם הודעה על הצלחה או על כישלון של הרצת צינור. כשהצינור יוצא, Google Cloud נשלחת הודעת סטטוס סופית באימייל לכתובות האימייל שציינתם.

במדריך הזה מוסבר איך להגדיר התראות באימייל מצינור עיבוד נתונים באמצעות רכיב ההתראות באימייל ב- Google Cloud SDK.

הערה: Google שומרת את כתובות האימייל שאליהן אתם שולחים התראות למשך עד 14 ימים למטרות ניפוי באגים ו-30 ימים למטרות ניתוח נתונים.

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

לפני שיוצרים צינור עיבוד נתונים לשליחת התראות, צריך להגדיר את Google Cloud הפרויקט ואת סביבת הפיתוח.

1. כדי להכין את Google Cloud הפרויקט להרצת צינורות ML, פועלים לפי ההוראות במדריך בנושא הגדרתGoogle Cloud הפרויקט.

2. מתקינים את גרסה 2 ואילך של Kubeflow Pipelines SDK.

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

הערה: כדי לשדרג לגרסה העדכנית של Kubeflow Pipelines SDK, מריצים את הפקודה הבאה:
pip install kfp --upgrade
אם יש גרסה עדכנית, הפעלת הפקודה הזו תגרום להסרת KFP ולהתקנת הגרסה העדכנית.\

1. כדי להשתמש בלקוח Python של Gemini Enterprise Agent Platform בצינורות שלכם, צריך להתקין את ספריות הלקוח של Gemini Enterprise Agent Platform בגרסה 1.7 ואילך.

2. כדי להשתמש בשירותי Gemini Enterprise Agent Platform בצינורות שלכם, צריך להתקין אתGoogle Cloud Pipeline Components.

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

בדוגמה הבאה מוצג איך להגדיר התראות באימייל על ידי הגדרת משימת התראה באימייל (notify_email_task) והוספתה ל-exit handler של צינור הנתונים (dsl.ExitHandler). משימת ההתראה הזו מפעילה את האופרטור VertexNotificationEmailOp ברכיב ההתראה באימייל כשהצינור יוצא.

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')

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

• ‫PIPELINE_NAME: השם של צינור העברת הנתונים.

• ‫PIPELINE_ROOT_PATH: מציינים URI של Cloud Storage שחשבון השירות של צינורות העיבוד יכול לגשת אליו. פריטי המידע של הרצות הצינור מאוחסנים בתיקיית הבסיס של הצינור.

  אפשר להגדיר את שורש צינור עיבוד הנתונים כארגומנט של ההערה @kfp.dsl.pipeline בפונקציית צינור עיבוד הנתונים, או להגדיר אותו כשמפעילים את הפונקציה create_run_from_job_spec כדי ליצור הפעלה של צינור עיבוד הנתונים.

• ‫TASK_NAME: השם של משימת צינור עיבוד הנתונים שרוצים להגדיר עבורה התראות באימייל.

• ‫RECIPIENTS_LIST: רשימה מופרדת בפסיקים של עד שלוש כתובות אימייל שאליהן יישלח האימייל עם ההתראה.

מוסיפים את המשימות של צינור עיבוד הנתונים בגוף של dsl.ExitHandler פונקציית הטיפול ביציאה. כשעוטפים את המשימות בפונקציית הטיפול ביציאה בצורה הזו, מציינים שרכיב האימייל של ההתראה צריך לדווח על הסטטוס של המשימות האלה כשהצינור יוצא. לדוגמה, אם משימה בתוכן של ה-exit handler נכשלת, ההתראה מדווחת על הסטטוס כנכשל.

דוגמה לאימייל עם התראה

אם מגדירים התראות באימייל לפייפליין באמצעות דוגמת הקוד שמופיעה במאמר שליחת התראה מצינור, Gemini Enterprise Agent Platform שולחת התראה באימייל שדומה לזו שמופיעה בהמשך כשהצינור יוצא:

נושא: משימה 'TASK_NAME' בעבודה 'PIPELINE_NAME' ב-Vertex Pipelines
מאת: Google Notifications <[e-mail]>

שלום ללקוח של Agent Platform,

המשימה 'TASK_NAME' בעבודה 'PIPELINE_NAME' ב-Gemini Enterprise Agent Platform Pipelines הסתיימה עם המצב הבא: {status}.

פרטים נוספים:
– פרויקט: {project}
– שם הצינור: PIPELINE_NAME
– מזהה משימת הצינור: {pipeline_job_id}
– שעת התחלה: {start_time}

כדי לראות את משימת הצינור הזו במסוף Cloud, אפשר להשתמש בקישור הבא: {console_link}

בברכה,
צוות Google Cloud AI

בדוגמה הזו:

• ‫{status}: המצב הסופי של המשימה, שיכול להיות SUCCEEDED, ‏FAILED או CANCELLED.
• ‫{project} הוא שם הפרויקט.
• ‫{pipeline_job_id} הוא המזהה הייחודי של משימת הצינור.
• ‫{start_time} מייצג את שעת ההתחלה של הצינור.
• ‫{console_link} הוא היפר-קישור למשימת הצינור במסוף Google Cloud .