更新通知API設置崗位的工作

您可以使用工作API添加郵件通知,在您的工作區或所有的工作。

寫的manoj.hegde

去年發表在:2023年3月17日

郵件通知管理多個工作時很有用。如果你有很多工作沒有通知,配置手動添加通知可以耗費時間。相反,您可以使用喬布斯API(AWS|Azure|GCP)郵件通知添加到工作區中的工作。

指令

為了調用API的工作,首先需要設置一個個人訪問令牌和一個秘密的範圍。這允許您通過一個腳本與API進行交互。

秘密範圍被設置之後,您可以運行一個筆記本中的示例腳本更新您的工作區中所有的工作。

創建一個磚個人訪問令牌

遵循個人用戶訪問令牌(AWS|Azure|GCP)的文檔創建一個個人訪問令牌。

創建一個秘密範圍

遵循創建一個Databricks-backed秘密範圍(AWS|Azure|GCP)文檔創建秘密範圍。

你的個人訪問令牌和磚實例存儲在保密範圍

遵循創建一個秘密Databricks-backed範圍(AWS|Azure|GCP)文檔存儲個人訪問令牌和磚實例創建新的秘密範圍內你的秘密。

磚實例是工作空間的主機名,例如,xxxxx.cloud.m.eheci.com。

使用一個Python腳本更新工作的通知在工作區中所有的工作

你需要運行腳本之前替換以下值:

<電子郵件地址>——電子郵件地址通知。
< scope-name >——你的名字包含秘密範圍。
< secret-name-1 >——秘密的名字會握著你的磚實例。
< secret-name-2 >——秘密的名稱保存你的個人訪問令牌。

進口json進口API_URL = dbutils.secrets請求。get(範圍= " < scope-name >”,關鍵= < secret-name1 >)令牌= dbutils.secrets。get(範圍= " < scope-name >”,關鍵= < secret-name2 >) url = f”{API_URL} / api / 2.0 /工作/列表”#得到在工作區中創建的所有工作負載= {}header ={“授權”:“持票人”+牌}=請求響應。請求(“獲得”,url,頭=頭,data =有效負載)response.json response.json()工作()['工作']:job_id =工作(“job_id”)有效載荷= {“job_id”: job_id,“new_settings”: {“email_notifications”: {“on_start”:[" <郵件地址>”#用戶的電子郵件ID],“on_success”:“<郵件地址>”,“on_failure”:(“<郵件地址>”)}}}url2 = f“{API_URL} / api / 2.1 /工作/更新”r =請求。帖子(url2, data = json.dumps(載荷),頭=頭)打印(“成功添加了email_notification工作”)

刪除

信息

你可以修改示例腳本添加額外的過濾選項如果你不想添加通知所有工作。例如,您可以根據就業創造者和過濾器隻通知添加到過濾工作。

這個版本的示例代碼添加了一個如果條件,檢查電子郵件地址值creator_user_name。這個過濾器的工作基於工作的創造者。

取代< job-creator-email-address >你想過濾電子郵件地址。

進口json進口API_URL = dbutils.secrets請求。get(範圍= " < scope-name >”,關鍵= < secret-name1 >)令牌= dbutils.secrets。get(範圍= " < scope-name >”,關鍵= < secret-name2 >) url = f”{API_URL} / api / 2.0 /工作/列表”#得到在工作區中創建的所有工作負載= {}header ={“授權”:“持票人”+牌}=請求響應。請求(“獲得”,url,頭=頭,data =有效負載)response.json response.json()工作()['工作']:如果工作[' creator_user_name '] = = < job-creator-email-address >: #過濾的工作基於就業創造者job_id =工作(“job_id”)有效載荷= {“job_id”: job_id new_settings ": {" email_notifications ": {“on_start”:[" <郵件地址>”#用戶的電子郵件ID],“on_success”:“<郵件地址>”,“on_failure”:(“<郵件地址>”)}}}url2 = f“{API_URL} / api / 2.1 /工作/更新”r =請求。帖子(url2, data = json.dumps(載荷),頭=頭)打印(“成功添加了email_notification工作”)