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')[来源]¶

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

当 Comprehend 文档分类器完成时触发。

参数：

document_classifier_arn (str) – Comprehend 文档分类器的 ARN。
waiter_delay (int) – 两次尝试之间等待的时间（秒）。(默认值: 120)
waiter_max_attempts (int) – 最大尝试次数。(默认值: 75)
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。

hook()[来源]¶

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