`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)[源代码]¶

基类: 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 区域

serialize()[源代码]¶

序列化 RedshiftDataTrigger 参数和类路径。

hook()[源代码]¶

async run()[源代码]¶

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

触发器应在其想要触发事件时产生一个事件，如果它已完成，则返回 None。单事件触发器应因此产生然后立即返回。

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

在这两种情况下，触发器类都应假设它们将被持久化，然后依赖于在不再需要时调用 cleanup()。

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

模块内容¶

类¶

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