如何使用 Boto3 在 AWS Glue 資料目錄中啟動工作流


在本文中,我們將瞭解使用者如何在 AWS Glue 資料目錄中啟動工作流。

示例

問題陳述:使用 Python 中的 boto3 庫啟動工作流。

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

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

  • 步驟 2:workflow_name 是此函式中的引數。

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

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

  • 步驟 5:現在使用 start_workflow_run 函式並將引數 workflow_name 作為 Name 傳遞。

  • 步驟 6:它返回 RunId 和響應元資料並啟動工作流。

  • 步驟 7:如果啟動工作流時出現問題,則處理通用異常。

示例程式碼

以下程式碼啟動工作流:

import boto3
from botocore.exceptions import ClientError

def start_a_workflow(workflow_name)
   session = boto3.session.Session()
   glue_client = session.client('glue')
   try:
      response = glue_client.start_workflow_run(Name=workflow_name)
      return response
   except ClientError as e:
      raise Exception("boto3 client error in start_a_workflow: " + e.__str__())
   except Exception as e:
      raise Exception("Unexpected error in start_a_workflow: " + e.__str__())
print(start_a_workflow("test-daily"))

輸出

{'RunId': 'wr_64e880240692fddd5e1b19aed587f856bc20a96f54bc', 'ResponseMetadata': {'RequestId': '782e953b-8ee3-4876-9b2c-cd35e147b513', 'HTTPStatusCode': 200, 'HTTPHeaders': {'date': 'Sun, 28 Mar 2021 08:11:02 GMT', 'content-type': 'application/x-amz-json-1.1', 'content-length': '79', 'connection': 'keep-alive', 'x-amzn-requestid': '782e953b-********************************13'}, 'RetryAttempts': 0}}

更新於:2021年4月15日

661 次瀏覽

啟動您的職業生涯

完成課程獲得認證

開始學習
廣告