airflow.providers.amazon.aws.hooks.glue_databrew

類

GlueDataBrewHook

與 AWS DataBrew 互動。

模組內容

class airflow.providers.amazon.aws.hooks.glue_databrew.GlueDataBrewHook(*args, **kwargs)[source]

基類：airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

與 AWS DataBrew 互動。

可以指定額外的引數（如 aws_conn_id），這些引數會向下傳遞給底層的 AwsBaseHook。

另請參閱

job_completion(job_name, run_id, delay=10, max_attempts=60)[source]

等待 Glue DataBrew 作業達到終端狀態。

引數：

  • job_name (str) – 本次執行中正在處理的作業名稱。

  • run_id (str) – 作業執行的唯一識別符號。

  • delay (int) – 輪詢之間的延遲時間（秒）。

  • maxAttempts – 輪詢完成的最大嘗試次數。

返回：

作業狀態

返回型別：

str

get_job_state(job_name, run_id)[source]

獲取作業執行的狀態。

引數：

  • job_name (str) – 本次執行中正在處理的作業名稱。

  • run_id (str) – 作業執行的唯一識別符號。

返回：

作業執行的狀態。'STARTING'|'RUNNING'|'STOPPING'|'STOPPED'|'SUCCEEDED'|'FAILED'|'TIMEOUT'

返回型別：

str

此條目有幫助嗎？