airflow.providers.amazon.aws.triggers.kinesis_analytics¶

类¶

KinesisAnalyticsV2ApplicationOperationCompleteTrigger

在 Apache Flink 的托管服务应用程序启动或停止完成时触发。

模块内容¶

class airflow.providers.amazon.aws.triggers.kinesis_analytics.KinesisAnalyticsV2ApplicationOperationCompleteTrigger(application_name, waiter_name, waiter_delay=120, waiter_max_attempts=75, aws_conn_id='aws_default', **kwargs)[source]¶

基类： airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

在 Apache Flink 的托管服务应用程序启动或停止完成时触发。

参数:

application_name (str) – 应用程序名称。
waiter_name (str) – 用于停止或启动应用程序的等待器的名称。
waiter_delay (int) – 每次尝试之间等待的时间（以秒为单位）。 (默认值: 120)
waiter_max_attempts (int) – 最大尝试次数。 (默认值: 75)
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。

hook()[source]¶

在子类中覆盖以返回正确的钩子。