Skip to content

Typed dictionaries

Index > KinesisAnalytics > Typed dictionaries

Auto-generated documentation for KinesisAnalytics type annotations stubs module types-aiobotocore-kinesisanalytics.

CloudWatchLoggingOptionTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import CloudWatchLoggingOptionTypeDef

def get_value() -> CloudWatchLoggingOptionTypeDef:
    return {
        "LogStreamARN": ...,
        "RoleARN": ...,
    }
Definition
class CloudWatchLoggingOptionTypeDef(TypedDict):
    LogStreamARN: str,
    RoleARN: str,

CloudWatchLoggingOptionDescriptionTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import CloudWatchLoggingOptionDescriptionTypeDef

def get_value() -> CloudWatchLoggingOptionDescriptionTypeDef:
    return {
        "LogStreamARN": ...,
        "RoleARN": ...,
    }
Definition
class CloudWatchLoggingOptionDescriptionTypeDef(TypedDict):
    LogStreamARN: str,
    RoleARN: str,
    CloudWatchLoggingOptionId: NotRequired[str],

ApplicationSummaryTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import ApplicationSummaryTypeDef

def get_value() -> ApplicationSummaryTypeDef:
    return {
        "ApplicationName": ...,
        "ApplicationARN": ...,
        "ApplicationStatus": ...,
    }
Definition
class ApplicationSummaryTypeDef(TypedDict):
    ApplicationName: str,
    ApplicationARN: str,
    ApplicationStatus: ApplicationStatusType,  # (1)
  1. See ApplicationStatusType

CloudWatchLoggingOptionUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import CloudWatchLoggingOptionUpdateTypeDef

def get_value() -> CloudWatchLoggingOptionUpdateTypeDef:
    return {
        "CloudWatchLoggingOptionId": ...,
    }
Definition
class CloudWatchLoggingOptionUpdateTypeDef(TypedDict):
    CloudWatchLoggingOptionId: str,
    LogStreamARNUpdate: NotRequired[str],
    RoleARNUpdate: NotRequired[str],

CSVMappingParametersTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import CSVMappingParametersTypeDef

def get_value() -> CSVMappingParametersTypeDef:
    return {
        "RecordRowDelimiter": ...,
        "RecordColumnDelimiter": ...,
    }
Definition
class CSVMappingParametersTypeDef(TypedDict):
    RecordRowDelimiter: str,
    RecordColumnDelimiter: str,

TagTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import TagTypeDef

def get_value() -> TagTypeDef:
    return {
        "Key": ...,
    }
Definition
class TagTypeDef(TypedDict):
    Key: str,
    Value: NotRequired[str],

ResponseMetadataTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import ResponseMetadataTypeDef

def get_value() -> ResponseMetadataTypeDef:
    return {
        "RequestId": ...,
        "HostId": ...,
        "HTTPStatusCode": ...,
        "HTTPHeaders": ...,
        "RetryAttempts": ...,
    }
Definition
class ResponseMetadataTypeDef(TypedDict):
    RequestId: str,
    HostId: str,
    HTTPStatusCode: int,
    HTTPHeaders: Dict[str, str],
    RetryAttempts: int,

DeleteApplicationCloudWatchLoggingOptionRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import DeleteApplicationCloudWatchLoggingOptionRequestRequestTypeDef

def get_value() -> DeleteApplicationCloudWatchLoggingOptionRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
        "CurrentApplicationVersionId": ...,
        "CloudWatchLoggingOptionId": ...,
    }
Definition
class DeleteApplicationCloudWatchLoggingOptionRequestRequestTypeDef(TypedDict):
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    CloudWatchLoggingOptionId: str,

DeleteApplicationInputProcessingConfigurationRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import DeleteApplicationInputProcessingConfigurationRequestRequestTypeDef

def get_value() -> DeleteApplicationInputProcessingConfigurationRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
        "CurrentApplicationVersionId": ...,
        "InputId": ...,
    }
Definition
class DeleteApplicationInputProcessingConfigurationRequestRequestTypeDef(TypedDict):
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    InputId: str,

DeleteApplicationOutputRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import DeleteApplicationOutputRequestRequestTypeDef

def get_value() -> DeleteApplicationOutputRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
        "CurrentApplicationVersionId": ...,
        "OutputId": ...,
    }
Definition
class DeleteApplicationOutputRequestRequestTypeDef(TypedDict):
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    OutputId: str,

DeleteApplicationReferenceDataSourceRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import DeleteApplicationReferenceDataSourceRequestRequestTypeDef

def get_value() -> DeleteApplicationReferenceDataSourceRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
        "CurrentApplicationVersionId": ...,
        "ReferenceId": ...,
    }
Definition
class DeleteApplicationReferenceDataSourceRequestRequestTypeDef(TypedDict):
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    ReferenceId: str,

DeleteApplicationRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import DeleteApplicationRequestRequestTypeDef

def get_value() -> DeleteApplicationRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
        "CreateTimestamp": ...,
    }
