airflow.providers.amazon.aws.operators.ec2
¶
Module Contents¶
Classes¶
Start AWS EC2 instance using boto3. |
|
Stop AWS EC2 instance using boto3. |
|
Create and start a specified number of EC2 Instances using boto3 |
|
Terminate EC2 Instances using boto3 |
- class airflow.providers.amazon.aws.operators.ec2.EC2StartInstanceOperator(*, instance_id, aws_conn_id='aws_default', region_name=None, check_interval=15, **kwargs)[source]¶
Bases:
airflow.models.BaseOperator
Start AWS EC2 instance using boto3.
See also
For more information on how to use this operator, take a look at the guide: Start an Amazon EC2 instance
- Parameters
instance_id (str) – id of the AWS EC2 instance
aws_conn_id (str) – aws connection to use
region_name (str | None) – (optional) aws region name associated with the client
check_interval (float) – time in seconds that the job should wait in between each instance state checks until operation is completed
- class airflow.providers.amazon.aws.operators.ec2.EC2StopInstanceOperator(*, instance_id, aws_conn_id='aws_default', region_name=None, check_interval=15, **kwargs)[source]¶
Bases:
airflow.models.BaseOperator
Stop AWS EC2 instance using boto3.
See also
For more information on how to use this operator, take a look at the guide: Stop an Amazon EC2 instance
- Parameters
instance_id (str) – id of the AWS EC2 instance
aws_conn_id (str) – aws connection to use
region_name (str | None) – (optional) aws region name associated with the client
check_interval (float) – time in seconds that the job should wait in between each instance state checks until operation is completed
- class airflow.providers.amazon.aws.operators.ec2.EC2CreateInstanceOperator(image_id, max_count=1, min_count=1, aws_conn_id='aws_default', region_name=None, poll_interval=20, max_attempts=20, config=None, wait_for_completion=False, **kwargs)[source]¶
Bases:
airflow.models.BaseOperator
Create and start a specified number of EC2 Instances using boto3
See also
For more information on how to use this operator, take a look at the guide: Create and start an Amazon EC2 instance
- Parameters
image_id (str) – ID of the AMI used to create the instance.
max_count (int) – Maximum number of instances to launch. Defaults to 1.
min_count (int) – Minimum number of instances to launch. Defaults to 1.
aws_conn_id (str) – AWS connection to use
region_name (str | None) – AWS region name associated with the client.
poll_interval (int) – Number of seconds to wait before attempting to check state of instance. Only used if wait_for_completion is True. Default is 20.
max_attempts (int) – Maximum number of attempts when checking state of instance. Only used if wait_for_completion is True. Default is 20.
config (dict | None) – Dictionary for arbitrary parameters to the boto3 run_instances call.
wait_for_completion (bool) – If True, the operator will wait for the instance to be in the running state before returning.
- class airflow.providers.amazon.aws.operators.ec2.EC2TerminateInstanceOperator(instance_ids, aws_conn_id='aws_default', region_name=None, poll_interval=20, max_attempts=20, wait_for_completion=False, **kwargs)[source]¶
Bases:
airflow.models.BaseOperator
Terminate EC2 Instances using boto3
See also
For more information on how to use this operator, take a look at the guide: Terminate an Amazon EC2 instance
- Parameters
instance_id – ID of the instance to be terminated.
aws_conn_id (str) – AWS connection to use
region_name (str | None) – AWS region name associated with the client.
poll_interval (int) – Number of seconds to wait before attempting to check state of instance. Only used if wait_for_completion is True. Default is 20.
max_attempts (int) – Maximum number of attempts when checking state of instance. Only used if wait_for_completion is True. Default is 20.
wait_for_completion (bool) – If True, the operator will wait for the instance to be in the terminated state before returning.