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

can_paginate

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

# can_paginate method definition

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

generate_presigned_url

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

# generate_presigned_url method definition

def generate_presigned_url(
    self,
    ClientMethod: str,
    Params: Mapping[str, Any] = ...,
    ExpiresIn: int = 3600,
    HttpMethod: str = ...,
) -> str:
    ...

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 AddApplicationReferenceDataSourceResponseTypeDef

# 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

add_application_vpc_configuration

Adds a Virtual Private Cloud (VPC) configuration to the application.

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

# add_application_vpc_configuration method definition

def add_application_vpc_configuration(
    self,
    *,
    ApplicationName: str,
    VpcConfiguration: VpcConfigurationTypeDef,  # (1)
    CurrentApplicationVersionId: int = ...,
    ConditionalToken: str = ...,
) -> AddApplicationVpcConfigurationResponseTypeDef:  # (2)
    ...

1. See VpcConfigurationTypeDef
2. See AddApplicationVpcConfigurationResponseTypeDef

# add_application_vpc_configuration method usage example with argument unpacking

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

parent.add_application_vpc_configuration(**kwargs)

1. See AddApplicationVpcConfigurationRequestRequestTypeDef

create_application

Creates a Managed Service for Apache Flink application.

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

# create_application method definition

def create_application(
    self,
    *,
    ApplicationName: str,
    RuntimeEnvironment: RuntimeEnvironmentType,  # (1)
    ServiceExecutionRole: str,
    ApplicationDescription: str = ...,
    ApplicationConfiguration: ApplicationConfigurationTypeDef = ...,  # (2)
    CloudWatchLoggingOptions: Sequence[CloudWatchLoggingOptionTypeDef] = ...,  # (3)
    Tags: Sequence[TagTypeDef] = ...,  # (4)
    ApplicationMode: ApplicationModeType = ...,  # (5)
) -> CreateApplicationResponseTypeDef:  # (6)
    ...

1. See RuntimeEnvironmentType
2. See ApplicationConfigurationTypeDef
3. See CloudWatchLoggingOptionTypeDef
4. See TagTypeDef
5. See ApplicationModeType
6. See CreateApplicationResponseTypeDef

# create_application method usage example with argument unpacking

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

parent.create_application(**kwargs)

1. See CreateApplicationRequestRequestTypeDef

create_application_presigned_url

Creates and returns a URL that you can use to connect to an application's extension.

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

# create_application_presigned_url method definition

def create_application_presigned_url(
    self,
    *,
    ApplicationName: str,
    UrlType: UrlTypeType,  # (1)
    SessionExpirationDurationInSeconds: int = ...,
) -> CreateApplicationPresignedUrlResponseTypeDef:  # (2)
    ...

1. See UrlTypeType
2. See CreateApplicationPresignedUrlResponseTypeDef

# create_application_presigned_url method usage example with argument unpacking

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

parent.create_application_presigned_url(**kwargs)

1. See CreateApplicationPresignedUrlRequestRequestTypeDef

create_application_snapshot

Creates a snapshot of the application's state data.

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

# create_application_snapshot method definition

def create_application_snapshot(
    self,
    *,
    ApplicationName: str,
    SnapshotName: str,
) -> dict[str, Any]:
    ...

# create_application_snapshot method usage example with argument unpacking

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

parent.create_application_snapshot(**kwargs)

1. See CreateApplicationSnapshotRequestRequestTypeDef

delete_application

Deletes the specified application.

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

# delete_application method definition

def delete_application(
    self,
    *,
    ApplicationName: str,
    CreateTimestamp: TimestampTypeDef,
) -> 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

Deletes an Amazon CloudWatch log stream from an SQL-based Kinesis Data Analytics application.

Type annotations and code completion for boto3.client("kinesisanalyticsv2").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,
    CloudWatchLoggingOptionId: str,
    CurrentApplicationVersionId: int = ...,
    ConditionalToken: str = ...,
) -> DeleteApplicationCloudWatchLoggingOptionResponseTypeDef:  # (1)
    ...

1. See DeleteApplicationCloudWatchLoggingOptionResponseTypeDef

# delete_application_cloud_watch_logging_option method usage example with argument unpacking

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

parent.delete_application_cloud_watch_logging_option(**kwargs)

1. See DeleteApplicationCloudWatchLoggingOptionRequestRequestTypeDef

delete_application_input_processing_configuration

Deletes an InputProcessingConfiguration from an input.

Type annotations and code completion for boto3.client("kinesisanalyticsv2").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,
) -> DeleteApplicationInputProcessingConfigurationResponseTypeDef:  # (1)
    ...