Definition
class DeleteApplicationRequestRequestTypeDef(TypedDict):
    ApplicationName: str,
    CreateTimestamp: Union[datetime, str],

DescribeApplicationRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import DescribeApplicationRequestRequestTypeDef

def get_value() -> DescribeApplicationRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
    }
Definition
class DescribeApplicationRequestRequestTypeDef(TypedDict):
    ApplicationName: str,

DestinationSchemaTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import DestinationSchemaTypeDef

def get_value() -> DestinationSchemaTypeDef:
    return {
        "RecordFormatType": ...,
    }
Definition
class DestinationSchemaTypeDef(TypedDict):
    RecordFormatType: RecordFormatTypeType,  # (1)
  1. See RecordFormatTypeType

InputStartingPositionConfigurationTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import InputStartingPositionConfigurationTypeDef

def get_value() -> InputStartingPositionConfigurationTypeDef:
    return {
        "InputStartingPosition": ...,
    }
Definition
class InputStartingPositionConfigurationTypeDef(TypedDict):
    InputStartingPosition: NotRequired[InputStartingPositionType],  # (1)
  1. See InputStartingPositionType

S3ConfigurationTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import S3ConfigurationTypeDef

def get_value() -> S3ConfigurationTypeDef:
    return {
        "RoleARN": ...,
        "BucketARN": ...,
        "FileKey": ...,
    }
Definition
class S3ConfigurationTypeDef(TypedDict):
    RoleARN: str,
    BucketARN: str,
    FileKey: str,

InputParallelismTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import InputParallelismTypeDef

def get_value() -> InputParallelismTypeDef:
    return {
        "Count": ...,
    }
Definition
class InputParallelismTypeDef(TypedDict):
    Count: NotRequired[int],

KinesisFirehoseInputDescriptionTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import KinesisFirehoseInputDescriptionTypeDef

def get_value() -> KinesisFirehoseInputDescriptionTypeDef:
    return {
        "ResourceARN": ...,
    }
Definition
class KinesisFirehoseInputDescriptionTypeDef(TypedDict):
    ResourceARN: NotRequired[str],
    RoleARN: NotRequired[str],

KinesisStreamsInputDescriptionTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import KinesisStreamsInputDescriptionTypeDef

def get_value() -> KinesisStreamsInputDescriptionTypeDef:
    return {
        "ResourceARN": ...,
    }
Definition
class KinesisStreamsInputDescriptionTypeDef(TypedDict):
    ResourceARN: NotRequired[str],
    RoleARN: NotRequired[str],

InputLambdaProcessorDescriptionTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import InputLambdaProcessorDescriptionTypeDef

def get_value() -> InputLambdaProcessorDescriptionTypeDef:
    return {
        "ResourceARN": ...,
    }
Definition
class InputLambdaProcessorDescriptionTypeDef(TypedDict):
    ResourceARN: NotRequired[str],
    RoleARN: NotRequired[str],

InputLambdaProcessorTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import InputLambdaProcessorTypeDef

def get_value() -> InputLambdaProcessorTypeDef:
    return {
        "ResourceARN": ...,
        "RoleARN": ...,
    }
Definition
class InputLambdaProcessorTypeDef(TypedDict):
    ResourceARN: str,
    RoleARN: str,

InputLambdaProcessorUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import InputLambdaProcessorUpdateTypeDef

def get_value() -> InputLambdaProcessorUpdateTypeDef:
    return {
        "ResourceARNUpdate": ...,
    }
Definition
class InputLambdaProcessorUpdateTypeDef(TypedDict):
    ResourceARNUpdate: NotRequired[str],
    RoleARNUpdate: NotRequired[str],

InputParallelismUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import InputParallelismUpdateTypeDef

def get_value() -> InputParallelismUpdateTypeDef:
    return {
        "CountUpdate": ...,
    }
Definition
class InputParallelismUpdateTypeDef(TypedDict):
    CountUpdate: NotRequired[int],

RecordColumnTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import RecordColumnTypeDef

def get_value() -> RecordColumnTypeDef:
    return {
        "Name": ...,
        "SqlType": ...,
    }
Definition
class RecordColumnTypeDef(TypedDict):
    Name: str,
    SqlType: str,
    Mapping: NotRequired[str],

KinesisFirehoseInputTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import KinesisFirehoseInputTypeDef

def get_value() -> KinesisFirehoseInputTypeDef:
    return {
        "ResourceARN": ...,
        "RoleARN": ...,
    }
Definition
class KinesisFirehoseInputTypeDef(TypedDict):
    ResourceARN: str,
    RoleARN: str,

KinesisStreamsInputTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import KinesisStreamsInputTypeDef

def get_value() -> KinesisStreamsInputTypeDef:
    return {
        "ResourceARN": ...,
        "RoleARN": ...,
    }
Definition
class KinesisStreamsInputTypeDef(TypedDict):
    ResourceARN: str,
    RoleARN: str,

KinesisFirehoseInputUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import KinesisFirehoseInputUpdateTypeDef

def get_value() -> KinesisFirehoseInputUpdateTypeDef:
    return {
        "ResourceARNUpdate": ...,
    }
Definition
class KinesisFirehoseInputUpdateTypeDef(TypedDict):
    ResourceARNUpdate: NotRequired[str],
    RoleARNUpdate: NotRequired[str],

KinesisStreamsInputUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import KinesisStreamsInputUpdateTypeDef

def get_value() -> KinesisStreamsInputUpdateTypeDef:
    return {
        "ResourceARNUpdate": ...,
    }
Definition
class KinesisStreamsInputUpdateTypeDef(TypedDict):
    ResourceARNUpdate: NotRequired[str],
    RoleARNUpdate: NotRequired[str],

JSONMappingParametersTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import JSONMappingParametersTypeDef

def get_value() -> JSONMappingParametersTypeDef:
    return {
        "RecordRowPath": ...,
    }
Definition
class JSONMappingParametersTypeDef(TypedDict):
    RecordRowPath: str,

KinesisFirehoseOutputDescriptionTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import KinesisFirehoseOutputDescriptionTypeDef

def get_value() -> KinesisFirehoseOutputDescriptionTypeDef:
    return {
        "ResourceARN": ...,
    }
Definition
class KinesisFirehoseOutputDescriptionTypeDef(TypedDict):
    ResourceARN: NotRequired[str],
    RoleARN: NotRequired[str],

KinesisFirehoseOutputTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import KinesisFirehoseOutputTypeDef

def get_value() -> KinesisFirehoseOutputTypeDef:
    return {
        "ResourceARN": ...,
        "RoleARN": ...,
    }
Definition
class KinesisFirehoseOutputTypeDef(TypedDict):
    ResourceARN: str,
    RoleARN: str,

KinesisFirehoseOutputUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import KinesisFirehoseOutputUpdateTypeDef

def get_value() -> KinesisFirehoseOutputUpdateTypeDef:
    return {
        "ResourceARNUpdate": ...,
    }
Definition
class KinesisFirehoseOutputUpdateTypeDef(TypedDict):
    ResourceARNUpdate: NotRequired[str],
    RoleARNUpdate: NotRequired[str],

KinesisStreamsOutputDescriptionTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import KinesisStreamsOutputDescriptionTypeDef

def get_value() -> KinesisStreamsOutputDescriptionTypeDef:
    return {
        "ResourceARN": ...,
    }
Definition
class KinesisStreamsOutputDescriptionTypeDef(TypedDict):
    ResourceARN: NotRequired[str],
    RoleARN: NotRequired[str],

KinesisStreamsOutputTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import KinesisStreamsOutputTypeDef

def get_value() -> KinesisStreamsOutputTypeDef:
    return {
        "ResourceARN": ...,
        "RoleARN": ...,
    }
Definition
class KinesisStreamsOutputTypeDef(TypedDict):
    ResourceARN: str,
    RoleARN: str,

KinesisStreamsOutputUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import KinesisStreamsOutputUpdateTypeDef

def get_value() -> KinesisStreamsOutputUpdateTypeDef:
    return {
        "ResourceARNUpdate": ...,
    }
Definition
class KinesisStreamsOutputUpdateTypeDef(TypedDict):
    ResourceARNUpdate: NotRequired[str],
    RoleARNUpdate: NotRequired[str],

LambdaOutputDescriptionTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import LambdaOutputDescriptionTypeDef

def get_value() -> LambdaOutputDescriptionTypeDef:
    return {
        "ResourceARN": ...,
    }
Definition
class LambdaOutputDescriptionTypeDef(TypedDict):
    ResourceARN: NotRequired[str],
    RoleARN: NotRequired[str],

LambdaOutputTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import LambdaOutputTypeDef

def get_value() -> LambdaOutputTypeDef:
    return {
        "ResourceARN": ...,
        "RoleARN": ...,
    }
Definition
class LambdaOutputTypeDef(TypedDict):
    ResourceARN: str,
    RoleARN: str,

LambdaOutputUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import LambdaOutputUpdateTypeDef

def get_value() -> LambdaOutputUpdateTypeDef:
    return {
        "ResourceARNUpdate": ...,
    }
Definition
class LambdaOutputUpdateTypeDef(TypedDict):
    ResourceARNUpdate: NotRequired[str],
    RoleARNUpdate: NotRequired[str],

ListApplicationsRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import ListApplicationsRequestRequestTypeDef

def get_value() -> ListApplicationsRequestRequestTypeDef:
    return {
        "Limit": ...,
    }
Definition
class ListApplicationsRequestRequestTypeDef(TypedDict):
    Limit: NotRequired[int],
    ExclusiveStartApplicationName: NotRequired[str],

ListTagsForResourceRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import ListTagsForResourceRequestRequestTypeDef

def get_value() -> ListTagsForResourceRequestRequestTypeDef:
    return {
        "ResourceARN": ...,
    }
