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
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.
client = boto3.client("kinesisanalytics")
try:
do_something(client)
except (
client.ClientError,
client.CodeValidationException,
client.ConcurrentModificationException,
client.InvalidApplicationConfigurationException,
client.InvalidArgumentException,
client.LimitExceededException,
client.ResourceInUseException,
client.ResourceNotFoundException,
client.ResourceProvisionedThroughputExceededException,
client.ServiceUnavailableException,
client.TooManyTagsException,
client.UnableToDetectSchemaException,
client.UnsupportedOperationException,
) as e:
print(e)
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
def add_application_cloud_watch_logging_option(
self,
*,
ApplicationName: str,
CurrentApplicationVersionId: int,
CloudWatchLoggingOption: CloudWatchLoggingOptionTypeDef, # (1)
) -> Dict[str, Any]:
...
kwargs: AddApplicationCloudWatchLoggingOptionRequestRequestTypeDef = { # (1)
"ApplicationName": ...,
"CurrentApplicationVersionId": ...,
"CloudWatchLoggingOption": ...,
}
parent.add_application_cloud_watch_logging_option(**kwargs)
add_application_input
.
Type annotations and code completion for boto3.client("kinesisanalytics").add_application_input
method.
boto3 documentation
def add_application_input(
self,
*,
ApplicationName: str,
CurrentApplicationVersionId: int,
Input: InputTypeDef, # (1)
) -> Dict[str, Any]:
...
- See InputTypeDef
kwargs: AddApplicationInputRequestRequestTypeDef = { # (1)
"ApplicationName": ...,
"CurrentApplicationVersionId": ...,
"Input": ...,
}
parent.add_application_input(**kwargs)
add_application_input_processing_configuration
.
Type annotations and code completion for boto3.client("kinesisanalytics").add_application_input_processing_configuration
method.
boto3 documentation
def add_application_input_processing_configuration(
self,
*,
ApplicationName: str,
CurrentApplicationVersionId: int,
InputId: str,
InputProcessingConfiguration: InputProcessingConfigurationTypeDef, # (1)
) -> Dict[str, Any]:
...
kwargs: AddApplicationInputProcessingConfigurationRequestRequestTypeDef = { # (1)
"ApplicationName": ...,
"CurrentApplicationVersionId": ...,
"InputId": ...,
"InputProcessingConfiguration": ...,
}
parent.add_application_input_processing_configuration(**kwargs)
add_application_output
.
Type annotations and code completion for boto3.client("kinesisanalytics").add_application_output
method.
boto3 documentation
def add_application_output(
self,
*,
ApplicationName: str,
CurrentApplicationVersionId: int,
Output: OutputTypeDef, # (1)
) -> Dict[str, Any]:
...
- See OutputTypeDef
kwargs: AddApplicationOutputRequestRequestTypeDef = { # (1)
"ApplicationName": ...,
"CurrentApplicationVersionId": ...,
"Output": ...,
}
parent.add_application_output(**kwargs)
add_application_reference_data_source
.
Type annotations and code completion for boto3.client("kinesisanalytics").add_application_reference_data_source
method.
boto3 documentation
def add_application_reference_data_source(
self,
*,
ApplicationName: str,
CurrentApplicationVersionId: int,
ReferenceDataSource: ReferenceDataSourceTypeDef, # (1)
) -> Dict[str, Any]:
...
kwargs: AddApplicationReferenceDataSourceRequestRequestTypeDef = { # (1)
"ApplicationName": ...,
"CurrentApplicationVersionId": ...,
"ReferenceDataSource": ...,
}
parent.add_application_reference_data_source(**kwargs)
can_paginate
Check if an operation can be paginated.
Type annotations and code completion for boto3.client("kinesisanalytics").can_paginate
method.
boto3 documentation
close
Closes underlying endpoint connections.
Type annotations and code completion for boto3.client("kinesisanalytics").close
method.
boto3 documentation
create_application
.
Type annotations and code completion for boto3.client("kinesisanalytics").create_application
method.
boto3 documentation
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)
...
- See InputTypeDef
- See OutputTypeDef
- See CloudWatchLoggingOptionTypeDef
- See TagTypeDef
- See CreateApplicationResponseTypeDef
kwargs: CreateApplicationRequestRequestTypeDef = { # (1)
"ApplicationName": ...,
}
parent.create_application(**kwargs)
delete_application
.
Type annotations and code completion for boto3.client("kinesisanalytics").delete_application
method.
boto3 documentation
def delete_application(
self,
*,
ApplicationName: str,
CreateTimestamp: Union[datetime, str],
) -> Dict[str, Any]:
...
kwargs: DeleteApplicationRequestRequestTypeDef = { # (1)
"ApplicationName": ...,
"CreateTimestamp": ...,
}
parent.delete_application(**kwargs)
delete_application_cloud_watch_logging_option
.
Type annotations and code completion for boto3.client("kinesisanalytics").delete_application_cloud_watch_logging_option
method.
boto3 documentation
def delete_application_cloud_watch_logging_option(
self,
*,
ApplicationName: str,
CurrentApplicationVersionId: int,
CloudWatchLoggingOptionId: str,
) -> Dict[str, Any]:
...
kwargs: DeleteApplicationCloudWatchLoggingOptionRequestRequestTypeDef = { # (1)
"ApplicationName": ...,
"CurrentApplicationVersionId": ...,
"CloudWatchLoggingOptionId": ...,
}
parent.delete_application_cloud_watch_logging_option(**kwargs)
delete_application_input_processing_configuration
.
Type annotations and code completion for boto3.client("kinesisanalytics").delete_application_input_processing_configuration
method.
boto3 documentation
def delete_application_input_processing_configuration(
self,
*,
ApplicationName: str,
CurrentApplicationVersionId: int,
InputId: str,
) -> Dict[str, Any]:
...
kwargs: DeleteApplicationInputProcessingConfigurationRequestRequestTypeDef = { # (1)
"ApplicationName": ...,
"CurrentApplicationVersionId": ...,
"InputId": ...,
}
parent.delete_application_input_processing_configuration(**kwargs)
delete_application_output
.
Type annotations and code completion for boto3.client("kinesisanalytics").delete_application_output
method.
boto3 documentation
def delete_application_output(
self,
*,
ApplicationName: str,
CurrentApplicationVersionId: int,
OutputId: str,
) -> Dict[str, Any]:
...
kwargs: DeleteApplicationOutputRequestRequestTypeDef = { # (1)
"ApplicationName": ...,
"CurrentApplicationVersionId": ...,
"OutputId": ...,
}
parent.delete_application_output(**kwargs)
delete_application_reference_data_source
.
Type annotations and code completion for boto3.client("kinesisanalytics").delete_application_reference_data_source
method.
boto3 documentation
def delete_application_reference_data_source(
self,
*,
ApplicationName: str,
CurrentApplicationVersionId: int,
ReferenceId: str,
) -> Dict[str, Any]:
...
kwargs: DeleteApplicationReferenceDataSourceRequestRequestTypeDef = { # (1)
"ApplicationName": ...,
"CurrentApplicationVersionId": ...,
"ReferenceId": ...,
}
parent.delete_application_reference_data_source(**kwargs)
describe_application
.
Type annotations and code completion for boto3.client("kinesisanalytics").describe_application
method.
boto3 documentation
def describe_application(
self,
*,
ApplicationName: str,
) -> DescribeApplicationResponseTypeDef: # (1)
...
kwargs: DescribeApplicationRequestRequestTypeDef = { # (1)
"ApplicationName": ...,
}
parent.describe_application(**kwargs)
discover_input_schema
.
Type annotations and code completion for boto3.client("kinesisanalytics").discover_input_schema
method.
boto3 documentation
def discover_input_schema(
self,
*,
ResourceARN: str = ...,
RoleARN: str = ...,
InputStartingPositionConfiguration: InputStartingPositionConfigurationTypeDef = ..., # (1)
S3Configuration: S3ConfigurationTypeDef = ..., # (2)
InputProcessingConfiguration: InputProcessingConfigurationTypeDef = ..., # (3)
) -> DiscoverInputSchemaResponseTypeDef: # (4)
...
- See InputStartingPositionConfigurationTypeDef
- See S3ConfigurationTypeDef
- See InputProcessingConfigurationTypeDef
- See DiscoverInputSchemaResponseTypeDef
kwargs: DiscoverInputSchemaRequestRequestTypeDef = { # (1)
"ResourceARN": ...,
}
parent.discover_input_schema(**kwargs)
generate_presigned_url
Generate a presigned url given a client, its method, and arguments.
Type annotations and code completion for boto3.client("kinesisanalytics").generate_presigned_url
method.
boto3 documentation
def generate_presigned_url(
self,
ClientMethod: str,
Params: Mapping[str, Any] = ...,
ExpiresIn: int = 3600,
HttpMethod: str = ...,
) -> str:
...
list_applications
.
Type annotations and code completion for boto3.client("kinesisanalytics").list_applications
method.
boto3 documentation
def list_applications(
self,
*,
Limit: int = ...,
ExclusiveStartApplicationName: str = ...,
) -> ListApplicationsResponseTypeDef: # (1)
...
kwargs: ListApplicationsRequestRequestTypeDef = { # (1)
"Limit": ...,
}
parent.list_applications(**kwargs)
list_tags_for_resource
Retrieves the list of key-value tags assigned to the application.
Type annotations and code completion for boto3.client("kinesisanalytics").list_tags_for_resource
method.
boto3 documentation
def list_tags_for_resource(
self,
*,
ResourceARN: str,
) -> ListTagsForResourceResponseTypeDef: # (1)
...
kwargs: ListTagsForResourceRequestRequestTypeDef = { # (1)
"ResourceARN": ...,
}
parent.list_tags_for_resource(**kwargs)
start_application
.
Type annotations and code completion for boto3.client("kinesisanalytics").start_application
method.
boto3 documentation
def start_application(
self,
*,
ApplicationName: str,
InputConfigurations: Sequence[InputConfigurationTypeDef], # (1)
) -> Dict[str, Any]:
...
kwargs: StartApplicationRequestRequestTypeDef = { # (1)
"ApplicationName": ...,
"InputConfigurations": ...,
}
parent.start_application(**kwargs)
stop_application
.
Type annotations and code completion for boto3.client("kinesisanalytics").stop_application
method.
boto3 documentation
kwargs: StopApplicationRequestRequestTypeDef = { # (1)
"ApplicationName": ...,
}
parent.stop_application(**kwargs)
tag_resource
Adds one or more key-value tags to a Kinesis Analytics application.
Type annotations and code completion for boto3.client("kinesisanalytics").tag_resource
method.
boto3 documentation
def tag_resource(
self,
*,
ResourceARN: str,
Tags: Sequence[TagTypeDef], # (1)
) -> Dict[str, Any]:
...
- See TagTypeDef
kwargs: TagResourceRequestRequestTypeDef = { # (1)
"ResourceARN": ...,
"Tags": ...,
}
parent.tag_resource(**kwargs)
untag_resource
Removes one or more tags from a Kinesis Analytics application.
Type annotations and code completion for boto3.client("kinesisanalytics").untag_resource
method.
boto3 documentation
def untag_resource(
self,
*,
ResourceARN: str,
TagKeys: Sequence[str],
) -> Dict[str, Any]:
...
kwargs: UntagResourceRequestRequestTypeDef = { # (1)
"ResourceARN": ...,
"TagKeys": ...,
}
parent.untag_resource(**kwargs)
update_application
.
Type annotations and code completion for boto3.client("kinesisanalytics").update_application
method.
boto3 documentation
def update_application(
self,
*,
ApplicationName: str,
CurrentApplicationVersionId: int,
ApplicationUpdate: ApplicationUpdateTypeDef, # (1)
) -> Dict[str, Any]:
...