airflow.providers.amazon.aws.triggers.bedrock¶

類¶

`BedrockCustomizeModelCompletedTrigger`	當 Bedrock 模型定製作業完成時觸發。
`BedrockKnowledgeBaseActiveTrigger`	當 Bedrock 知識庫達到 ACTIVE 狀態時觸發。
`BedrockProvisionModelThroughputCompletedTrigger`	當預置吞吐量作業完成時觸發。
`BedrockIngestionJobTrigger`	當 Bedrock 資料攝取作業達到 COMPLETE 狀態時觸發。
`BedrockBaseBatchInferenceTrigger`	當批次推理作業完成時觸發。
`BedrockBatchInferenceCompletedTrigger`	當批次推理作業完成時觸發。
`BedrockBatchInferenceScheduledTrigger`	當批次推理作業已排程時觸發。

模組內容¶

class airflow.providers.amazon.aws.triggers.bedrock.BedrockCustomizeModelCompletedTrigger(*, job_name, waiter_delay=120, waiter_max_attempts=75, aws_conn_id=None)[source]¶

繼承自: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

當 Bedrock 模型定製作業完成時觸發。

引數：:

job_name (str) – Bedrock 模型定製作業的名稱。
waiter_delay (int) – 每次嘗試之間等待的時間間隔（秒）。 (預設值: 120)
waiter_max_attempts (int) – 最大嘗試次數。 (預設值: 75)
aws_conn_id (str | None) – 用於 AWS 憑據的 Airflow 連線。

hook()[source]¶

在子類中重寫以返回正確的 hook。

class airflow.providers.amazon.aws.triggers.bedrock.BedrockKnowledgeBaseActiveTrigger(*, knowledge_base_id, waiter_delay=5, waiter_max_attempts=24, aws_conn_id=None)[source]¶

繼承自: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

當 Bedrock 知識庫達到 ACTIVE 狀態時觸發。

引數：:

knowledge_base_id (str) – 要獲取資訊的知識庫的唯一識別符號。
waiter_delay (int) – 每次嘗試之間等待的時間間隔（秒）。 (預設值: 5)
waiter_max_attempts (int) – 最大嘗試次數。 (預設值: 24)
aws_conn_id (str | None) – 用於 AWS 憑據的 Airflow 連線。

hook()[source]¶

在子類中重寫以返回正確的 hook。

class airflow.providers.amazon.aws.triggers.bedrock.BedrockProvisionModelThroughputCompletedTrigger(*, provisioned_model_id, waiter_delay=120, waiter_max_attempts=75, aws_conn_id=None)[source]¶

繼承自: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

當預置吞吐量作業完成時觸發。

引數：:

provisioned_model_id (str) – 預置吞吐量的 ARN 或名稱。
waiter_delay (int) – 每次嘗試之間等待的時間間隔（秒）。 (預設值: 120)
waiter_max_attempts (int) – 最大嘗試次數。 (預設值: 75)
aws_conn_id (str | None) – 用於 AWS 憑據的 Airflow 連線。

hook()[source]¶

在子類中重寫以返回正確的 hook。

class airflow.providers.amazon.aws.triggers.bedrock.BedrockIngestionJobTrigger(*, knowledge_base_id, data_source_id, ingestion_job_id, waiter_delay=60, waiter_max_attempts=10, aws_conn_id=None)[source]¶

繼承自: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

當 Bedrock 資料攝取作業達到 COMPLETE 狀態時觸發。

引數：:

knowledge_base_id (str) – 要獲取資訊的知識庫的唯一識別符號。
data_source_id (str) – 資料攝取作業中資料來源的唯一識別符號。
ingestion_job_id (str) – 資料攝取作業的唯一識別符號。
waiter_delay (int) – 每次嘗試之間等待的時間間隔（秒）。 (預設值: 60)
waiter_max_attempts (int) – 最大嘗試次數。 (預設值: 10)
aws_conn_id (str | None) – 用於 AWS 憑據的 Airflow 連線。

hook()[source]¶

在子類中重寫以返回正確的 hook。

class airflow.providers.amazon.aws.triggers.bedrock.BedrockBaseBatchInferenceTrigger(*, job_arn, waiter_name=NOTSET, waiter_delay=120, waiter_max_attempts=75, aws_conn_id=None)[source]¶

繼承自: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

當批次推理作業完成時觸發。

引數：:

job_arn (str) – 批次推理作業的 Amazon 資源名稱 (ARN)。
waiter_delay (int) – 每次嘗試之間等待的時間間隔（秒）。 (預設值: 120)
waiter_max_attempts (int) – 最大嘗試次數。 (預設值: 75)
aws_conn_id (str | None) – 用於 AWS 憑據的 Airflow 連線。

hook()[source]¶

在子類中重寫以返回正確的 hook。

class airflow.providers.amazon.aws.triggers.bedrock.BedrockBatchInferenceCompletedTrigger(*, job_arn, waiter_delay=120, waiter_max_attempts=75, aws_conn_id=None)[source]¶

繼承自: BedrockBaseBatchInferenceTrigger

當批次推理作業完成時觸發。

引數：:

job_arn (str) – 批次推理作業的 Amazon 資源名稱 (ARN)。
waiter_delay (int) – 每次嘗試之間等待的時間間隔（秒）。 (預設值: 120)
waiter_max_attempts (int) – 最大嘗試次數。 (預設值: 75)
aws_conn_id (str | None) – 用於 AWS 憑據的 Airflow 連線。

class airflow.providers.amazon.aws.triggers.bedrock.BedrockBatchInferenceScheduledTrigger(*, job_arn, waiter_delay=120, waiter_max_attempts=75, aws_conn_id=None)[source]¶

繼承自: BedrockBaseBatchInferenceTrigger

當批次推理作業已排程時觸發。

引數：:

job_arn (str) – 批次推理作業的 Amazon 資源名稱 (ARN)。
waiter_delay (int) – 每次嘗試之間等待的時間間隔（秒）。 (預設值: 120)
waiter_max_attempts (int) – 最大嘗試次數。 (預設值: 75)
aws_conn_id (str | None) – 用於 AWS 憑據的 Airflow 連線。