Definition
class ListTagsForResourceRequestRequestTypeDef(TypedDict):
    ResourceARN: str,

S3ReferenceDataSourceDescriptionTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import S3ReferenceDataSourceDescriptionTypeDef

def get_value() -> S3ReferenceDataSourceDescriptionTypeDef:
    return {
        "BucketARN": ...,
        "FileKey": ...,
        "ReferenceRoleARN": ...,
    }
Definition
class S3ReferenceDataSourceDescriptionTypeDef(TypedDict):
    BucketARN: str,
    FileKey: str,
    ReferenceRoleARN: str,

S3ReferenceDataSourceTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import S3ReferenceDataSourceTypeDef

def get_value() -> S3ReferenceDataSourceTypeDef:
    return {
        "BucketARN": ...,
        "FileKey": ...,
        "ReferenceRoleARN": ...,
    }
Definition
class S3ReferenceDataSourceTypeDef(TypedDict):
    BucketARN: str,
    FileKey: str,
    ReferenceRoleARN: str,

S3ReferenceDataSourceUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import S3ReferenceDataSourceUpdateTypeDef

def get_value() -> S3ReferenceDataSourceUpdateTypeDef:
    return {
        "BucketARNUpdate": ...,
    }
Definition
class S3ReferenceDataSourceUpdateTypeDef(TypedDict):
    BucketARNUpdate: NotRequired[str],
    FileKeyUpdate: NotRequired[str],
    ReferenceRoleARNUpdate: NotRequired[str],

StopApplicationRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import StopApplicationRequestRequestTypeDef

def get_value() -> StopApplicationRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
    }
Definition
class StopApplicationRequestRequestTypeDef(TypedDict):
    ApplicationName: str,

UntagResourceRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import UntagResourceRequestRequestTypeDef

def get_value() -> UntagResourceRequestRequestTypeDef:
    return {
        "ResourceARN": ...,
        "TagKeys": ...,
    }
Definition
class UntagResourceRequestRequestTypeDef(TypedDict):
    ResourceARN: str,
    TagKeys: Sequence[str],

AddApplicationCloudWatchLoggingOptionRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import AddApplicationCloudWatchLoggingOptionRequestRequestTypeDef

def get_value() -> AddApplicationCloudWatchLoggingOptionRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
        "CurrentApplicationVersionId": ...,
        "CloudWatchLoggingOption": ...,
    }
Definition
class AddApplicationCloudWatchLoggingOptionRequestRequestTypeDef(TypedDict):
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    CloudWatchLoggingOption: CloudWatchLoggingOptionTypeDef,  # (1)
  1. See CloudWatchLoggingOptionTypeDef

TagResourceRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import TagResourceRequestRequestTypeDef

def get_value() -> TagResourceRequestRequestTypeDef:
    return {
        "ResourceARN": ...,
        "Tags": ...,
    }
Definition
class TagResourceRequestRequestTypeDef(TypedDict):
    ResourceARN: str,
    Tags: Sequence[TagTypeDef],  # (1)
  1. See TagTypeDef

CreateApplicationResponseTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import CreateApplicationResponseTypeDef

def get_value() -> CreateApplicationResponseTypeDef:
    return {
        "ApplicationSummary": ...,
        "ResponseMetadata": ...,
    }
Definition
class CreateApplicationResponseTypeDef(TypedDict):
    ApplicationSummary: ApplicationSummaryTypeDef,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ApplicationSummaryTypeDef
  2. See ResponseMetadataTypeDef

ListApplicationsResponseTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import ListApplicationsResponseTypeDef

def get_value() -> ListApplicationsResponseTypeDef:
    return {
        "ApplicationSummaries": ...,
        "HasMoreApplications": ...,
        "ResponseMetadata": ...,
    }
Definition
class ListApplicationsResponseTypeDef(TypedDict):
    ApplicationSummaries: List[ApplicationSummaryTypeDef],  # (1)
    HasMoreApplications: bool,
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ApplicationSummaryTypeDef
  2. See ResponseMetadataTypeDef

ListTagsForResourceResponseTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import ListTagsForResourceResponseTypeDef

def get_value() -> ListTagsForResourceResponseTypeDef:
    return {
        "Tags": ...,
        "ResponseMetadata": ...,
    }
Definition
class ListTagsForResourceResponseTypeDef(TypedDict):
    Tags: List[TagTypeDef],  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See TagTypeDef
  2. See ResponseMetadataTypeDef

InputConfigurationTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import InputConfigurationTypeDef

def get_value() -> InputConfigurationTypeDef:
    return {
        "Id": ...,
        "InputStartingPositionConfiguration": ...,
    }
Definition
class InputConfigurationTypeDef(TypedDict):
    Id: str,
    InputStartingPositionConfiguration: InputStartingPositionConfigurationTypeDef,  # (1)
  1. See InputStartingPositionConfigurationTypeDef

InputProcessingConfigurationDescriptionTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import InputProcessingConfigurationDescriptionTypeDef

