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。