airflow.providers.amazon.aws.sensors.redshift_cluster¶

类¶

RedshiftClusterSensor

等待 Redshift 集群达到特定状态。

模块内容¶

class airflow.providers.amazon.aws.sensors.redshift_cluster.RedshiftClusterSensor(*, cluster_identifier, target_status='available', aws_conn_id='aws_default', deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[源码]¶

基类: airflow.sensors.base.BaseSensorOperator

等待 Redshift 集群达到特定状态。

另请参阅

有关如何使用此传感器的更多信息，请参阅指南：等待 Amazon Redshift 集群状态

参数:

cluster_identifier (str) – 要 Ping 的集群标识符。
target_status (str) – 期望的集群状态。
deferrable (bool) – 以可延迟模式运行算子。

template_fields: collections.abc.Sequence[str] = ('cluster_identifier', 'target_status')[源码]¶

cluster_identifier[源码]¶

target_status = 'available'[源码]¶

aws_conn_id = 'aws_default'[源码]¶

deferrable = True[源码]¶

poke(context)[源码]¶

派生此类时重写。

execute(context)[源码]¶

创建算子时派生。

执行任务的主要方法。上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

execute_complete(context, event=None)[源码]¶

property hook: airflow.providers.amazon.aws.hooks.redshift_cluster.RedshiftHook[源码]¶