def get_value() -> InputProcessingConfigurationDescriptionTypeDef:
    return {
        "InputLambdaProcessorDescription": ...,
    }
Definition
class InputProcessingConfigurationDescriptionTypeDef(TypedDict):
    InputLambdaProcessorDescription: NotRequired[InputLambdaProcessorDescriptionTypeDef],  # (1)
  1. See InputLambdaProcessorDescriptionTypeDef

InputProcessingConfigurationTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import InputProcessingConfigurationTypeDef

def get_value() -> InputProcessingConfigurationTypeDef:
    return {
        "InputLambdaProcessor": ...,
    }
Definition
class InputProcessingConfigurationTypeDef(TypedDict):
    InputLambdaProcessor: InputLambdaProcessorTypeDef,  # (1)
  1. See InputLambdaProcessorTypeDef

InputProcessingConfigurationUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import InputProcessingConfigurationUpdateTypeDef

def get_value() -> InputProcessingConfigurationUpdateTypeDef:
    return {
        "InputLambdaProcessorUpdate": ...,
    }
Definition
class InputProcessingConfigurationUpdateTypeDef(TypedDict):
    InputLambdaProcessorUpdate: InputLambdaProcessorUpdateTypeDef,  # (1)
  1. See InputLambdaProcessorUpdateTypeDef

MappingParametersTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import MappingParametersTypeDef

def get_value() -> MappingParametersTypeDef:
    return {
        "JSONMappingParameters": ...,
    }
Definition
class MappingParametersTypeDef(TypedDict):
    JSONMappingParameters: NotRequired[JSONMappingParametersTypeDef],  # (1)
    CSVMappingParameters: NotRequired[CSVMappingParametersTypeDef],  # (2)
  1. See JSONMappingParametersTypeDef
  2. See CSVMappingParametersTypeDef

OutputDescriptionTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import OutputDescriptionTypeDef

def get_value() -> OutputDescriptionTypeDef:
    return {
        "OutputId": ...,
    }
Definition
class OutputDescriptionTypeDef(TypedDict):
    OutputId: NotRequired[str],
    Name: NotRequired[str],
    KinesisStreamsOutputDescription: NotRequired[KinesisStreamsOutputDescriptionTypeDef],  # (1)
    KinesisFirehoseOutputDescription: NotRequired[KinesisFirehoseOutputDescriptionTypeDef],  # (2)
    LambdaOutputDescription: NotRequired[LambdaOutputDescriptionTypeDef],  # (3)
    DestinationSchema: NotRequired[DestinationSchemaTypeDef],  # (4)
  1. See KinesisStreamsOutputDescriptionTypeDef
  2. See KinesisFirehoseOutputDescriptionTypeDef
  3. See LambdaOutputDescriptionTypeDef
  4. See DestinationSchemaTypeDef

OutputTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import OutputTypeDef

def get_value() -> OutputTypeDef:
    return {
        "Name": ...,
        "DestinationSchema": ...,
    }
Definition
class OutputTypeDef(TypedDict):
    Name: str,
    DestinationSchema: DestinationSchemaTypeDef,  # (4)
    KinesisStreamsOutput: NotRequired[KinesisStreamsOutputTypeDef],  # (1)
    KinesisFirehoseOutput: NotRequired[KinesisFirehoseOutputTypeDef],  # (2)
    LambdaOutput: NotRequired[LambdaOutputTypeDef],  # (3)
  1. See KinesisStreamsOutputTypeDef
  2. See KinesisFirehoseOutputTypeDef
  3. See LambdaOutputTypeDef
  4. See DestinationSchemaTypeDef

OutputUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import OutputUpdateTypeDef

def get_value() -> OutputUpdateTypeDef:
    return {
        "OutputId": ...,
    }
Definition
class OutputUpdateTypeDef(TypedDict):
    OutputId: str,
    NameUpdate: NotRequired[str],
    KinesisStreamsOutputUpdate: NotRequired[KinesisStreamsOutputUpdateTypeDef],  # (1)
    KinesisFirehoseOutputUpdate: NotRequired[KinesisFirehoseOutputUpdateTypeDef],  # (2)
    LambdaOutputUpdate: NotRequired[LambdaOutputUpdateTypeDef],  # (3)
    DestinationSchemaUpdate: NotRequired[DestinationSchemaTypeDef],  # (4)
  1. See KinesisStreamsOutputUpdateTypeDef
  2. See KinesisFirehoseOutputUpdateTypeDef
  3. See LambdaOutputUpdateTypeDef
  4. See DestinationSchemaTypeDef

StartApplicationRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import StartApplicationRequestRequestTypeDef

def get_value() -> StartApplicationRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
        "InputConfigurations": ...,
    }
Definition
class StartApplicationRequestRequestTypeDef(TypedDict):
    ApplicationName: str,
    InputConfigurations: Sequence[InputConfigurationTypeDef],  # (1)
  1. See InputConfigurationTypeDef

AddApplicationInputProcessingConfigurationRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import AddApplicationInputProcessingConfigurationRequestRequestTypeDef

def get_value() -> AddApplicationInputProcessingConfigurationRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
        "CurrentApplicationVersionId": ...,
        "InputId": ...,
        "InputProcessingConfiguration": ...,
    }
Definition
class AddApplicationInputProcessingConfigurationRequestRequestTypeDef(TypedDict):
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    InputId: str,
    InputProcessingConfiguration: InputProcessingConfigurationTypeDef,  # (1)
  1. See InputProcessingConfigurationTypeDef

DiscoverInputSchemaRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import DiscoverInputSchemaRequestRequestTypeDef

def get_value() -> DiscoverInputSchemaRequestRequestTypeDef:
    return {
        "ResourceARN": ...,
    }
Definition
class DiscoverInputSchemaRequestRequestTypeDef(TypedDict):
    ResourceARN: NotRequired[str],
    RoleARN: NotRequired[str],
    InputStartingPositionConfiguration: NotRequired[InputStartingPositionConfigurationTypeDef],  # (1)
    S3Configuration: NotRequired[S3ConfigurationTypeDef],  # (2)
    InputProcessingConfiguration: NotRequired[InputProcessingConfigurationTypeDef],  # (3)
  1. See InputStartingPositionConfigurationTypeDef
  2. See S3ConfigurationTypeDef
  3. See InputProcessingConfigurationTypeDef

RecordFormatTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import RecordFormatTypeDef

def get_value() -> RecordFormatTypeDef:
    return {
        "RecordFormatType": ...,
    }
Definition
class RecordFormatTypeDef(TypedDict):
    RecordFormatType: RecordFormatTypeType,  # (1)
    MappingParameters: NotRequired[MappingParametersTypeDef],  # (2)
  1. See RecordFormatTypeType
  2. See MappingParametersTypeDef

AddApplicationOutputRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import AddApplicationOutputRequestRequestTypeDef

def get_value() -> AddApplicationOutputRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
        "CurrentApplicationVersionId": ...,
        "Output": ...,
    }
Definition
class AddApplicationOutputRequestRequestTypeDef(TypedDict):
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    Output: OutputTypeDef,  # (1)
  1. See OutputTypeDef

InputSchemaUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import InputSchemaUpdateTypeDef

def get_value() -> InputSchemaUpdateTypeDef:
    return {
        "RecordFormatUpdate": ...,
    }
Definition
class InputSchemaUpdateTypeDef(TypedDict):
    RecordFormatUpdate: NotRequired[RecordFormatTypeDef],  # (1)
    RecordEncodingUpdate: NotRequired[str],
    RecordColumnUpdates: NotRequired[Sequence[RecordColumnTypeDef]],  # (2)
  1. See RecordFormatTypeDef
  2. See RecordColumnTypeDef

SourceSchemaTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import SourceSchemaTypeDef

def get_value() -> SourceSchemaTypeDef:
    return {
        "RecordFormat": ...,
        "RecordColumns": ...,
    }
Definition
class SourceSchemaTypeDef(TypedDict):
    RecordFormat: RecordFormatTypeDef,  # (1)
    RecordColumns: Sequence[RecordColumnTypeDef],  # (2)
    RecordEncoding: NotRequired[str],
  1. See RecordFormatTypeDef
  2. See RecordColumnTypeDef

InputUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import InputUpdateTypeDef

def get_value() -> InputUpdateTypeDef:
    return {
        "InputId": ...,
    }
Definition
class InputUpdateTypeDef(TypedDict):
    InputId: str,
    NamePrefixUpdate: NotRequired[str],
    InputProcessingConfigurationUpdate: NotRequired[InputProcessingConfigurationUpdateTypeDef],  # (1)
    KinesisStreamsInputUpdate: NotRequired[KinesisStreamsInputUpdateTypeDef],  # (2)
    KinesisFirehoseInputUpdate: NotRequired[KinesisFirehoseInputUpdateTypeDef],  # (3)
    InputSchemaUpdate: NotRequired[InputSchemaUpdateTypeDef],  # (4)
    InputParallelismUpdate: NotRequired[InputParallelismUpdateTypeDef],  # (5)
  1. See InputProcessingConfigurationUpdateTypeDef
  2. See KinesisStreamsInputUpdateTypeDef
  3. See KinesisFirehoseInputUpdateTypeDef
  4. See InputSchemaUpdateTypeDef
  5. See InputParallelismUpdateTypeDef

DiscoverInputSchemaResponseTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import DiscoverInputSchemaResponseTypeDef

def get_value() -> DiscoverInputSchemaResponseTypeDef:
    return {
        "InputSchema": ...,
        "ParsedInputRecords": ...,
        "ProcessedInputRecords": ...,
        "RawInputRecords": ...,
        "ResponseMetadata": ...,
    }