1. See DeleteApplicationInputProcessingConfigurationResponseTypeDef

# 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

Deletes the output destination configuration from your SQL-based Kinesis Data Analytics application's configuration.

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

# delete_application_output method definition

def delete_application_output(
    self,
    *,
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    OutputId: str,
) -> DeleteApplicationOutputResponseTypeDef:  # (1)
    ...

1. See DeleteApplicationOutputResponseTypeDef

# 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

Deletes a reference data source configuration from the specified SQL-based Kinesis Data Analytics application's configuration.

Type annotations and code completion for boto3.client("kinesisanalyticsv2").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,
) -> DeleteApplicationReferenceDataSourceResponseTypeDef:  # (1)
    ...

1. See DeleteApplicationReferenceDataSourceResponseTypeDef

# 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

delete_application_snapshot

Deletes a snapshot of application state.

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

# delete_application_snapshot method definition

def delete_application_snapshot(
    self,
    *,
    ApplicationName: str,
    SnapshotName: str,
    SnapshotCreationTimestamp: TimestampTypeDef,
) -> dict[str, Any]:
    ...

# delete_application_snapshot method usage example with argument unpacking

kwargs: DeleteApplicationSnapshotRequestRequestTypeDef = {  # (1)
    "ApplicationName": ...,
    "SnapshotName": ...,
    "SnapshotCreationTimestamp": ...,
}

parent.delete_application_snapshot(**kwargs)

1. See DeleteApplicationSnapshotRequestRequestTypeDef

delete_application_vpc_configuration

Removes a VPC configuration from a Managed Service for Apache Flink application.

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

# delete_application_vpc_configuration method definition

def delete_application_vpc_configuration(
    self,
    *,
    ApplicationName: str,
    VpcConfigurationId: str,
    CurrentApplicationVersionId: int = ...,
    ConditionalToken: str = ...,
) -> DeleteApplicationVpcConfigurationResponseTypeDef:  # (1)
    ...

1. See DeleteApplicationVpcConfigurationResponseTypeDef

# delete_application_vpc_configuration method usage example with argument unpacking

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

parent.delete_application_vpc_configuration(**kwargs)

1. See DeleteApplicationVpcConfigurationRequestRequestTypeDef

describe_application

Returns information about a specific Managed Service for Apache Flink application.

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

# describe_application method definition

def describe_application(
    self,
    *,
    ApplicationName: str,
    IncludeAdditionalDetails: bool = ...,
) -> DescribeApplicationResponseTypeDef:  # (1)
    ...

1. See DescribeApplicationResponseTypeDef

# describe_application method usage example with argument unpacking

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

parent.describe_application(**kwargs)

1. See DescribeApplicationRequestRequestTypeDef

describe_application_operation

Returns information about a specific operation performed on a Managed Service for Apache Flink application.

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

# describe_application_operation method definition

def describe_application_operation(
    self,
    *,
    ApplicationName: str,
    OperationId: str,
) -> DescribeApplicationOperationResponseTypeDef:  # (1)
    ...

1. See DescribeApplicationOperationResponseTypeDef

# describe_application_operation method usage example with argument unpacking

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

parent.describe_application_operation(**kwargs)

1. See DescribeApplicationOperationRequestRequestTypeDef

describe_application_snapshot

Returns information about a snapshot of application state data.

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

# describe_application_snapshot method definition

def describe_application_snapshot(
    self,
    *,
    ApplicationName: str,
    SnapshotName: str,
) -> DescribeApplicationSnapshotResponseTypeDef:  # (1)
    ...

1. See DescribeApplicationSnapshotResponseTypeDef

# describe_application_snapshot method usage example with argument unpacking

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

parent.describe_application_snapshot(**kwargs)

1. See DescribeApplicationSnapshotRequestRequestTypeDef

describe_application_version

Provides a detailed description of a specified version of the application.

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

# describe_application_version method definition

def describe_application_version(
    self,
    *,
    ApplicationName: str,
    ApplicationVersionId: int,
) -> DescribeApplicationVersionResponseTypeDef:  # (1)
    ...

1. See DescribeApplicationVersionResponseTypeDef

# describe_application_version method usage example with argument unpacking

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

parent.describe_application_version(**kwargs)

1. See DescribeApplicationVersionRequestRequestTypeDef

discover_input_schema

Infers a schema for a SQL-based Kinesis Data Analytics application by evaluating sample records on the specified streaming source (Kinesis data stream or Kinesis Data Firehose delivery stream) or Amazon S3 object.

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

