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

基类： 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()[源代码]¶

在子类中重写以返回正确的钩子。

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

模块内容¶

类¶

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