amazon.aws.hooks.redshift_cluster
¶
Module Contents¶
Classes¶
Interact with AWS Redshift using aiobotocore python library |
Attributes¶
- amazon.aws.hooks.redshift_cluster.log¶
- class amazon.aws.hooks.redshift_cluster.RedshiftHookAsync(*args, **kwargs)¶
Bases:
astronomer.providers.amazon.aws.hooks.base_aws_async.AwsBaseHookAsync
Interact with AWS Redshift using aiobotocore python library
- async cluster_status(self, cluster_identifier)¶
Connects to the AWS redshift cluster via aiobotocore and get the status and returns the status of the cluster based on the cluster_identifier passed
- Parameters
cluster_identifier (str) – unique identifier of a cluster
- async pause_cluster(self, cluster_identifier)¶
Connects to the AWS redshift cluster via aiobotocore and pause the cluster based on the cluster_identifier passed
- Parameters
cluster_identifier (str) – unique identifier of a cluster
- async resume_cluster(self, cluster_identifier)¶
Connects to the AWS redshift cluster via aiobotocore and resume the cluster for the cluster_identifier passed
- Parameters
cluster_identifier (str) – unique identifier of a cluster
- async get_cluster_status(self, cluster_identifier, expected_state, flag)¶
Make call self.cluster_status to know the status and run till the expected_state is met and set the flag
- Parameters
cluster_identifier (str) – unique identifier of a cluster
expected_state (str) – expected_state example(“available”, “pausing”, “paused””)
flag (asyncio.Event) – asyncio even flag set true if success and if any error