airflow.providers.amazon.aws.hooks.kinesis_analytics¶
类¶
与 Amazon Kinesis Analytics V2 进行交互。 |
模块内容¶
- class airflow.providers.amazon.aws.hooks.kinesis_analytics.KinesisAnalyticsV2Hook(*args, **kwargs)[source]¶
Bases:
airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook
与 Amazon Kinesis Analytics V2 进行交互。
提供围绕
boto3.client("kinesisanalyticsv2")
的轻量级包装。可以指定额外的参数(例如
aws_conn_id
),这些参数将被传递到底层 AwsBaseHook。- APPLICATION_START_INTERMEDIATE_STATES: tuple[str, Ellipsis] = ('STARTING', 'UPDATING', 'AUTOSCALING')[source]¶
- APPLICATION_START_FAILURE_STATES: tuple[str, Ellipsis] = ('DELETING', 'STOPPING', 'READY', 'FORCE_STOPPING', 'ROLLING_BACK', 'MAINTENANCE', 'ROLLED_BACK')[source]¶
- APPLICATION_STOP_INTERMEDIATE_STATES: tuple[str, Ellipsis] = ('STARTING', 'UPDATING', 'AUTOSCALING', 'RUNNING', 'STOPPING', 'FORCE_STOPPING')[source]¶