airflow.providers.amazon.aws.operators.mwaa¶
此模組包含 AWS MWAA operators。
類¶
在 Amazon MWAA 環境中觸發 Dag Run。 |
模組內容¶
- class airflow.providers.amazon.aws.operators.mwaa.MwaaTriggerDagRunOperator(*, env_name, trigger_dag_id, trigger_run_id=None, logical_date=None, data_interval_start=None, data_interval_end=None, conf=None, note=None, wait_for_completion=False, waiter_delay=60, waiter_max_attempts=20, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[原始碼]¶
基類：
airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator[airflow.providers.amazon.aws.hooks.mwaa.MwaaHook]在 Amazon MWAA 環境中觸發 Dag Run。
另請參閱
有關如何使用此 operator 的更多資訊，請參閱指南： 在 Amazon MWAA 環境中觸發 DAG 執行
- 引數：
env_name (str) – MWAA 環境名稱 (templated)
trigger_dag_id (str) – 要觸發的 DAG ID (templated)
trigger_run_id (str | None) – 執行 ID。此引數與 trigger_dag_id 一起構成唯一鍵。(templated)
logical_date (str | None) – 邏輯日期（之前稱為執行日期）。這是此 DAG 執行涵蓋的時間或間隔，取決於 DAG 定義。此引數與 trigger_dag_id 一起構成唯一鍵。(templated)
data_interval_start (str | None) – DAG 執行涵蓋的時間間隔的開始
data_interval_end (str | None) – DAG 執行涵蓋的時間間隔的結束
conf (dict | None) – 附加配置引數。此欄位的值只能在建立物件時設定。(templated)
note (str | None) – 包含使用者關於 DagRun 手動輸入的備註。(templated)
wait_for_completion (bool) – 是否等待 DAG 執行停止。(預設值：False)
waiter_delay (int) – 狀態檢查之間的等待時間，單位為秒。(預設值：120)
waiter_max_attempts (int) – 檢查 DAG 執行完成的最大嘗試次數。(預設值：720)
deferrable (bool) – 如果為 True，則 operator 將非同步等待 DAG 執行停止。這意味著等待完成。此模式需要安裝 aiobotocore 模組。(預設值：False)
aws_conn_id – 用於 AWS 憑據的 Airflow 連線。如果此引數為
None或為空，則使用預設的 boto3 行為。如果在分散式環境中執行 Airflow 且 aws_conn_id 為 None 或為空，則將使用預設的 boto3 配置（並且必須在每個 worker 節點上維護）。region_name – AWS region_name。如果未指定，則使用預設的 boto3 行為。
verify – 是否驗證 SSL 證書。參見： https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html
botocore_config – botocore 客戶端的配置字典（鍵值對）。參見： https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html
- template_fields: collections.abc.Sequence[str][原始碼]¶