# discover_input_schema method definition

def discover_input_schema(
    self,
    *,
    ServiceExecutionRole: str,
    ResourceARN: str = ...,
    InputStartingPositionConfiguration: InputStartingPositionConfigurationTypeDef = ...,  # (1)
    S3Configuration: S3ConfigurationTypeDef = ...,  # (2)
    InputProcessingConfiguration: InputProcessingConfigurationTypeDef = ...,  # (3)
) -> DiscoverInputSchemaResponseTypeDef:  # (4)
    ...

1. See InputStartingPositionConfigurationTypeDef
2. See S3ConfigurationTypeDef
3. See InputProcessingConfigurationTypeDef
4. See DiscoverInputSchemaResponseTypeDef

# discover_input_schema method usage example with argument unpacking

kwargs: DiscoverInputSchemaRequestRequestTypeDef = {  # (1)
    "ServiceExecutionRole": ...,
}

parent.discover_input_schema(**kwargs)

1. See DiscoverInputSchemaRequestRequestTypeDef

list_application_operations

Lists information about operations performed on a Managed Service for Apache Flink application.

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

# list_application_operations method definition

def list_application_operations(
    self,
    *,
    ApplicationName: str,
    Limit: int = ...,
    NextToken: str = ...,
    Operation: str = ...,
    OperationStatus: OperationStatusType = ...,  # (1)
) -> ListApplicationOperationsResponseTypeDef:  # (2)
    ...

1. See OperationStatusType
2. See ListApplicationOperationsResponseTypeDef

# list_application_operations method usage example with argument unpacking

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

parent.list_application_operations(**kwargs)

1. See ListApplicationOperationsRequestRequestTypeDef

list_application_snapshots

Lists information about the current application snapshots.

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

# list_application_snapshots method definition

def list_application_snapshots(
    self,
    *,
    ApplicationName: str,
    Limit: int = ...,
    NextToken: str = ...,
) -> ListApplicationSnapshotsResponseTypeDef:  # (1)
    ...

1. See ListApplicationSnapshotsResponseTypeDef

# list_application_snapshots method usage example with argument unpacking

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

parent.list_application_snapshots(**kwargs)

1. See ListApplicationSnapshotsRequestRequestTypeDef

list_application_versions

Lists all the versions for the specified application, including versions that were rolled back.

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

# list_application_versions method definition

def list_application_versions(
    self,
    *,
    ApplicationName: str,
    Limit: int = ...,
    NextToken: str = ...,
) -> ListApplicationVersionsResponseTypeDef:  # (1)
    ...

1. See ListApplicationVersionsResponseTypeDef

# list_application_versions method usage example with argument unpacking

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

parent.list_application_versions(**kwargs)

1. See ListApplicationVersionsRequestRequestTypeDef

list_applications

Returns a list of Managed Service for Apache Flink applications in your account.

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

# list_applications method definition

def list_applications(
    self,
    *,
    Limit: int = ...,
    NextToken: str = ...,
) -> ListApplicationsResponseTypeDef:  # (1)
    ...

1. See ListApplicationsResponseTypeDef

# list_applications method usage example with argument unpacking

kwargs: ListApplicationsRequestRequestTypeDef = {  # (1)
    "Limit": ...,
}

parent.list_applications(**kwargs)

1. See ListApplicationsRequestRequestTypeDef

list_tags_for_resource

Retrieves the list of key-value tags assigned to the application.

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

# list_tags_for_resource method definition

def list_tags_for_resource(
    self,
    *,
    ResourceARN: str,
) -> ListTagsForResourceResponseTypeDef:  # (1)
    ...

1. See ListTagsForResourceResponseTypeDef

# list_tags_for_resource method usage example with argument unpacking

kwargs: ListTagsForResourceRequestRequestTypeDef = {  # (1)
    "ResourceARN": ...,
}

parent.list_tags_for_resource(**kwargs)

1. See ListTagsForResourceRequestRequestTypeDef

rollback_application

Reverts the application to the previous running version.

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

# rollback_application method definition

def rollback_application(
    self,
    *,
    ApplicationName: str,
    CurrentApplicationVersionId: int,
) -> RollbackApplicationResponseTypeDef:  # (1)
    ...

1. See RollbackApplicationResponseTypeDef

# rollback_application method usage example with argument unpacking

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

parent.rollback_application(**kwargs)

1. See RollbackApplicationRequestRequestTypeDef

start_application

Starts the specified Managed Service for Apache Flink application.

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

