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。

此條目有幫助嗎?