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

類¶

KinesisAnalyticsV2Hook

與 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。

另請參閱

airflow.providers.amazon.aws.hooks.base_aws.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_START_SUCCESS_STATES: tuple[str, Ellipsis] = ('RUNNING',)[source]¶

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

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

APPLICATION_STOP_SUCCESS_STATES: tuple[str, Ellipsis] = ('READY',)[source]¶

本條目有幫助嗎？