airflow.providers.amazon.aws.sensors.ec2¶

类¶

EC2InstanceStateSensor

轮询 AWS EC2 实例的状态，直到实例达到目标状态。

模块内容¶

class airflow.providers.amazon.aws.sensors.ec2.EC2InstanceStateSensor(*, target_state, instance_id, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[source]¶

Bases: airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor[airflow.providers.amazon.aws.hooks.ec2.EC2Hook]

轮询 AWS EC2 实例的状态，直到实例达到目标状态。

另请参阅

有关如何使用此传感器的更多信息，请参阅指南：等待 Amazon EC2 实例状态

参数:

target_state (str) – 实例的目标状态
instance_id (str) – AWS EC2 实例的 ID
region_name – （可选）与客户端关联的 AWS 区域名称
deferrable (bool) – 如果为 True，传感器将在可延迟模式下运行

aws_hook_class[source]¶

template_fields: collections.abc.Sequence[str][source]¶

ui_color = '#cc8811'[source]¶

ui_fgcolor = '#ffffff'[source]¶

valid_states = ['running', 'stopped', 'terminated'][source]¶

target_state[source]¶

instance_id[source]¶

deferrable = True[source]¶

execute(context)[source]¶

创建操作器时派生。

执行任务的主要方法。Context 是与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

poke(context)[source]¶

派生此类时重写。

execute_complete(context, event=None)[source]¶