AWS CloudFormation¶

AWS CloudFormation 使您能夠可預測且重複地建立和預置 AWS 基礎設施部署。它幫助您利用 Amazon EC2、Amazon Elastic Block Store、Amazon SNS、Elastic Load Balancing 和 Auto Scaling 等 AWS 產品在雲中構建高可靠、高可擴充套件、經濟高效的應用程式，而無需擔心建立和配置底層 AWS 基礎設施。AWS CloudFormation 使您可以使用模板檔案將資源集合作為一個單元（一個堆疊）建立和刪除。

先決任務¶

要使用這些 Operator，您需要完成幾項任務

使用 AWS Console 或 AWS CLI 建立必要的資源。
透過 pip 安裝 API 庫。
pip install 'apache-airflow[amazon]'
詳細資訊請參閱安裝 Airflow®
設定連線.

通用引數¶

aws_conn_id

Amazon Web Services 連線 ID 的引用。如果此引數設定為 None，則使用預設的 boto3 行為，不進行連線查詢。否則，使用 Connection 中儲存的憑證。預設值: aws_default

region_name

AWS 區域名稱。如果此引數設定為 None 或省略，則使用 AWS 連線 Extra Parameter 中的 region_name。否則，使用指定的值而不是連線值。預設值: None

verify

是否驗證 SSL 證書。

False - 不驗證 SSL 證書。
path/to/cert/bundle.pem - 要使用的 CA 證書捆綁包的檔名。如果您想使用與 botocore 使用的不同的 CA 證書捆綁包，可以指定此引數。

如果此引數設定為 None 或省略，則使用 AWS 連線 Extra Parameter 中的 verify。否則，使用指定的值而不是連線值。預設值: None

botocore_config

提供的字典用於構建 botocore.config.Config。此配置可用於配置避免限流異常、超時等。

示例，有關引數的更多詳細資訊，請參閱 botocore.config.Config¶

{
    "signature_version": "unsigned",
    "s3": {
        "us_east_1_regional_endpoint": True,
    },
    "retries": {
      "mode": "standard",
      "max_attempts": 10,
    },
    "connect_timeout": 300,
    "read_timeout": 300,
    "tcp_keepalive": True,
}

如果此引數設定為 None 或省略，則使用 AWS 連線 Extra Parameter 中的 config_kwargs。否則，使用指定的值而不是連線值。預設值: None

注意

指定一個空字典 {} 將覆蓋 botocore.config.Config 的連線配置。

Operator¶

建立 AWS CloudFormation 堆疊¶

要建立新的 AWS CloudFormation 堆疊，請使用 CloudFormationCreateStackOperator。

tests/system/amazon/aws/example_cloudformation.py

create_stack = CloudFormationCreateStackOperator(
    task_id="create_stack",
    stack_name=cloudformation_stack_name,
    cloudformation_parameters=cloudformation_create_parameters,
)

刪除 AWS CloudFormation 堆疊¶

要刪除 AWS CloudFormation 堆疊，您可以使用 CloudFormationDeleteStackOperator。

tests/system/amazon/aws/example_cloudformation.py

delete_stack = CloudFormationDeleteStackOperator(
    task_id="delete_stack",
    stack_name=cloudformation_stack_name,
)

Sensor¶

等待 AWS CloudFormation 堆疊建立狀態¶

要等待 AWS CloudFormation 堆疊建立的狀態直到其達到終端狀態，您可以使用 CloudFormationCreateStackSensor

tests/system/amazon/aws/example_cloudformation.py

wait_for_stack_create = CloudFormationCreateStackSensor(
    task_id="wait_for_stack_create",
    stack_name=cloudformation_stack_name,
)

等待 AWS CloudFormation 堆疊刪除狀態¶

要等待 AWS CloudFormation 堆疊刪除的狀態直到其達到終端狀態，您可以使用 CloudFormationDeleteStackSensor

tests/system/amazon/aws/example_cloudformation.py

wait_for_stack_delete = CloudFormationDeleteStackSensor(
    task_id="wait_for_stack_delete",
    stack_name=cloudformation_stack_name,
)

參考¶

適用於 CloudFormation 的 AWS boto3 庫文件