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

模块内容¶

类¶

KinesisAnalyticsV2Hook

与 Amazon Kinesis Analytics V2 交互。

class airflow.providers.amazon.aws.hooks.kinesis_analytics.KinesisAnalyticsV2Hook(*args, **kwargs)[源代码]¶

基类： airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

与 Amazon Kinesis Analytics V2 交互。

提供对 boto3.client("kinesisanalyticsv2") 的轻量级封装。

可以指定其他参数（例如 aws_conn_id），这些参数将传递给底层的 AwsBaseHook。

另请参阅

airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

APPLICATION_START_INTERMEDIATE_STATES: tuple[str, Ellipsis] = ('STARTING', 'UPDATING', 'AUTOSCALING')[源代码]¶

APPLICATION_START_FAILURE_STATES: tuple[str, Ellipsis] = ('DELETING', 'STOPPING', 'READY', 'FORCE_STOPPING', 'ROLLING_BACK', 'MAINTENANCE', 'ROLLED_BACK')[源代码]¶

APPLICATION_START_SUCCESS_STATES: tuple[str, Ellipsis] = ('RUNNING',)[源代码]¶

APPLICATION_STOP_INTERMEDIATE_STATES: tuple[str, Ellipsis] = ('STARTING', 'UPDATING', 'AUTOSCALING', 'RUNNING', 'STOPPING', 'FORCE_STOPPING')[源代码]¶

APPLICATION_STOP_FAILURE_STATES: tuple[str, Ellipsis] = ('DELETING', 'ROLLING_BACK', 'MAINTENANCE', 'ROLLED_BACK')[源代码]¶

APPLICATION_STOP_SUCCESS_STATES: tuple[str, Ellipsis] = ('READY',)[源代码]¶

此条目是否有帮助？