airflow.providers.amazon.aws.hooks.redshift_cluster

模块内容

RedshiftHook

与 Amazon Redshift 交互。

class airflow.providers.amazon.aws.hooks.redshift_cluster.RedshiftHook(*args, **kwargs)[源代码]

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

与 Amazon Redshift 交互。

这是 boto3.client("redshift") 的一个薄封装。

可以指定其他参数 (如 aws_conn_id),它们会传递给底层的 AwsBaseHook。

template_fields: collections.abc.Sequence[str] = ('cluster_identifier',)[源代码]
create_cluster(cluster_identifier, node_type, master_username, master_user_password, params)[源代码]

使用指定的参数创建一个新集群。

参数
  • cluster_identifier (str) – 集群的唯一标识符。

  • node_type (str) – 为集群配置的节点类型。有效值: ds2.xlargeds2.8xlargedc1.largedc1.8xlargedc2.largedc2.8xlargera3.xlplusra3.4xlargera3.16xlarge

  • master_username (str) – 与要创建的集群的管理员用户帐户关联的用户名。

  • master_user_password (str) – 与要创建的集群的管理员用户帐户关联的密码。

  • params (dict[str, Any]) – 其余的 AWS 创建集群 API 参数。

cluster_status(cluster_identifier)[源代码]

获取集群的状态。

参数

cluster_identifier (str) – 集群的唯一标识符

async cluster_status_async(cluster_identifier)[源代码]
delete_cluster(cluster_identifier, skip_final_cluster_snapshot=True, final_cluster_snapshot_identifier=None)[源代码]

删除集群并可选择创建快照。

参数
  • cluster_identifier (str) – 集群的唯一标识符

  • skip_final_cluster_snapshot (bool) – 确定是否创建集群快照

  • final_cluster_snapshot_identifier (str | None) – 最终集群快照的名称

describe_cluster_snapshots(cluster_identifier)[源代码]

列出集群的快照。

参数

cluster_identifier (str) – 集群的唯一标识符

restore_from_cluster_snapshot(cluster_identifier, snapshot_identifier)[源代码]

从快照还原集群。

参数
  • cluster_identifier (str) – 集群的唯一标识符

  • snapshot_identifier (str) – 集群快照的唯一标识符

create_cluster_snapshot(snapshot_identifier, cluster_identifier, retention_period=-1, tags=None)[源代码]

创建集群的快照。

参数
  • snapshot_identifier (str) – 集群快照的唯一标识符

  • cluster_identifier (str) – 集群的唯一标识符

  • retention_period (int) – 手动快照保留的天数。如果值为 -1,则手动快照将无限期保留。

  • tags ( list[Any] | None) – 标签实例列表

get_cluster_snapshot_status(snapshot_identifier)[source]

获取 Redshift 集群快照状态。

如果未找到集群快照,则返回 None

参数

snapshot_identifier ( str) – 您正在请求的快照的唯一标识符

此条目是否有帮助?