Skip to content

KinesisAnalyticsClient#

Index > KinesisAnalytics > KinesisAnalyticsClient

Auto-generated documentation for KinesisAnalytics type annotations stubs module mypy-boto3-kinesisanalytics.

KinesisAnalyticsClient#

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

# KinesisAnalyticsClient usage example

from boto3.session import Session
from mypy_boto3_kinesisanalytics.client import KinesisAnalyticsClient

def get_kinesisanalytics_client() -> KinesisAnalyticsClient:
    return Session().client("kinesisanalytics")

Exceptions#

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

# Exceptions.exceptions usage example

client = boto3.client("kinesisanalytics")

try:
    do_something(client)
except (
    client.exceptions.ClientError,
    client.exceptions.CodeValidationException,
    client.exceptions.ConcurrentModificationException,
    client.exceptions.InvalidApplicationConfigurationException,
    client.exceptions.InvalidArgumentException,
    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_kinesisanalytics.client import Exceptions

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

Methods#

add_application_cloud_watch_logging_option#

.

Type annotations and code completion for boto3.client("kinesisanalytics").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,
    CurrentApplicationVersionId: int,
    CloudWatchLoggingOption: CloudWatchLoggingOptionTypeDef,  # (1)
) -> Dict[str, Any]:
    ...
  1. See CloudWatchLoggingOptionTypeDef
# add_application_cloud_watch_logging_option method usage example with argument unpacking

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

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

add_application_input#

.

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

# add_application_input method definition

def add_application_input(
    self,
    *,
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    Input: InputTypeDef,  # (1)
) -> Dict[str, Any]:
    ...
  1. See InputTypeDef
# 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#

.

Type annotations and code completion for boto3.client("kinesisanalytics").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)
) -> Dict[str, Any]:
    ...
  1. See InputProcessingConfigurationTypeDef
# 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#

.

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

# add_application_output method definition

def add_application_output(
    self,
    *,
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    Output: OutputTypeDef,  # (1)
) -> Dict[str, Any]:
    ...
  1. See OutputTypeDef
# 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#

.

Type annotations and code completion for boto3.client("kinesisanalytics").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)
) -> Dict[str, Any]:
    ...
  1. See ReferenceDataSourceTypeDef
# add_application_reference_data_source method usage example with argument unpacking

kwargs: AddApplicationReferenceDataSourceRequestRequestTypeDef = {  # (1)
    "ApplicationName": ...,
    "CurrentApplicationVersionId": ...,
    "ReferenceDataSource": ...,
}

parent.add_application_reference_data_source(**kwargs)
  1. See AddApplicationReferenceDataSourceRequestRequestTypeDef

can_paginate#

Check if an operation can be paginated.

Type annotations and code completion for boto3.client("kinesisanalytics").can_paginate method. boto3 documentation

# can_paginate method definition

def can_paginate(
    self,
    operation_name: str,
) -> bool:
    ...

close#

Closes underlying endpoint connections.

Type annotations and code completion for boto3.client("kinesisanalytics").close method. boto3 documentation

# close method definition

def close(
    self,
) -> None:
    ...

create_application#

.

Type annotations and code completion for boto3.client("kinesisanalytics").create_application method. boto3 documentation

# create_application method definition

def create_application(
    self,
    *,
    ApplicationName: str,
    ApplicationDescription: str = ...,
    Inputs: Sequence[InputTypeDef] = ...,  # (1)
    Outputs: Sequence[OutputTypeDef] = ...,  # (2)
    CloudWatchLoggingOptions: Sequence[CloudWatchLoggingOptionTypeDef] = ...,  # (3)
    ApplicationCode: str = ...,
    Tags: Sequence[TagTypeDef] = ...,  # (4)
) -> CreateApplicationResponseTypeDef:  # (5)
    ...
  1. See InputTypeDef
  2. See OutputTypeDef
  3. See CloudWatchLoggingOptionTypeDef
  4. See TagTypeDef
  5. See CreateApplicationResponseTypeDef
