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

模块内容¶

类¶

`ComprehendPiiEntitiesDetectionJobCompletedTrigger`	当 Comprehend pii 实体检测作业完成时触发。
`ComprehendCreateDocumentClassifierCompletedTrigger`	当 Comprehend 文档分类器完成时触发。

class airflow.providers.amazon.aws.triggers.comprehend.ComprehendPiiEntitiesDetectionJobCompletedTrigger(*, job_id, waiter_delay=120, waiter_max_attempts=75, aws_conn_id='aws_default')[源代码]¶

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

当 Comprehend pii 实体检测作业完成时触发。

参数

job_id (str) – Comprehend pii 实体检测作业的 ID。
waiter_delay (int) – 两次尝试之间等待的秒数。（默认：120）
waiter_max_attempts (int) – 要进行的最大尝试次数。（默认：75）
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。

hook()[源代码]¶

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

class airflow.providers.amazon.aws.triggers.comprehend.ComprehendCreateDocumentClassifierCompletedTrigger(*, document_classifier_arn, waiter_delay=120, waiter_max_attempts=75, aws_conn_id='aws_default')[源代码]¶