airflow.providers.amazon.aws.hooks.kinesis_analytics

Module Contents

Classes

KinesisAnalyticsV2Hook

Interact with 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

Interact with Amazon Kinesis Analytics V2.

Provide thin wrapper around boto3.client("kinesisanalyticsv2").

Additional arguments (such as aws_conn_id) may be specified and are passed down to the underlying AwsBaseHook.

See also

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]

Was this entry helpful?