如何使用 Boto3 從 AWS Glue 資料目錄獲取與作業關聯的所有觸發器的詳細資訊


在本文中,我們將瞭解使用者如何從 AWS Glue 資料目錄獲取與作業關聯的所有觸發器的詳細資訊。

示例

獲取與作業“employee_details”關聯的所有觸發器的詳細資訊。

問題陳述:使用 Python 中的 boto3 庫獲取與作業關聯的所有觸發器的詳細資訊。

解決此問題的方法/演算法

  • 步驟 1:匯入 boto3botocore 異常以處理異常。

  • 步驟 2:job_name 是此函式的可選引數。如果提供了 job_name,它將檢索與同一作業關聯的所有觸發器,並且可以啟動此作業。但是,如果沒有此類觸發器,它將返回所有觸發器。預設值為 None,因此,如果在呼叫此函式時未傳遞 job_name,它將返回所有觸發器的詳細資訊。

  • 步驟 3:使用 boto3 lib 建立 AWS 會話。確保在預設配置檔案中提到了 region_name。如果未提及,則在建立會話時顯式傳遞 region_name

  • 步驟 4:glue 建立 AWS 客戶端。

  • 步驟 5:呼叫 get_triggers 並將 job_name 作為 DependentJobName 傳遞。

  • 步驟 6:它返回與此作業關聯的觸發器的詳細資訊。

  • 步驟 7:如果在檢查作業時出現錯誤,則處理通用異常。

示例程式碼

以下程式碼獲取與作業關聯的所有觸發器的詳細資訊:

import boto3
from botocore.exceptions import ClientError

def get_details_of_triggers(job_name=None):
   session = boto3.session.Session()
   glue_client = session.client('glue')
   try:
      response = glue_client.get_triggers(DependentJobName=job_name)
      return response
   except ClientError as e:
      raise Exception("boto3 client error in get_details_of_triggers: " + e.__str__())
   except Exception as e:
      raise Exception("Unexpected error in get_details_of_triggers: " + e.__str__())
a = get_details_of_triggers('employee_details')
print(a)

輸出

{'Triggers': [{'Name': '01_PythonShellTest1', 'WorkflowName': 'arn:aws:iam::1234:role/dev-edl, 'Id': 'string', 'Type': 'SCHEDULED'|'CONDITIONAL'|'ON_DEMAND', 'State': 'CREATING'|'CREATED'|'ACTIVATING'|'ACTIVATED'|'DEACTIVATING'|'DEACTIVATED'|'DELETING'|'UPDATING', 'Description': 'string', 'Schedule': 'string'
}]}

更新於: 2021年4月15日

318 次檢視

開啟你的 職業生涯

透過完成課程獲得認證

開始學習
廣告

© . All rights reserved.