# start_application method definition

def start_application(
    self,
    *,
    ApplicationName: str,
    RunConfiguration: RunConfigurationTypeDef = ...,  # (1)
) -> StartApplicationResponseTypeDef:  # (2)
    ...

1. See RunConfigurationTypeDef
2. See StartApplicationResponseTypeDef

# start_application method usage example with argument unpacking

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

parent.start_application(**kwargs)

1. See StartApplicationRequestRequestTypeDef

stop_application

Stops the application from processing data.

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

# stop_application method definition

def stop_application(
    self,
    *,
    ApplicationName: str,
    Force: bool = ...,
) -> StopApplicationResponseTypeDef:  # (1)
    ...

1. See StopApplicationResponseTypeDef

# stop_application method usage example with argument unpacking

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

parent.stop_application(**kwargs)

1. See StopApplicationRequestRequestTypeDef

tag_resource

Adds one or more key-value tags to a Managed Service for Apache Flink application.

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

# tag_resource method definition

def tag_resource(
    self,
    *,
    ResourceARN: str,
    Tags: Sequence[TagTypeDef],  # (1)
) -> dict[str, Any]:
    ...

1. See TagTypeDef

# tag_resource method usage example with argument unpacking

kwargs: TagResourceRequestRequestTypeDef = {  # (1)
    "ResourceARN": ...,
    "Tags": ...,
}

parent.tag_resource(**kwargs)

1. See TagResourceRequestRequestTypeDef

untag_resource

Removes one or more tags from a Managed Service for Apache Flink application.

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

# untag_resource method definition

def untag_resource(
    self,
    *,
    ResourceARN: str,
    TagKeys: Sequence[str],
) -> dict[str, Any]:
    ...

# untag_resource method usage example with argument unpacking

kwargs: UntagResourceRequestRequestTypeDef = {  # (1)
    "ResourceARN": ...,
    "TagKeys": ...,
}

parent.untag_resource(**kwargs)

1. See UntagResourceRequestRequestTypeDef

update_application

Updates an existing Managed Service for Apache Flink application.

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

# update_application method definition

def update_application(
    self,
    *,
    ApplicationName: str,
    CurrentApplicationVersionId: int = ...,
    ApplicationConfigurationUpdate: ApplicationConfigurationUpdateTypeDef = ...,  # (1)
    ServiceExecutionRoleUpdate: str = ...,
    RunConfigurationUpdate: RunConfigurationUpdateTypeDef = ...,  # (2)
    CloudWatchLoggingOptionUpdates: Sequence[CloudWatchLoggingOptionUpdateTypeDef] = ...,  # (3)
    ConditionalToken: str = ...,
    RuntimeEnvironmentUpdate: RuntimeEnvironmentType = ...,  # (4)
) -> UpdateApplicationResponseTypeDef:  # (5)
    ...

1. See ApplicationConfigurationUpdateTypeDef
2. See RunConfigurationUpdateTypeDef
3. See CloudWatchLoggingOptionUpdateTypeDef
4. See RuntimeEnvironmentType
5. See UpdateApplicationResponseTypeDef

# update_application method usage example with argument unpacking

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

parent.update_application(**kwargs)

1. See UpdateApplicationRequestRequestTypeDef

update_application_maintenance_configuration

Updates the maintenance configuration of the Managed Service for Apache Flink application.

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

# update_application_maintenance_configuration method definition

def update_application_maintenance_configuration(
    self,
    *,
    ApplicationName: str,
    ApplicationMaintenanceConfigurationUpdate: ApplicationMaintenanceConfigurationUpdateTypeDef,  # (1)
) -> UpdateApplicationMaintenanceConfigurationResponseTypeDef:  # (2)
    ...

1. See ApplicationMaintenanceConfigurationUpdateTypeDef
2. See UpdateApplicationMaintenanceConfigurationResponseTypeDef

# update_application_maintenance_configuration method usage example with argument unpacking

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

parent.update_application_maintenance_configuration(**kwargs)

1. See UpdateApplicationMaintenanceConfigurationRequestRequestTypeDef

get_paginator

Type annotations and code completion for boto3.client("kinesisanalyticsv2").get_paginator method with overloads.

• client.get_paginator("list_application_operations") -> ListApplicationOperationsPaginator
• client.get_paginator("list_application_snapshots") -> ListApplicationSnapshotsPaginator
• client.get_paginator("list_application_versions") -> ListApplicationVersionsPaginator
• client.get_paginator("list_applications") -> ListApplicationsPaginator