airflow.providers.amazon.aws.hooks.ec2

模块内容

类

EC2Hook

与 Amazon Elastic Compute Cloud (EC2) 交互。

函数

only_client_type(func)

属性

PS

RT

airflow.providers.amazon.aws.hooks.ec2.PS[source]
airflow.providers.amazon.aws.hooks.ec2.RT[source]
airflow.providers.amazon.aws.hooks.ec2.only_client_type(func)[source]
class airflow.providers.amazon.aws.hooks.ec2.EC2Hook(api_type='resource_type', *args, **kwargs)[source]

基类：airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

与 Amazon Elastic Compute Cloud (EC2) 交互。

提供 boto3.client("ec2") 或 boto3.resource("ec2") 的厚包装器。

参数

api_type – 如果设置为 client_type，则 hook 使用 boto3.client("ec2") 功能；如果设置为 resource_type，则 hook 使用 boto3.resource("ec2") 功能。

可以指定其他参数（例如 aws_conn_id），并将其传递给底层的 AwsBaseHook。

另请参阅

API_TYPES[source]
get_instance(instance_id, filters=None)[source]

按 ID 获取 EC2 实例并返回。

参数

  • instance_id (str) – AWS EC2 实例的 ID

  • filters (list | None) – 用于指定要获取的实例的过滤器列表

返回

实例对象

stop_instances(instance_ids)[source]

停止具有给定 ID 的实例。

参数

instance_ids (list) – 要停止的实例 ID 列表

返回

以键 StoppingInstances 和值作为正在停止的实例列表的字典

返回类型

dict

start_instances(instance_ids)[source]

启动具有给定 ID 的实例。

参数

instance_ids (list) – 要启动的实例 ID 列表

返回

以键 StartingInstances 和值作为正在启动的实例列表的字典

返回类型

dict

terminate_instances(instance_ids)[source]

终止具有给定 ID 的实例。

参数

instance_ids (list) – 要终止的实例 ID 列表

返回

以键 TerminatingInstances 和值作为正在终止的实例列表的字典

返回类型

dict

describe_instances(filters=None, instance_ids=None)[source]

描述 EC2 实例，可选择应用过滤器和选择性实例 ID。

参数

  • filters (list | None) – 用于指定要描述的实例的过滤器列表

  • instance_ids (list | None) – 要描述的实例 ID 列表

返回

来自 EC2 describe_instances API 的响应

get_instances(filters=None, instance_ids=None)[source]

获取实例详细信息列表，可选择应用过滤器和选择性实例 ID。

参数

  • instance_ids (list | None) – 要获取实例的 ID 列表

  • filters (list | None) – 用于指定要获取的实例的过滤器列表

返回

实例列表

返回类型

list

get_instance_ids(filters=None)[source]

获取实例 ID 列表，可选择应用过滤器以获取选择性实例。

参数

filters (list | None) – 用于指定要获取的实例的过滤器列表

返回

实例 ID 列表

返回类型

list

async get_instance_state_async(instance_id)[source]
get_instance_state(instance_id)[source]

按 ID 获取 EC2 实例状态并返回。

参数

instance_id (str) – AWS EC2 实例的 ID

返回

实例的当前状态

返回类型

str

wait_for_state(instance_id, target_state, check_interval)[source]

等待 EC2 实例，直到其状态等于 target_state。

参数

  • instance_id (str) – AWS EC2 实例的 ID

  • target_state (str) – 实例的目标状态

  • check_interval ( float ) – 作业在每次实例状态检查之间等待的时间（以秒为单位），直到操作完成。

返回

无

返回类型

无

此条目是否有帮助？