Redshift Operator Async¶
To delete an AWS Redshift cluster if cluster status is in available
state
RedshiftDeleteClusterOperatorAsync
.
delete_redshift_cluster = RedshiftDeleteClusterOperatorAsync(
task_id="delete_redshift_cluster",
trigger_rule="all_done",
cluster_identifier=REDSHIFT_CLUSTER_IDENTIFIER,
aws_conn_id=AWS_CONN_ID,
skip_final_cluster_snapshot=True,
final_cluster_snapshot_identifier=None,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/amazon/aws/example_dags/example_redshift_cluster_management.py
To pause an AWS Redshift cluster if cluster status is in available
state
RedshiftPauseClusterOperatorAsync
.
pause_redshift_cluster = RedshiftPauseClusterOperatorAsync(
task_id="pause_redshift_cluster",
cluster_identifier=REDSHIFT_CLUSTER_IDENTIFIER,
aws_conn_id=AWS_CONN_ID,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/amazon/aws/example_dags/example_redshift_cluster_management.py
To resume a paused AWS Redshift cluster asynchronously
RedshiftResumeClusterOperatorAsync
.
resume_redshift_cluster = RedshiftResumeClusterOperatorAsync(
task_id="resume_redshift_cluster",
cluster_identifier=REDSHIFT_CLUSTER_IDENTIFIER,
aws_conn_id=AWS_CONN_ID,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/amazon/aws/example_dags/example_redshift_cluster_management.py