# create_application method usage example with argument unpacking

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

parent.create_application(**kwargs)
  1. See CreateApplicationRequestRequestTypeDef

delete_application#

.

Type annotations and code completion for boto3.client("kinesisanalytics").delete_application method. boto3 documentation

# delete_application method definition

def delete_application(
    self,
    *,
    ApplicationName: str,
    CreateTimestamp: Union[datetime, str],
) -> Dict[str, Any]:
    ...
# delete_application method usage example with argument unpacking

kwargs: DeleteApplicationRequestRequestTypeDef = {  # (1)
    "ApplicationName": ...,
    "CreateTimestamp": ...,
}

parent.delete_application(**kwargs)
  1. See DeleteApplicationRequestRequestTypeDef

delete_application_cloud_watch_logging_option#

.

Type annotations and code completion for boto3.client("kinesisanalytics").delete_application_cloud_watch_logging_option method. boto3 documentation

# delete_application_cloud_watch_logging_option method definition

def delete_application_cloud_watch_logging_option(
    self,
    *,
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    CloudWatchLoggingOptionId: str,
) -> Dict[str, Any]:
    ...
# delete_application_cloud_watch_logging_option method usage example with argument unpacking

kwargs: DeleteApplicationCloudWatchLoggingOptionRequestRequestTypeDef = {  # (1)
    "ApplicationName": ...,
    "CurrentApplicationVersionId": ...,
    "CloudWatchLoggingOptionId": ...,
}

parent.delete_application_cloud_watch_logging_option(**kwargs)
  1. See DeleteApplicationCloudWatchLoggingOptionRequestRequestTypeDef

delete_application_input_processing_configuration#

.

Type annotations and code completion for boto3.client("kinesisanalytics").delete_application_input_processing_configuration method. boto3 documentation

# delete_application_input_processing_configuration method definition

def delete_application_input_processing_configuration(
    self,
    *,
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    InputId: str,
) -> Dict[str, Any]:
    ...
# delete_application_input_processing_configuration method usage example with argument unpacking

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

parent.delete_application_input_processing_configuration(**kwargs)
  1. See DeleteApplicationInputProcessingConfigurationRequestRequestTypeDef

delete_application_output#

.

Type annotations and code completion for boto3.client("kinesisanalytics").delete_application_output method. boto3 documentation

# delete_application_output method definition

def delete_application_output(
    self,
    *,
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    OutputId: str,
) -> Dict[str, Any]:
    ...
# delete_application_output method usage example with argument unpacking

kwargs: DeleteApplicationOutputRequestRequestTypeDef = {  # (1)
    "ApplicationName": ...,
    "CurrentApplicationVersionId": ...,
    "OutputId": ...,
}

parent.delete_application_output(**kwargs)
  1. See DeleteApplicationOutputRequestRequestTypeDef

delete_application_reference_data_source#

.

Type annotations and code completion for boto3.client("kinesisanalytics").delete_application_reference_data_source method. boto3 documentation

# delete_application_reference_data_source method definition

def delete_application_reference_data_source(
    self,
    *,
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    ReferenceId: str,
) -> Dict[str, Any]:
    ...
# delete_application_reference_data_source method usage example with argument unpacking

kwargs: DeleteApplicationReferenceDataSourceRequestRequestTypeDef = {  # (1)
    "ApplicationName": ...,
    "CurrentApplicationVersionId": ...,
    "ReferenceId": ...,
}

parent.delete_application_reference_data_source(**kwargs)
  1. See DeleteApplicationReferenceDataSourceRequestRequestTypeDef

describe_application#

.

Type annotations and code completion for boto3.client("kinesisanalytics").describe_application method. boto3 documentation

# describe_application method definition

def describe_application(
    self,
    *,
    ApplicationName: str,
) -> DescribeApplicationResponseTypeDef:  # (1)
    ...
  1. See DescribeApplicationResponseTypeDef
# describe_application method usage example with argument unpacking

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

parent.describe_application(**kwargs)
  1. See