Definition
class DiscoverInputSchemaResponseTypeDef(TypedDict):
    InputSchema: SourceSchemaTypeDef,  # (1)
    ParsedInputRecords: List[List[str]],
    ProcessedInputRecords: List[str],
    RawInputRecords: List[str],
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See SourceSchemaTypeDef
  2. See ResponseMetadataTypeDef

InputDescriptionTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import InputDescriptionTypeDef

def get_value() -> InputDescriptionTypeDef:
    return {
        "InputId": ...,
    }
Definition
class InputDescriptionTypeDef(TypedDict):
    InputId: NotRequired[str],
    NamePrefix: NotRequired[str],
    InAppStreamNames: NotRequired[List[str]],
    InputProcessingConfigurationDescription: NotRequired[InputProcessingConfigurationDescriptionTypeDef],  # (1)
    KinesisStreamsInputDescription: NotRequired[KinesisStreamsInputDescriptionTypeDef],  # (2)
    KinesisFirehoseInputDescription: NotRequired[KinesisFirehoseInputDescriptionTypeDef],  # (3)
    InputSchema: NotRequired[SourceSchemaTypeDef],  # (4)
    InputParallelism: NotRequired[InputParallelismTypeDef],  # (5)
    InputStartingPositionConfiguration: NotRequired[InputStartingPositionConfigurationTypeDef],  # (6)
  1. See InputProcessingConfigurationDescriptionTypeDef
  2. See KinesisStreamsInputDescriptionTypeDef
  3. See KinesisFirehoseInputDescriptionTypeDef
  4. See SourceSchemaTypeDef
  5. See InputParallelismTypeDef
  6. See InputStartingPositionConfigurationTypeDef

InputTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import InputTypeDef

def get_value() -> InputTypeDef:
    return {
        "NamePrefix": ...,
        "InputSchema": ...,
    }
Definition
class InputTypeDef(TypedDict):
    NamePrefix: str,
    InputSchema: SourceSchemaTypeDef,  # (5)
    InputProcessingConfiguration: NotRequired[InputProcessingConfigurationTypeDef],  # (1)
    KinesisStreamsInput: NotRequired[KinesisStreamsInputTypeDef],  # (2)
    KinesisFirehoseInput: NotRequired[KinesisFirehoseInputTypeDef],  # (3)
    InputParallelism: NotRequired[InputParallelismTypeDef],  # (4)
  1. See InputProcessingConfigurationTypeDef
  2. See KinesisStreamsInputTypeDef
  3. See KinesisFirehoseInputTypeDef
  4. See InputParallelismTypeDef
  5. See SourceSchemaTypeDef

ReferenceDataSourceDescriptionTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import ReferenceDataSourceDescriptionTypeDef

def get_value() -> ReferenceDataSourceDescriptionTypeDef:
    return {
        "ReferenceId": ...,
        "TableName": ...,
        "S3ReferenceDataSourceDescription": ...,
    }
Definition
class ReferenceDataSourceDescriptionTypeDef(TypedDict):
    ReferenceId: str,
    TableName: str,
    S3ReferenceDataSourceDescription: S3ReferenceDataSourceDescriptionTypeDef,  # (1)
    ReferenceSchema: NotRequired[SourceSchemaTypeDef],  # (2)
  1. See S3ReferenceDataSourceDescriptionTypeDef
  2. See SourceSchemaTypeDef

ReferenceDataSourceTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import ReferenceDataSourceTypeDef

def get_value() -> ReferenceDataSourceTypeDef:
    return {
        "TableName": ...,
        "ReferenceSchema": ...,
    }
Definition
class ReferenceDataSourceTypeDef(TypedDict):
    TableName: str,
    ReferenceSchema: SourceSchemaTypeDef,  # (2)
    S3ReferenceDataSource: NotRequired[S3ReferenceDataSourceTypeDef],  # (1)
  1. See S3ReferenceDataSourceTypeDef
  2. See SourceSchemaTypeDef

ReferenceDataSourceUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import ReferenceDataSourceUpdateTypeDef

def get_value() -> ReferenceDataSourceUpdateTypeDef:
    return {
        "ReferenceId": ...,
    }
Definition
class ReferenceDataSourceUpdateTypeDef(TypedDict):
    ReferenceId: str,
    TableNameUpdate: NotRequired[str],
    S3ReferenceDataSourceUpdate: NotRequired[S3ReferenceDataSourceUpdateTypeDef],  # (1)
    ReferenceSchemaUpdate: NotRequired[SourceSchemaTypeDef],  # (2)
  1. See S3ReferenceDataSourceUpdateTypeDef
  2. See SourceSchemaTypeDef

AddApplicationInputRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import AddApplicationInputRequestRequestTypeDef

def get_value() -> AddApplicationInputRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
        "CurrentApplicationVersionId": ...,
        "Input": ...,
    }
Definition
class AddApplicationInputRequestRequestTypeDef(TypedDict):
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    Input: InputTypeDef,  # (1)
  1. See InputTypeDef

CreateApplicationRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import CreateApplicationRequestRequestTypeDef

def get_value() -> CreateApplicationRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
    }
Definition
class CreateApplicationRequestRequestTypeDef(TypedDict):
    ApplicationName: str,
    ApplicationDescription: NotRequired[str],
    Inputs: NotRequired[Sequence[InputTypeDef]],  # (1)
    Outputs: NotRequired[Sequence[OutputTypeDef]],  # (2)
    CloudWatchLoggingOptions: NotRequired[Sequence[CloudWatchLoggingOptionTypeDef]],  # (3)
    ApplicationCode: NotRequired[str],
    Tags: NotRequired[Sequence[TagTypeDef]],  # (4)
  1. See InputTypeDef
  2. See OutputTypeDef
  3. See CloudWatchLoggingOptionTypeDef
  4. See TagTypeDef

ApplicationDetailTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import ApplicationDetailTypeDef

def get_value() -> ApplicationDetailTypeDef:
    return {
        "ApplicationName": ...,
        "ApplicationARN": ...,
        "ApplicationStatus": ...,
        "ApplicationVersionId": ...,
    }
Definition
class ApplicationDetailTypeDef(TypedDict):
    ApplicationName: str,
    ApplicationARN: str,
    ApplicationStatus: ApplicationStatusType,  # (1)
    ApplicationVersionId: int,
    ApplicationDescription: NotRequired[str],
    CreateTimestamp: NotRequired[datetime],
    LastUpdateTimestamp: NotRequired[datetime],
    InputDescriptions: NotRequired[List[InputDescriptionTypeDef]],  # (2)
    OutputDescriptions: NotRequired[List[OutputDescriptionTypeDef]],  # (3)
    ReferenceDataSourceDescriptions: NotRequired[List[ReferenceDataSourceDescriptionTypeDef]],  # (4)
    CloudWatchLoggingOptionDescriptions: NotRequired[List[CloudWatchLoggingOptionDescriptionTypeDef]],  # (5)
    ApplicationCode: NotRequired[str],
  1. See ApplicationStatusType
  2. See InputDescriptionTypeDef
  3. See OutputDescriptionTypeDef
  4. See ReferenceDataSourceDescriptionTypeDef
  5. See CloudWatchLoggingOptionDescriptionTypeDef

AddApplicationReferenceDataSourceRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import AddApplicationReferenceDataSourceRequestRequestTypeDef

def get_value() -> AddApplicationReferenceDataSourceRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
        "CurrentApplicationVersionId": ...,
        "ReferenceDataSource": ...,
    }
Definition
class AddApplicationReferenceDataSourceRequestRequestTypeDef(TypedDict):
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    ReferenceDataSource: ReferenceDataSourceTypeDef,  # (1)
  1. See ReferenceDataSourceTypeDef

ApplicationUpdateTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import ApplicationUpdateTypeDef

def get_value() -> ApplicationUpdateTypeDef:
    return {
        "InputUpdates": ...,
    }
Definition
class ApplicationUpdateTypeDef(TypedDict):
    InputUpdates: NotRequired[Sequence[InputUpdateTypeDef]],  # (1)
    ApplicationCodeUpdate: NotRequired[str],
    OutputUpdates: NotRequired[Sequence[OutputUpdateTypeDef]],  # (2)
    ReferenceDataSourceUpdates: NotRequired[Sequence[ReferenceDataSourceUpdateTypeDef]],  # (3)
    CloudWatchLoggingOptionUpdates: NotRequired[Sequence[CloudWatchLoggingOptionUpdateTypeDef]],  # (4)
  1. See InputUpdateTypeDef
  2. See OutputUpdateTypeDef
  3. See ReferenceDataSourceUpdateTypeDef
  4. See CloudWatchLoggingOptionUpdateTypeDef

DescribeApplicationResponseTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import DescribeApplicationResponseTypeDef

def get_value() -> DescribeApplicationResponseTypeDef:
    return {
        "ApplicationDetail": ...,
        "ResponseMetadata": ...,
    }
Definition
class DescribeApplicationResponseTypeDef(TypedDict):
    ApplicationDetail: ApplicationDetailTypeDef,  # (1)
    ResponseMetadata: ResponseMetadataTypeDef,  # (2)
  1. See ApplicationDetailTypeDef
  2. See ResponseMetadataTypeDef

UpdateApplicationRequestRequestTypeDef

Usage Example
from types_aiobotocore_kinesisanalytics.type_defs import UpdateApplicationRequestRequestTypeDef

def get_value() -> UpdateApplicationRequestRequestTypeDef:
    return {
        "ApplicationName": ...,
        "CurrentApplicationVersionId": ...,
        "ApplicationUpdate": ...,
    }
Definition
class UpdateApplicationRequestRequestTypeDef(TypedDict):
    ApplicationName: str,
    CurrentApplicationVersionId: int,
    ApplicationUpdate: ApplicationUpdateTypeDef,  # (1)
  1. See ApplicationUpdateTypeDef