`airflow.providers.amazon.aws.triggers.glue_databrew`¶

模块内容¶

类¶

GlueDataBrewJobCompleteTrigger

监视 Glue DataBrew 作业，并在其完成时触发。

class airflow.providers.amazon.aws.triggers.glue_databrew.GlueDataBrewJobCompleteTrigger(job_name, run_id, waiter_delay=30, waiter_max_attempts=60, aws_conn_id='aws_default', **kwargs)[源代码]¶

基类：airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

监视 Glue DataBrew 作业，并在其完成时触发。

参数

job_name (str) – Glue DataBrew 作业名称
run_id (str) – 要监视的特定作业运行的 ID
waiter_delay (int) – 两次检查之间等待的秒数。默认为 30 秒。
waiter_max_attempts (int) – 等待作业完成的最大尝试次数。默认为 60 次尝试。
aws_conn_id (str | None) – 用于 AWS 凭证的 Airflow 连接。

hook()[源代码]¶

在子类中重写以返回正确的 hook。

airflow.providers.amazon.aws.triggers.glue_databrew¶

模块内容¶

类¶

`airflow.providers.amazon.aws.triggers.glue_databrew`¶