Skip to content

KinesisAnalyticsV2Client#

Index > KinesisAnalyticsV2 > KinesisAnalyticsV2Client

Auto-generated documentation for KinesisAnalyticsV2 type annotations stubs module mypy-boto3-kinesisanalyticsv2.

KinesisAnalyticsV2Client#

Type annotations and code completion for boto3.client("kinesisanalyticsv2"). boto3 documentation

# KinesisAnalyticsV2Client usage example

from boto3.session import Session
from mypy_boto3_kinesisanalyticsv2.client import KinesisAnalyticsV2Client

def get_kinesisanalyticsv2_client() -> KinesisAnalyticsV2Client:
    return Session().client("kinesisanalyticsv2")

Exceptions#

boto3 client exceptions are generated in runtime. This class provides code completion for boto3.client("kinesisanalyticsv2").exceptions structure.

# Exceptions.exceptions usage example

client = boto3.client("kinesisanalyticsv2")

try:
    do_something(client)
except (
    client.exceptions.ClientError,
    client.exceptions.CodeValidationException,
    client.exceptions.ConcurrentModificationException,
    client.exceptions.InvalidApplicationConfigurationException,
    client.exceptions.InvalidArgumentException,
    client.exceptions.InvalidRequestException,
    client.exceptions.LimitExceededException,
    client.exceptions.ResourceInUseException,
    client.exceptions.ResourceNotFoundException,
    client.exceptions.ResourceProvisionedThroughputExceededException,
    client.exceptions.ServiceUnavailableException,
    client.exceptions.TooManyTagsException,
    client.exceptions.UnableToDetectSchemaException,
    client.exceptions.UnsupportedOperationException,
) as e:
    print(e)
# Exceptions.exceptions type checking example

from mypy_boto3_kinesisanalyticsv2.client import Exceptions

def handle_error(exc: Exceptions.ClientError) -> None:
    ...

Methods#

add_application_cloud_watch_logging_option#

Adds an Amazon CloudWatch log stream to monitor application configuration errors.

Type annotations and code completion for boto3.client("kinesisanalyticsv2").add_application_cloud_watch_logging_option method. boto3 documentation

# add_application_cloud_watch_logging_option method definition

def add_application_cloud_watch_logging_option(
    self,
    *,
    ApplicationName: str,
    CloudWatchLoggingOption: CloudWatchLoggingOptionTypeDef,  # (1)
    CurrentApplicationVersionId: int = ...,
    ConditionalToken: str = ...,
) -> AddApplicationCloudWatchLoggingOptionResponseTypeDef:  # (2)
    ...
  1. See CloudWatchLoggingOptionTypeDef
  2. See AddApplicationCloudWatchLoggingOptionResponseTypeDef 
# add_application_cloud_watch_logging_option method usage example with argument unpacking

kwargs: AddApplicationCloudWatchLoggingOptionRequestRequestTypeDef = {  # (1)
    "ApplicationName": ...,
    "CloudWatchLoggingOption": ...,
}

parent.add_application_cloud_watch_logging_option(**kwargs)
  1. See AddApplicationCloudWatchLoggingOptionRequestRequestTypeDef

add_application_input#

Adds a streaming source to your SQL-based Kinesis Data Analytics application.

Type annotations and code completion for boto3.client("kinesisanalyticsv2").add_application_input method. boto3 documentation

# add_application_input method definition

def add_application_input(
    self,
    *,
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    Input: InputTypeDef,  # (1)
) -> AddApplicationInputResponseTypeDef:  # (2)
    ...
  1. See InputTypeDef
  2. See AddApplicationInputResponseTypeDef 
# add_application_input method usage example with argument unpacking

kwargs: AddApplicationInputRequestRequestTypeDef = {  # (1)
    "ApplicationName": ...,
    "CurrentApplicationVersionId": ...,
    "Input": ...,
}

parent.add_application_input(**kwargs)
  1. See AddApplicationInputRequestRequestTypeDef

add_application_input_processing_configuration#

Adds an InputProcessingConfiguration to a SQL-based Kinesis Data Analytics application.

Type annotations and code completion for boto3.client("kinesisanalyticsv2").add_application_input_processing_configuration method. boto3 documentation

# add_application_input_processing_configuration method definition

def add_application_input_processing_configuration(
    self,
    *,
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    InputId: str,
    InputProcessingConfiguration: InputProcessingConfigurationTypeDef,  # (1)
) -> AddApplicationInputProcessingConfigurationResponseTypeDef:  # (2)
    ...
  1. See InputProcessingConfigurationTypeDef
  2. See AddApplicationInputProcessingConfigurationResponseTypeDef 
# add_application_input_processing_configuration method usage example with argument unpacking

kwargs: AddApplicationInputProcessingConfigurationRequestRequestTypeDef = {  # (1)
    "ApplicationName": ...,
    "CurrentApplicationVersionId": ...,
    "InputId": ...,
    "InputProcessingConfiguration": ...,
}

parent.add_application_input_processing_configuration(**kwargs)
  1. See AddApplicationInputProcessingConfigurationRequestRequestTypeDef

add_application_output#

Adds an external destination to your SQL-based Kinesis Data Analytics application.

Type annotations and code completion for boto3.client("kinesisanalyticsv2").add_application_output method. boto3 documentation

# add_application_output method definition

def add_application_output(
    self,
    *,
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    Output: OutputTypeDef,  # (1)
) -> AddApplicationOutputResponseTypeDef:  # (2)
    ...
  1. See OutputTypeDef
  2. See AddApplicationOutputResponseTypeDef 
# add_application_output method usage example with argument unpacking

kwargs: AddApplicationOutputRequestRequestTypeDef = {  # (1)
    "ApplicationName": ...,
    "CurrentApplicationVersionId": ...,
    "Output": ...,
}

parent.add_application_output(**kwargs)
  1. See AddApplicationOutputRequestRequestTypeDef

add_application_reference_data_source#

Adds a reference data source to an existing SQL-based Kinesis Data Analytics application.

Type annotations and code completion for boto3.client("kinesisanalyticsv2").add_application_reference_data_source method. boto3 documentation

# add_application_reference_data_source method definition

def add_application_reference_data_source(
    self,
    *,
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    ReferenceDataSource: ReferenceDataSourceTypeDef,  # (1)
) -> AddApplicationReferenceDataSourceResponseTypeDef:  # (2)
    ...
  1. See ReferenceDataSourceTypeDef
  2. See