airflow.providers.amazon.aws.triggers.redshift_data¶

类¶

RedshiftDataTrigger

RedshiftDataTrigger 作为可延迟类触发，带有参数，以便在触发器中运行任务。

模块内容¶

class airflow.providers.amazon.aws.triggers.redshift_data.RedshiftDataTrigger(statement_id, task_id, poll_interval, aws_conn_id='aws_default', region_name=None, verify=None, botocore_config=None)[source]¶

基类: airflow.triggers.base.BaseTrigger

RedshiftDataTrigger 作为可延迟类触发，带有参数，以便在触发器中运行任务。

参数:

statement_id (str) – 语句的 UUID
task_id (str) – DAG 的任务 ID
poll_interval (int) – 检查状态的轮询周期（秒）
aws_conn_id (str | None) – 用于 redshift 的 AWS 连接 ID
region_name (str | None) – 要使用的 AWS 区域名称

statement_id[source]¶

task_id[source]¶

poll_interval[source]¶

aws_conn_id = 'aws_default'[source]¶

region_name = None[source]¶

verify = None[source]¶

botocore_config = None[source]¶

serialize()[source]¶

序列化 RedshiftDataTrigger 参数和类路径。

property hook: airflow.providers.amazon.aws.hooks.redshift_data.RedshiftDataHook[source]¶

async run()[source]¶

在异步上下文中运行触发器。

触发器应在需要触发事件时产生 (yield) 一个 Event，并在完成时返回 None。因此，单事件触发器应先产生 (yield)，然后立即返回。

如果它产生了 (yield)，它很可能会很快恢复，但也可能不会（例如，如果工作负载正在转移到另一个触发器进程，或者多事件触发器用于单个事件任务延迟）。

无论哪种情况，Trigger 类都应假定它们会被持久化，并在不再需要时依赖于调用 cleanup() 方法。