亚马逊弹性计算云 (EC2)¶

亚马逊弹性计算云 (Amazon EC2) 是一项 Web 服务，可提供可调整大小的计算能力（实际上是 Amazon 数据中心的服务器），您可以使用它来构建和托管您的软件系统。

先决条件任务¶

要使用这些操作器，您必须执行以下操作

使用 AWS 控制台或 AWS CLI 创建必要的资源。
通过 pip 安装 API 库。
pip install 'apache-airflow[amazon]'
详细信息请参阅 Airflow™ 的安装
设置连接.

操作器¶

启动 Amazon EC2 实例¶

要启动 Amazon EC2 实例，您可以使用 EC2StartInstanceOperator。

tests/system/providers/amazon/aws/example_ec2.py[源代码]

start_instance = EC2StartInstanceOperator(
    task_id="start_instance",
    instance_id=instance_id,
)

停止 Amazon EC2 实例¶

要停止 Amazon EC2 实例，您可以使用 EC2StopInstanceOperator。

tests/system/providers/amazon/aws/example_ec2.py[源代码]

stop_instance = EC2StopInstanceOperator(
    task_id="stop_instance",
    instance_id=instance_id,
)

创建并启动 Amazon EC2 实例¶

要创建并启动 Amazon EC2 实例，您可以使用 EC2CreateInstanceOperator。

tests/system/providers/amazon/aws/example_ec2.py[源代码]

create_instance = EC2CreateInstanceOperator(
    task_id="create_instance",
    image_id=image_id,
    max_count=1,
    min_count=1,
    config=config,
)

终止 Amazon EC2 实例¶

要终止 Amazon EC2 实例，您可以使用 EC2TerminateInstanceOperator。

tests/system/providers/amazon/aws/example_ec2.py[源代码]

terminate_instance = EC2TerminateInstanceOperator(
    task_id="terminate_instance",
    instance_ids=instance_id,
    wait_for_completion=True,
)

重启 Amazon EC2 实例¶

要重启 Amazon EC2 实例，您可以使用 EC2RebootInstanceOperator。

tests/system/providers/amazon/aws/example_ec2.py[源代码]

reboot_instance = EC2RebootInstanceOperator(
    task_id="reboot_instace",
    instance_ids=instance_id,
)

休眠 Amazon EC2 实例¶

要休眠 Amazon EC2 实例，您可以使用 EC2HibernateInstanceOperator。

tests/system/providers/amazon/aws/example_ec2.py[源代码]

hibernate_instance = EC2HibernateInstanceOperator(
    task_id="hibernate_instace",
    instance_ids=instance_id,
)

传感器¶

等待 Amazon EC2 实例状态¶

要检查 Amazon EC2 实例的状态并等待其达到目标状态，您可以使用 EC2InstanceStateSensor。

tests/system/providers/amazon/aws/example_ec2.py[源代码]

await_instance = EC2InstanceStateSensor(
    task_id="await_instance",
    instance_id=instance_id,
    target_state="running",
)

参考¶

EC2 的 Boto3 库文档