Type definitions#
Index > IoTAnalytics > Type definitions
Auto-generated documentation for IoTAnalytics type annotations stubs module types-boto3-iotanalytics.
BlobTypeDef#
# BlobTypeDef definition
BlobTypeDef = Union[
str,
bytes,
IO[Any],
StreamingBody,
]
TimestampTypeDef#
# TimestampTypeDef definition
TimestampTypeDef = Union[
datetime,
str,
]
AddAttributesActivityUnionTypeDef#
# AddAttributesActivityUnionTypeDef definition
AddAttributesActivityUnionTypeDef = Union[
AddAttributesActivityTypeDef, # (1)
AddAttributesActivityOutputTypeDef, # (2)
]
RemoveAttributesActivityUnionTypeDef#
# RemoveAttributesActivityUnionTypeDef definition
RemoveAttributesActivityUnionTypeDef = Union[
RemoveAttributesActivityTypeDef, # (1)
RemoveAttributesActivityOutputTypeDef, # (2)
]
SelectAttributesActivityUnionTypeDef#
# SelectAttributesActivityUnionTypeDef definition
SelectAttributesActivityUnionTypeDef = Union[
SelectAttributesActivityTypeDef, # (1)
SelectAttributesActivityOutputTypeDef, # (2)
]
SchemaDefinitionUnionTypeDef#
# SchemaDefinitionUnionTypeDef definition
SchemaDefinitionUnionTypeDef = Union[
SchemaDefinitionTypeDef, # (1)
SchemaDefinitionOutputTypeDef, # (2)
]
SqlQueryDatasetActionUnionTypeDef#
# SqlQueryDatasetActionUnionTypeDef definition
SqlQueryDatasetActionUnionTypeDef = Union[
SqlQueryDatasetActionTypeDef, # (1)
SqlQueryDatasetActionOutputTypeDef, # (2)
]
ContainerDatasetActionUnionTypeDef#
# ContainerDatasetActionUnionTypeDef definition
ContainerDatasetActionUnionTypeDef = Union[
ContainerDatasetActionTypeDef, # (1)
ContainerDatasetActionOutputTypeDef, # (2)
]
PipelineActivityUnionTypeDef#
# PipelineActivityUnionTypeDef definition
PipelineActivityUnionTypeDef = Union[
PipelineActivityTypeDef, # (1)
PipelineActivityOutputTypeDef, # (2)
]
ParquetConfigurationUnionTypeDef#
# ParquetConfigurationUnionTypeDef definition
ParquetConfigurationUnionTypeDef = Union[
ParquetConfigurationTypeDef, # (1)
ParquetConfigurationOutputTypeDef, # (2)
]
DatasetActionUnionTypeDef#
# DatasetActionUnionTypeDef definition
DatasetActionUnionTypeDef = Union[
DatasetActionTypeDef, # (1)
DatasetActionOutputTypeDef, # (2)
]
AddAttributesActivityOutputTypeDef#
# AddAttributesActivityOutputTypeDef definition
class AddAttributesActivityOutputTypeDef(TypedDict):
name: str,
attributes: dict[str, str],
next: NotRequired[str],
AddAttributesActivityTypeDef#
# AddAttributesActivityTypeDef definition
class AddAttributesActivityTypeDef(TypedDict):
name: str,
attributes: Mapping[str, str],
next: NotRequired[str],
BatchPutMessageErrorEntryTypeDef#
# BatchPutMessageErrorEntryTypeDef definition
class BatchPutMessageErrorEntryTypeDef(TypedDict):
messageId: NotRequired[str],
errorCode: NotRequired[str],
errorMessage: NotRequired[str],
ResponseMetadataTypeDef#
# ResponseMetadataTypeDef definition
class ResponseMetadataTypeDef(TypedDict):
RequestId: str,
HTTPStatusCode: int,
HTTPHeaders: dict[str, str],
RetryAttempts: int,
HostId: NotRequired[str],
CancelPipelineReprocessingRequestRequestTypeDef#
# CancelPipelineReprocessingRequestRequestTypeDef definition
class CancelPipelineReprocessingRequestRequestTypeDef(TypedDict):
pipelineName: str,
reprocessingId: str,
ChannelActivityTypeDef#
# ChannelActivityTypeDef definition
class ChannelActivityTypeDef(TypedDict):
name: str,
channelName: str,
next: NotRequired[str],
ChannelMessagesTypeDef#
# ChannelMessagesTypeDef definition
class ChannelMessagesTypeDef(TypedDict):
s3Paths: NotRequired[Sequence[str]],
EstimatedResourceSizeTypeDef#
# EstimatedResourceSizeTypeDef definition
class EstimatedResourceSizeTypeDef(TypedDict):
estimatedSizeInBytes: NotRequired[float],
estimatedOn: NotRequired[datetime],
CustomerManagedChannelS3StorageTypeDef#
# CustomerManagedChannelS3StorageTypeDef definition
class CustomerManagedChannelS3StorageTypeDef(TypedDict):
bucket: str,
roleArn: str,
keyPrefix: NotRequired[str],
CustomerManagedChannelS3StorageSummaryTypeDef#
# CustomerManagedChannelS3StorageSummaryTypeDef definition
class CustomerManagedChannelS3StorageSummaryTypeDef(TypedDict):
bucket: NotRequired[str],
keyPrefix: NotRequired[str],
roleArn: NotRequired[str],
RetentionPeriodTypeDef#
# RetentionPeriodTypeDef definition
class RetentionPeriodTypeDef(TypedDict):
unlimited: NotRequired[bool],
numberOfDays: NotRequired[int],
ColumnTypeDef#
# ColumnTypeDef definition
class ColumnTypeDef(TypedDict):
name: str,
type: str,
ResourceConfigurationTypeDef#
# ResourceConfigurationTypeDef definition
class ResourceConfigurationTypeDef(TypedDict):
computeType: ComputeTypeType, # (1)
volumeSizeInGB: int,
- See ComputeTypeType
TagTypeDef#
# TagTypeDef definition
class TagTypeDef(TypedDict):
key: str,
value: str,
CreateDatasetContentRequestRequestTypeDef#
# CreateDatasetContentRequestRequestTypeDef definition
class CreateDatasetContentRequestRequestTypeDef(TypedDict):
datasetName: str,
versionId: NotRequired[str],
VersioningConfigurationTypeDef#
# VersioningConfigurationTypeDef definition
class VersioningConfigurationTypeDef(TypedDict):
unlimited: NotRequired[bool],
maxVersions: NotRequired[int],
CustomerManagedDatastoreS3StorageSummaryTypeDef#
# CustomerManagedDatastoreS3StorageSummaryTypeDef definition
class CustomerManagedDatastoreS3StorageSummaryTypeDef(TypedDict):
bucket: NotRequired[str],
keyPrefix: NotRequired[str],
roleArn: NotRequired[str],
CustomerManagedDatastoreS3StorageTypeDef#
# CustomerManagedDatastoreS3StorageTypeDef definition
class CustomerManagedDatastoreS3StorageTypeDef(TypedDict):
bucket: str,
roleArn: str,
keyPrefix: NotRequired[str],
DatasetActionSummaryTypeDef#
# DatasetActionSummaryTypeDef definition
class DatasetActionSummaryTypeDef(TypedDict):
actionName: NotRequired[str],
actionType: NotRequired[DatasetActionTypeType], # (1)
IotEventsDestinationConfigurationTypeDef#
# IotEventsDestinationConfigurationTypeDef definition
class IotEventsDestinationConfigurationTypeDef(TypedDict):
inputName: str,
roleArn: str,
DatasetContentStatusTypeDef#
# DatasetContentStatusTypeDef definition
class DatasetContentStatusTypeDef(TypedDict):
state: NotRequired[DatasetContentStateType], # (1)
reason: NotRequired[str],
DatasetContentVersionValueTypeDef#
# DatasetContentVersionValueTypeDef definition
class DatasetContentVersionValueTypeDef(TypedDict):
datasetName: str,
DatasetEntryTypeDef#
# DatasetEntryTypeDef definition
class DatasetEntryTypeDef(TypedDict):
entryName: NotRequired[str],
dataURI: NotRequired[str],
ScheduleTypeDef#
# ScheduleTypeDef definition
class ScheduleTypeDef(TypedDict):
expression: NotRequired[str],
TriggeringDatasetTypeDef#
# TriggeringDatasetTypeDef definition
class TriggeringDatasetTypeDef(TypedDict):
name: str,
DatastoreActivityTypeDef#
# DatastoreActivityTypeDef definition
class DatastoreActivityTypeDef(TypedDict):
name: str,
datastoreName: str,
IotSiteWiseCustomerManagedDatastoreS3StorageSummaryTypeDef#
# IotSiteWiseCustomerManagedDatastoreS3StorageSummaryTypeDef definition
class IotSiteWiseCustomerManagedDatastoreS3StorageSummaryTypeDef(TypedDict):
bucket: NotRequired[str],
keyPrefix: NotRequired[str],
IotSiteWiseCustomerManagedDatastoreS3StorageTypeDef#
# IotSiteWiseCustomerManagedDatastoreS3StorageTypeDef definition
class IotSiteWiseCustomerManagedDatastoreS3StorageTypeDef(TypedDict):
bucket: str,
keyPrefix: NotRequired[str],
PartitionTypeDef#
# PartitionTypeDef definition
class PartitionTypeDef(TypedDict):
attributeName: str,
TimestampPartitionTypeDef#
# TimestampPartitionTypeDef definition
class TimestampPartitionTypeDef(TypedDict):
attributeName: str,
timestampFormat: NotRequired[str],
DeleteChannelRequestRequestTypeDef#
# DeleteChannelRequestRequestTypeDef definition
class DeleteChannelRequestRequestTypeDef(TypedDict):
channelName: str,
DeleteDatasetContentRequestRequestTypeDef#
# DeleteDatasetContentRequestRequestTypeDef definition
class DeleteDatasetContentRequestRequestTypeDef(TypedDict):
datasetName: str,
versionId: NotRequired[str],
DeleteDatasetRequestRequestTypeDef#
# DeleteDatasetRequestRequestTypeDef definition
class DeleteDatasetRequestRequestTypeDef(TypedDict):
datasetName: str,
DeleteDatastoreRequestRequestTypeDef#
# DeleteDatastoreRequestRequestTypeDef definition
class DeleteDatastoreRequestRequestTypeDef(TypedDict):
datastoreName: str,
DeletePipelineRequestRequestTypeDef#
# DeletePipelineRequestRequestTypeDef definition
class DeletePipelineRequestRequestTypeDef(TypedDict):
pipelineName: str,
DeltaTimeSessionWindowConfigurationTypeDef#
# DeltaTimeSessionWindowConfigurationTypeDef definition
class DeltaTimeSessionWindowConfigurationTypeDef(TypedDict):
timeoutInMinutes: int,
DeltaTimeTypeDef#
# DeltaTimeTypeDef definition
class DeltaTimeTypeDef(TypedDict):
offsetSeconds: int,
timeExpression: str,
DescribeChannelRequestRequestTypeDef#
# DescribeChannelRequestRequestTypeDef definition
class DescribeChannelRequestRequestTypeDef(TypedDict):
channelName: str,
includeStatistics: NotRequired[bool],
DescribeDatasetRequestRequestTypeDef#
# DescribeDatasetRequestRequestTypeDef definition
class DescribeDatasetRequestRequestTypeDef(TypedDict):
datasetName: str,
DescribeDatastoreRequestRequestTypeDef#
# DescribeDatastoreRequestRequestTypeDef definition
class DescribeDatastoreRequestRequestTypeDef(TypedDict):
datastoreName: str,
includeStatistics: NotRequired[bool],
LoggingOptionsTypeDef#
# LoggingOptionsTypeDef definition
class LoggingOptionsTypeDef(TypedDict):
roleArn: str,
level: LoggingLevelType, # (1)
enabled: bool,
- See LoggingLevelType
DescribePipelineRequestRequestTypeDef#
# DescribePipelineRequestRequestTypeDef definition
class DescribePipelineRequestRequestTypeDef(TypedDict):
pipelineName: str,
DeviceRegistryEnrichActivityTypeDef#
# DeviceRegistryEnrichActivityTypeDef definition
class DeviceRegistryEnrichActivityTypeDef(TypedDict):
name: str,
attribute: str,
thingName: str,
roleArn: str,
next: NotRequired[str],
DeviceShadowEnrichActivityTypeDef#
# DeviceShadowEnrichActivityTypeDef definition
class DeviceShadowEnrichActivityTypeDef(TypedDict):
name: str,
attribute: str,
thingName: str,
roleArn: str,
next: NotRequired[str],
FilterActivityTypeDef#
# FilterActivityTypeDef definition
class FilterActivityTypeDef(TypedDict):
name: str,
filter: str,
next: NotRequired[str],
GetDatasetContentRequestRequestTypeDef#
# GetDatasetContentRequestRequestTypeDef definition
class GetDatasetContentRequestRequestTypeDef(TypedDict):
datasetName: str,
versionId: NotRequired[str],
GlueConfigurationTypeDef#
# GlueConfigurationTypeDef definition
class GlueConfigurationTypeDef(TypedDict):
tableName: str,
databaseName: str,
LambdaActivityTypeDef#
# LambdaActivityTypeDef definition
class LambdaActivityTypeDef(TypedDict):
name: str,
lambdaName: str,
batchSize: int,
next: NotRequired[str],
PaginatorConfigTypeDef#
# PaginatorConfigTypeDef definition
class PaginatorConfigTypeDef(TypedDict):
MaxItems: NotRequired[int],
PageSize: NotRequired[int],
StartingToken: NotRequired[str],
ListChannelsRequestRequestTypeDef#
# ListChannelsRequestRequestTypeDef definition
class ListChannelsRequestRequestTypeDef(TypedDict):
nextToken: NotRequired[str],
maxResults: NotRequired[int],
ListDatasetsRequestRequestTypeDef#
# ListDatasetsRequestRequestTypeDef definition
class ListDatasetsRequestRequestTypeDef(TypedDict):
nextToken: NotRequired[str],
maxResults: NotRequired[int],
ListDatastoresRequestRequestTypeDef#
# ListDatastoresRequestRequestTypeDef definition
class ListDatastoresRequestRequestTypeDef(TypedDict):
nextToken: NotRequired[str],
maxResults: NotRequired[int],
ListPipelinesRequestRequestTypeDef#
# ListPipelinesRequestRequestTypeDef definition
class ListPipelinesRequestRequestTypeDef(TypedDict):
nextToken: NotRequired[str],
maxResults: NotRequired[int],
ListTagsForResourceRequestRequestTypeDef#
# ListTagsForResourceRequestRequestTypeDef definition
class ListTagsForResourceRequestRequestTypeDef(TypedDict):
resourceArn: str,
MathActivityTypeDef#
# MathActivityTypeDef definition
class MathActivityTypeDef(TypedDict):
name: str,
attribute: str,
math: str,
next: NotRequired[str],
OutputFileUriValueTypeDef#
# OutputFileUriValueTypeDef definition
class OutputFileUriValueTypeDef(TypedDict):
fileName: str,
RemoveAttributesActivityOutputTypeDef#
# RemoveAttributesActivityOutputTypeDef definition
class RemoveAttributesActivityOutputTypeDef(TypedDict):
name: str,
attributes: list[str],
next: NotRequired[str],
SelectAttributesActivityOutputTypeDef#
# SelectAttributesActivityOutputTypeDef definition
class SelectAttributesActivityOutputTypeDef(TypedDict):
name: str,
attributes: list[str],
next: NotRequired[str],
ReprocessingSummaryTypeDef#
# ReprocessingSummaryTypeDef definition
class ReprocessingSummaryTypeDef(TypedDict):
id: NotRequired[str],
status: NotRequired[ReprocessingStatusType], # (1)
creationTime: NotRequired[datetime],
RemoveAttributesActivityTypeDef#
# RemoveAttributesActivityTypeDef definition
class RemoveAttributesActivityTypeDef(TypedDict):
name: str,
attributes: Sequence[str],
next: NotRequired[str],
SelectAttributesActivityTypeDef#
# SelectAttributesActivityTypeDef definition
class SelectAttributesActivityTypeDef(TypedDict):
name: str,
attributes: Sequence[str],
next: NotRequired[str],
UntagResourceRequestRequestTypeDef#
# UntagResourceRequestRequestTypeDef definition
class UntagResourceRequestRequestTypeDef(TypedDict):
resourceArn: str,
tagKeys: Sequence[str],
BatchPutMessageResponseTypeDef#
# BatchPutMessageResponseTypeDef definition
class BatchPutMessageResponseTypeDef(TypedDict):
batchPutMessageErrorEntries: list[BatchPutMessageErrorEntryTypeDef], # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
CreateDatasetContentResponseTypeDef#
# CreateDatasetContentResponseTypeDef definition
class CreateDatasetContentResponseTypeDef(TypedDict):
versionId: str,
ResponseMetadata: ResponseMetadataTypeDef, # (1)
CreatePipelineResponseTypeDef#
# CreatePipelineResponseTypeDef definition
class CreatePipelineResponseTypeDef(TypedDict):
pipelineName: str,
pipelineArn: str,
ResponseMetadata: ResponseMetadataTypeDef, # (1)
EmptyResponseMetadataTypeDef#
# EmptyResponseMetadataTypeDef definition
class EmptyResponseMetadataTypeDef(TypedDict):
ResponseMetadata: ResponseMetadataTypeDef, # (1)
RunPipelineActivityResponseTypeDef#
# RunPipelineActivityResponseTypeDef definition
class RunPipelineActivityResponseTypeDef(TypedDict):
payloads: list[bytes],
logResult: str,
ResponseMetadata: ResponseMetadataTypeDef, # (1)
SampleChannelDataResponseTypeDef#
# SampleChannelDataResponseTypeDef definition
class SampleChannelDataResponseTypeDef(TypedDict):
payloads: list[bytes],
ResponseMetadata: ResponseMetadataTypeDef, # (1)
StartPipelineReprocessingResponseTypeDef#
# StartPipelineReprocessingResponseTypeDef definition
class StartPipelineReprocessingResponseTypeDef(TypedDict):
reprocessingId: str,
ResponseMetadata: ResponseMetadataTypeDef, # (1)
MessageTypeDef#
# MessageTypeDef definition
class MessageTypeDef(TypedDict):
messageId: str,
payload: BlobTypeDef,
ChannelStatisticsTypeDef#
# ChannelStatisticsTypeDef definition
class ChannelStatisticsTypeDef(TypedDict):
size: NotRequired[EstimatedResourceSizeTypeDef], # (1)
DatastoreStatisticsTypeDef#
# DatastoreStatisticsTypeDef definition
class DatastoreStatisticsTypeDef(TypedDict):
size: NotRequired[EstimatedResourceSizeTypeDef], # (1)
ChannelStorageOutputTypeDef#
# ChannelStorageOutputTypeDef definition
class ChannelStorageOutputTypeDef(TypedDict):
serviceManagedS3: NotRequired[dict[str, Any]],
customerManagedS3: NotRequired[CustomerManagedChannelS3StorageTypeDef], # (1)
ChannelStorageTypeDef#
# ChannelStorageTypeDef definition
class ChannelStorageTypeDef(TypedDict):
serviceManagedS3: NotRequired[Mapping[str, Any]],
customerManagedS3: NotRequired[CustomerManagedChannelS3StorageTypeDef], # (1)
ChannelStorageSummaryTypeDef#
# ChannelStorageSummaryTypeDef definition
class ChannelStorageSummaryTypeDef(TypedDict):
serviceManagedS3: NotRequired[dict[str, Any]],
customerManagedS3: NotRequired[CustomerManagedChannelS3StorageSummaryTypeDef], # (1)
CreateChannelResponseTypeDef#
# CreateChannelResponseTypeDef definition
class CreateChannelResponseTypeDef(TypedDict):
channelName: str,
channelArn: str,
retentionPeriod: RetentionPeriodTypeDef, # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
CreateDatasetResponseTypeDef#
# CreateDatasetResponseTypeDef definition
class CreateDatasetResponseTypeDef(TypedDict):
datasetName: str,
datasetArn: str,
retentionPeriod: RetentionPeriodTypeDef, # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
CreateDatastoreResponseTypeDef#
# CreateDatastoreResponseTypeDef definition
class CreateDatastoreResponseTypeDef(TypedDict):
datastoreName: str,
datastoreArn: str,
retentionPeriod: RetentionPeriodTypeDef, # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
SchemaDefinitionOutputTypeDef#
# SchemaDefinitionOutputTypeDef definition
class SchemaDefinitionOutputTypeDef(TypedDict):
columns: NotRequired[list[ColumnTypeDef]], # (1)
- See ColumnTypeDef
SchemaDefinitionTypeDef#
# SchemaDefinitionTypeDef definition
class SchemaDefinitionTypeDef(TypedDict):
columns: NotRequired[Sequence[ColumnTypeDef]], # (1)
- See ColumnTypeDef
ListTagsForResourceResponseTypeDef#
# ListTagsForResourceResponseTypeDef definition
class ListTagsForResourceResponseTypeDef(TypedDict):
tags: list[TagTypeDef], # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
- See TagTypeDef
- See ResponseMetadataTypeDef
TagResourceRequestRequestTypeDef#
# TagResourceRequestRequestTypeDef definition
class TagResourceRequestRequestTypeDef(TypedDict):
resourceArn: str,
tags: Sequence[TagTypeDef], # (1)
- See TagTypeDef
DatasetContentSummaryTypeDef#
# DatasetContentSummaryTypeDef definition
class DatasetContentSummaryTypeDef(TypedDict):
version: NotRequired[str],
status: NotRequired[DatasetContentStatusTypeDef], # (1)
creationTime: NotRequired[datetime],
scheduleTime: NotRequired[datetime],
completionTime: NotRequired[datetime],
GetDatasetContentResponseTypeDef#
# GetDatasetContentResponseTypeDef definition
class GetDatasetContentResponseTypeDef(TypedDict):
entries: list[DatasetEntryTypeDef], # (1)
timestamp: datetime,
status: DatasetContentStatusTypeDef, # (2)
ResponseMetadata: ResponseMetadataTypeDef, # (3)
DatasetTriggerTypeDef#
# DatasetTriggerTypeDef definition
class DatasetTriggerTypeDef(TypedDict):
schedule: NotRequired[ScheduleTypeDef], # (1)
dataset: NotRequired[TriggeringDatasetTypeDef], # (2)
DatastoreIotSiteWiseMultiLayerStorageSummaryTypeDef#
# DatastoreIotSiteWiseMultiLayerStorageSummaryTypeDef definition
class DatastoreIotSiteWiseMultiLayerStorageSummaryTypeDef(TypedDict):
customerManagedS3Storage: NotRequired[IotSiteWiseCustomerManagedDatastoreS3StorageSummaryTypeDef], # (1)
DatastoreIotSiteWiseMultiLayerStorageTypeDef#
# DatastoreIotSiteWiseMultiLayerStorageTypeDef definition
class DatastoreIotSiteWiseMultiLayerStorageTypeDef(TypedDict):
customerManagedS3Storage: IotSiteWiseCustomerManagedDatastoreS3StorageTypeDef, # (1)
DatastorePartitionTypeDef#
# DatastorePartitionTypeDef definition
class DatastorePartitionTypeDef(TypedDict):
attributePartition: NotRequired[PartitionTypeDef], # (1)
timestampPartition: NotRequired[TimestampPartitionTypeDef], # (2)
LateDataRuleConfigurationTypeDef#
# LateDataRuleConfigurationTypeDef definition
class LateDataRuleConfigurationTypeDef(TypedDict):
deltaTimeSessionWindowConfiguration: NotRequired[DeltaTimeSessionWindowConfigurationTypeDef], # (1)
QueryFilterTypeDef#
# QueryFilterTypeDef definition
class QueryFilterTypeDef(TypedDict):
deltaTime: NotRequired[DeltaTimeTypeDef], # (1)
- See DeltaTimeTypeDef
DescribeLoggingOptionsResponseTypeDef#
# DescribeLoggingOptionsResponseTypeDef definition
class DescribeLoggingOptionsResponseTypeDef(TypedDict):
loggingOptions: LoggingOptionsTypeDef, # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
PutLoggingOptionsRequestRequestTypeDef#
# PutLoggingOptionsRequestRequestTypeDef definition
class PutLoggingOptionsRequestRequestTypeDef(TypedDict):
loggingOptions: LoggingOptionsTypeDef, # (1)
S3DestinationConfigurationTypeDef#
# S3DestinationConfigurationTypeDef definition
class S3DestinationConfigurationTypeDef(TypedDict):
bucket: str,
key: str,
roleArn: str,
glueConfiguration: NotRequired[GlueConfigurationTypeDef], # (1)
ListChannelsRequestPaginateTypeDef#
# ListChannelsRequestPaginateTypeDef definition
class ListChannelsRequestPaginateTypeDef(TypedDict):
PaginationConfig: NotRequired[PaginatorConfigTypeDef], # (1)
ListDatasetsRequestPaginateTypeDef#
# ListDatasetsRequestPaginateTypeDef definition
class ListDatasetsRequestPaginateTypeDef(TypedDict):
PaginationConfig: NotRequired[PaginatorConfigTypeDef], # (1)
ListDatastoresRequestPaginateTypeDef#
# ListDatastoresRequestPaginateTypeDef definition
class ListDatastoresRequestPaginateTypeDef(TypedDict):
PaginationConfig: NotRequired[PaginatorConfigTypeDef], # (1)
ListPipelinesRequestPaginateTypeDef#
# ListPipelinesRequestPaginateTypeDef definition
class ListPipelinesRequestPaginateTypeDef(TypedDict):
PaginationConfig: NotRequired[PaginatorConfigTypeDef], # (1)
ListDatasetContentsRequestPaginateTypeDef#
# ListDatasetContentsRequestPaginateTypeDef definition
class ListDatasetContentsRequestPaginateTypeDef(TypedDict):
datasetName: str,
scheduledOnOrAfter: NotRequired[TimestampTypeDef],
scheduledBefore: NotRequired[TimestampTypeDef],
PaginationConfig: NotRequired[PaginatorConfigTypeDef], # (1)
ListDatasetContentsRequestRequestTypeDef#
# ListDatasetContentsRequestRequestTypeDef definition
class ListDatasetContentsRequestRequestTypeDef(TypedDict):
datasetName: str,
nextToken: NotRequired[str],
maxResults: NotRequired[int],
scheduledOnOrAfter: NotRequired[TimestampTypeDef],
scheduledBefore: NotRequired[TimestampTypeDef],
SampleChannelDataRequestRequestTypeDef#
# SampleChannelDataRequestRequestTypeDef definition
class SampleChannelDataRequestRequestTypeDef(TypedDict):
channelName: str,
maxMessages: NotRequired[int],
startTime: NotRequired[TimestampTypeDef],
endTime: NotRequired[TimestampTypeDef],
StartPipelineReprocessingRequestRequestTypeDef#
# StartPipelineReprocessingRequestRequestTypeDef definition
class StartPipelineReprocessingRequestRequestTypeDef(TypedDict):
pipelineName: str,
startTime: NotRequired[TimestampTypeDef],
endTime: NotRequired[TimestampTypeDef],
channelMessages: NotRequired[ChannelMessagesTypeDef], # (1)
VariableTypeDef#
# VariableTypeDef definition
class VariableTypeDef(TypedDict):
name: str,
stringValue: NotRequired[str],
doubleValue: NotRequired[float],
datasetContentVersionValue: NotRequired[DatasetContentVersionValueTypeDef], # (1)
outputFileUriValue: NotRequired[OutputFileUriValueTypeDef], # (2)
PipelineActivityOutputTypeDef#
# PipelineActivityOutputTypeDef definition
class PipelineActivityOutputTypeDef(TypedDict):
channel: NotRequired[ChannelActivityTypeDef], # (1)
lambda: NotRequired[LambdaActivityTypeDef], # (2)
datastore: NotRequired[DatastoreActivityTypeDef], # (3)
addAttributes: NotRequired[AddAttributesActivityOutputTypeDef], # (4)
removeAttributes: NotRequired[RemoveAttributesActivityOutputTypeDef], # (5)
selectAttributes: NotRequired[SelectAttributesActivityOutputTypeDef], # (6)
filter: NotRequired[FilterActivityTypeDef], # (7)
math: NotRequired[MathActivityTypeDef], # (8)
deviceRegistryEnrich: NotRequired[DeviceRegistryEnrichActivityTypeDef], # (9)
deviceShadowEnrich: NotRequired[DeviceShadowEnrichActivityTypeDef], # (10)
- See ChannelActivityTypeDef
- See LambdaActivityTypeDef
- See DatastoreActivityTypeDef
- See AddAttributesActivityOutputTypeDef
- See RemoveAttributesActivityOutputTypeDef
- See SelectAttributesActivityOutputTypeDef
- See FilterActivityTypeDef
- See MathActivityTypeDef
- See DeviceRegistryEnrichActivityTypeDef
- See DeviceShadowEnrichActivityTypeDef
PipelineSummaryTypeDef#
# PipelineSummaryTypeDef definition
class PipelineSummaryTypeDef(TypedDict):
pipelineName: NotRequired[str],
reprocessingSummaries: NotRequired[list[ReprocessingSummaryTypeDef]], # (1)
creationTime: NotRequired[datetime],
lastUpdateTime: NotRequired[datetime],
BatchPutMessageRequestRequestTypeDef#
# BatchPutMessageRequestRequestTypeDef definition
class BatchPutMessageRequestRequestTypeDef(TypedDict):
channelName: str,
messages: Sequence[MessageTypeDef], # (1)
- See MessageTypeDef
ChannelTypeDef#
# ChannelTypeDef definition
class ChannelTypeDef(TypedDict):
name: NotRequired[str],
storage: NotRequired[ChannelStorageOutputTypeDef], # (1)
arn: NotRequired[str],
status: NotRequired[ChannelStatusType], # (2)
retentionPeriod: NotRequired[RetentionPeriodTypeDef], # (3)
creationTime: NotRequired[datetime],
lastUpdateTime: NotRequired[datetime],
lastMessageArrivalTime: NotRequired[datetime],
CreateChannelRequestRequestTypeDef#
# CreateChannelRequestRequestTypeDef definition
class CreateChannelRequestRequestTypeDef(TypedDict):
channelName: str,
channelStorage: NotRequired[ChannelStorageTypeDef], # (1)
retentionPeriod: NotRequired[RetentionPeriodTypeDef], # (2)
tags: NotRequired[Sequence[TagTypeDef]], # (3)
- See ChannelStorageTypeDef
- See RetentionPeriodTypeDef
- See TagTypeDef
UpdateChannelRequestRequestTypeDef#
# UpdateChannelRequestRequestTypeDef definition
class UpdateChannelRequestRequestTypeDef(TypedDict):
channelName: str,
channelStorage: NotRequired[ChannelStorageTypeDef], # (1)
retentionPeriod: NotRequired[RetentionPeriodTypeDef], # (2)
ChannelSummaryTypeDef#
# ChannelSummaryTypeDef definition
class ChannelSummaryTypeDef(TypedDict):
channelName: NotRequired[str],
channelStorage: NotRequired[ChannelStorageSummaryTypeDef], # (1)
status: NotRequired[ChannelStatusType], # (2)
creationTime: NotRequired[datetime],
lastUpdateTime: NotRequired[datetime],
lastMessageArrivalTime: NotRequired[datetime],
ParquetConfigurationOutputTypeDef#
# ParquetConfigurationOutputTypeDef definition
class ParquetConfigurationOutputTypeDef(TypedDict):
schemaDefinition: NotRequired[SchemaDefinitionOutputTypeDef], # (1)
ListDatasetContentsResponseTypeDef#
# ListDatasetContentsResponseTypeDef definition
class ListDatasetContentsResponseTypeDef(TypedDict):
datasetContentSummaries: list[DatasetContentSummaryTypeDef], # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
nextToken: NotRequired[str],
DatasetSummaryTypeDef#
# DatasetSummaryTypeDef definition
class DatasetSummaryTypeDef(TypedDict):
datasetName: NotRequired[str],
status: NotRequired[DatasetStatusType], # (1)
creationTime: NotRequired[datetime],
lastUpdateTime: NotRequired[datetime],
triggers: NotRequired[list[DatasetTriggerTypeDef]], # (2)
actions: NotRequired[list[DatasetActionSummaryTypeDef]], # (3)
DatastoreStorageSummaryTypeDef#
# DatastoreStorageSummaryTypeDef definition
class DatastoreStorageSummaryTypeDef(TypedDict):
serviceManagedS3: NotRequired[dict[str, Any]],
customerManagedS3: NotRequired[CustomerManagedDatastoreS3StorageSummaryTypeDef], # (1)
iotSiteWiseMultiLayerStorage: NotRequired[DatastoreIotSiteWiseMultiLayerStorageSummaryTypeDef], # (2)
- See CustomerManagedDatastoreS3StorageSummaryTypeDef
- See DatastoreIotSiteWiseMultiLayerStorageSummaryTypeDef
DatastoreStorageOutputTypeDef#
# DatastoreStorageOutputTypeDef definition
class DatastoreStorageOutputTypeDef(TypedDict):
serviceManagedS3: NotRequired[dict[str, Any]],
customerManagedS3: NotRequired[CustomerManagedDatastoreS3StorageTypeDef], # (1)
iotSiteWiseMultiLayerStorage: NotRequired[DatastoreIotSiteWiseMultiLayerStorageTypeDef], # (2)
DatastoreStorageTypeDef#
# DatastoreStorageTypeDef definition
class DatastoreStorageTypeDef(TypedDict):
serviceManagedS3: NotRequired[Mapping[str, Any]],
customerManagedS3: NotRequired[CustomerManagedDatastoreS3StorageTypeDef], # (1)
iotSiteWiseMultiLayerStorage: NotRequired[DatastoreIotSiteWiseMultiLayerStorageTypeDef], # (2)
DatastorePartitionsOutputTypeDef#
# DatastorePartitionsOutputTypeDef definition
class DatastorePartitionsOutputTypeDef(TypedDict):
partitions: NotRequired[list[DatastorePartitionTypeDef]], # (1)
DatastorePartitionsTypeDef#
# DatastorePartitionsTypeDef definition
class DatastorePartitionsTypeDef(TypedDict):
partitions: NotRequired[Sequence[DatastorePartitionTypeDef]], # (1)
LateDataRuleTypeDef#
# LateDataRuleTypeDef definition
class LateDataRuleTypeDef(TypedDict):
ruleConfiguration: LateDataRuleConfigurationTypeDef, # (1)
ruleName: NotRequired[str],
SqlQueryDatasetActionOutputTypeDef#
# SqlQueryDatasetActionOutputTypeDef definition
class SqlQueryDatasetActionOutputTypeDef(TypedDict):
sqlQuery: str,
filters: NotRequired[list[QueryFilterTypeDef]], # (1)
SqlQueryDatasetActionTypeDef#
# SqlQueryDatasetActionTypeDef definition
class SqlQueryDatasetActionTypeDef(TypedDict):
sqlQuery: str,
filters: NotRequired[Sequence[QueryFilterTypeDef]], # (1)
DatasetContentDeliveryDestinationTypeDef#
# DatasetContentDeliveryDestinationTypeDef definition
class DatasetContentDeliveryDestinationTypeDef(TypedDict):
iotEventsDestinationConfiguration: NotRequired[IotEventsDestinationConfigurationTypeDef], # (1)
s3DestinationConfiguration: NotRequired[S3DestinationConfigurationTypeDef], # (2)
ContainerDatasetActionOutputTypeDef#
# ContainerDatasetActionOutputTypeDef definition
class ContainerDatasetActionOutputTypeDef(TypedDict):
image: str,
executionRoleArn: str,
resourceConfiguration: ResourceConfigurationTypeDef, # (1)
variables: NotRequired[list[VariableTypeDef]], # (2)
ContainerDatasetActionTypeDef#
# ContainerDatasetActionTypeDef definition
class ContainerDatasetActionTypeDef(TypedDict):
image: str,
executionRoleArn: str,
resourceConfiguration: ResourceConfigurationTypeDef, # (1)
variables: NotRequired[Sequence[VariableTypeDef]], # (2)
PipelineTypeDef#
# PipelineTypeDef definition
class PipelineTypeDef(TypedDict):
name: NotRequired[str],
arn: NotRequired[str],
activities: NotRequired[list[PipelineActivityOutputTypeDef]], # (1)
reprocessingSummaries: NotRequired[list[ReprocessingSummaryTypeDef]], # (2)
creationTime: NotRequired[datetime],
lastUpdateTime: NotRequired[datetime],
ListPipelinesResponseTypeDef#
# ListPipelinesResponseTypeDef definition
class ListPipelinesResponseTypeDef(TypedDict):
pipelineSummaries: list[PipelineSummaryTypeDef], # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
nextToken: NotRequired[str],
PipelineActivityTypeDef#
# PipelineActivityTypeDef definition
class PipelineActivityTypeDef(TypedDict):
channel: NotRequired[ChannelActivityTypeDef], # (1)
lambda: NotRequired[LambdaActivityTypeDef], # (2)
datastore: NotRequired[DatastoreActivityTypeDef], # (3)
addAttributes: NotRequired[AddAttributesActivityUnionTypeDef], # (4)
removeAttributes: NotRequired[RemoveAttributesActivityUnionTypeDef], # (5)
selectAttributes: NotRequired[SelectAttributesActivityUnionTypeDef], # (6)
filter: NotRequired[FilterActivityTypeDef], # (7)
math: NotRequired[MathActivityTypeDef], # (8)
deviceRegistryEnrich: NotRequired[DeviceRegistryEnrichActivityTypeDef], # (9)
deviceShadowEnrich: NotRequired[DeviceShadowEnrichActivityTypeDef], # (10)
- See ChannelActivityTypeDef
- See LambdaActivityTypeDef
- See DatastoreActivityTypeDef
- See AddAttributesActivityTypeDef AddAttributesActivityOutputTypeDef
- See RemoveAttributesActivityTypeDef RemoveAttributesActivityOutputTypeDef
- See SelectAttributesActivityTypeDef SelectAttributesActivityOutputTypeDef
- See FilterActivityTypeDef
- See MathActivityTypeDef
- See DeviceRegistryEnrichActivityTypeDef
- See DeviceShadowEnrichActivityTypeDef
DescribeChannelResponseTypeDef#
# DescribeChannelResponseTypeDef definition
class DescribeChannelResponseTypeDef(TypedDict):
channel: ChannelTypeDef, # (1)
statistics: ChannelStatisticsTypeDef, # (2)
ResponseMetadata: ResponseMetadataTypeDef, # (3)
ListChannelsResponseTypeDef#
# ListChannelsResponseTypeDef definition
class ListChannelsResponseTypeDef(TypedDict):
channelSummaries: list[ChannelSummaryTypeDef], # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
nextToken: NotRequired[str],
FileFormatConfigurationOutputTypeDef#
# FileFormatConfigurationOutputTypeDef definition
class FileFormatConfigurationOutputTypeDef(TypedDict):
jsonConfiguration: NotRequired[dict[str, Any]],
parquetConfiguration: NotRequired[ParquetConfigurationOutputTypeDef], # (1)
ParquetConfigurationTypeDef#
# ParquetConfigurationTypeDef definition
class ParquetConfigurationTypeDef(TypedDict):
schemaDefinition: NotRequired[SchemaDefinitionUnionTypeDef], # (1)
ListDatasetsResponseTypeDef#
# ListDatasetsResponseTypeDef definition
class ListDatasetsResponseTypeDef(TypedDict):
datasetSummaries: list[DatasetSummaryTypeDef], # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
nextToken: NotRequired[str],
DatastoreSummaryTypeDef#
# DatastoreSummaryTypeDef definition
class DatastoreSummaryTypeDef(TypedDict):
datastoreName: NotRequired[str],
datastoreStorage: NotRequired[DatastoreStorageSummaryTypeDef], # (1)
status: NotRequired[DatastoreStatusType], # (2)
creationTime: NotRequired[datetime],
lastUpdateTime: NotRequired[datetime],
lastMessageArrivalTime: NotRequired[datetime],
fileFormatType: NotRequired[FileFormatTypeType], # (3)
datastorePartitions: NotRequired[DatastorePartitionsOutputTypeDef], # (4)
- See DatastoreStorageSummaryTypeDef
- See DatastoreStatusType
- See FileFormatTypeType
- See DatastorePartitionsOutputTypeDef
DatasetContentDeliveryRuleTypeDef#
# DatasetContentDeliveryRuleTypeDef definition
class DatasetContentDeliveryRuleTypeDef(TypedDict):
destination: DatasetContentDeliveryDestinationTypeDef, # (1)
entryName: NotRequired[str],
DatasetActionOutputTypeDef#
# DatasetActionOutputTypeDef definition
class DatasetActionOutputTypeDef(TypedDict):
actionName: NotRequired[str],
queryAction: NotRequired[SqlQueryDatasetActionOutputTypeDef], # (1)
containerAction: NotRequired[ContainerDatasetActionOutputTypeDef], # (2)
DescribePipelineResponseTypeDef#
# DescribePipelineResponseTypeDef definition
class DescribePipelineResponseTypeDef(TypedDict):
pipeline: PipelineTypeDef, # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
RunPipelineActivityRequestRequestTypeDef#
# RunPipelineActivityRequestRequestTypeDef definition
class RunPipelineActivityRequestRequestTypeDef(TypedDict):
pipelineActivity: PipelineActivityTypeDef, # (1)
payloads: Sequence[BlobTypeDef],
UpdatePipelineRequestRequestTypeDef#
# UpdatePipelineRequestRequestTypeDef definition
class UpdatePipelineRequestRequestTypeDef(TypedDict):
pipelineName: str,
pipelineActivities: Sequence[PipelineActivityTypeDef], # (1)
DatastoreTypeDef#
# DatastoreTypeDef definition
class DatastoreTypeDef(TypedDict):
name: NotRequired[str],
storage: NotRequired[DatastoreStorageOutputTypeDef], # (1)
arn: NotRequired[str],
status: NotRequired[DatastoreStatusType], # (2)
retentionPeriod: NotRequired[RetentionPeriodTypeDef], # (3)
creationTime: NotRequired[datetime],
lastUpdateTime: NotRequired[datetime],
lastMessageArrivalTime: NotRequired[datetime],
fileFormatConfiguration: NotRequired[FileFormatConfigurationOutputTypeDef], # (4)
datastorePartitions: NotRequired[DatastorePartitionsOutputTypeDef], # (5)
- See DatastoreStorageOutputTypeDef
- See DatastoreStatusType
- See RetentionPeriodTypeDef
- See FileFormatConfigurationOutputTypeDef
- See DatastorePartitionsOutputTypeDef
ListDatastoresResponseTypeDef#
# ListDatastoresResponseTypeDef definition
class ListDatastoresResponseTypeDef(TypedDict):
datastoreSummaries: list[DatastoreSummaryTypeDef], # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
nextToken: NotRequired[str],
DatasetTypeDef#
# DatasetTypeDef definition
class DatasetTypeDef(TypedDict):
name: NotRequired[str],
arn: NotRequired[str],
actions: NotRequired[list[DatasetActionOutputTypeDef]], # (1)
triggers: NotRequired[list[DatasetTriggerTypeDef]], # (2)
contentDeliveryRules: NotRequired[list[DatasetContentDeliveryRuleTypeDef]], # (3)
status: NotRequired[DatasetStatusType], # (4)
creationTime: NotRequired[datetime],
lastUpdateTime: NotRequired[datetime],
retentionPeriod: NotRequired[RetentionPeriodTypeDef], # (5)
versioningConfiguration: NotRequired[VersioningConfigurationTypeDef], # (6)
lateDataRules: NotRequired[list[LateDataRuleTypeDef]], # (7)
- See DatasetActionOutputTypeDef
- See DatasetTriggerTypeDef
- See DatasetContentDeliveryRuleTypeDef
- See DatasetStatusType
- See RetentionPeriodTypeDef
- See VersioningConfigurationTypeDef
- See LateDataRuleTypeDef
DatasetActionTypeDef#
# DatasetActionTypeDef definition
class DatasetActionTypeDef(TypedDict):
actionName: NotRequired[str],
queryAction: NotRequired[SqlQueryDatasetActionUnionTypeDef], # (1)
containerAction: NotRequired[ContainerDatasetActionUnionTypeDef], # (2)
- See SqlQueryDatasetActionTypeDef SqlQueryDatasetActionOutputTypeDef
- See ContainerDatasetActionTypeDef ContainerDatasetActionOutputTypeDef
CreatePipelineRequestRequestTypeDef#
# CreatePipelineRequestRequestTypeDef definition
class CreatePipelineRequestRequestTypeDef(TypedDict):
pipelineName: str,
pipelineActivities: Sequence[PipelineActivityUnionTypeDef], # (1)
tags: NotRequired[Sequence[TagTypeDef]], # (2)
DescribeDatastoreResponseTypeDef#
# DescribeDatastoreResponseTypeDef definition
class DescribeDatastoreResponseTypeDef(TypedDict):
datastore: DatastoreTypeDef, # (1)
statistics: DatastoreStatisticsTypeDef, # (2)
ResponseMetadata: ResponseMetadataTypeDef, # (3)
FileFormatConfigurationTypeDef#
# FileFormatConfigurationTypeDef definition
class FileFormatConfigurationTypeDef(TypedDict):
jsonConfiguration: NotRequired[Mapping[str, Any]],
parquetConfiguration: NotRequired[ParquetConfigurationUnionTypeDef], # (1)
DescribeDatasetResponseTypeDef#
# DescribeDatasetResponseTypeDef definition
class DescribeDatasetResponseTypeDef(TypedDict):
dataset: DatasetTypeDef, # (1)
ResponseMetadata: ResponseMetadataTypeDef, # (2)
UpdateDatasetRequestRequestTypeDef#
# UpdateDatasetRequestRequestTypeDef definition
class UpdateDatasetRequestRequestTypeDef(TypedDict):
datasetName: str,
actions: Sequence[DatasetActionTypeDef], # (1)
triggers: NotRequired[Sequence[DatasetTriggerTypeDef]], # (2)
contentDeliveryRules: NotRequired[Sequence[DatasetContentDeliveryRuleTypeDef]], # (3)
retentionPeriod: NotRequired[RetentionPeriodTypeDef], # (4)
versioningConfiguration: NotRequired[VersioningConfigurationTypeDef], # (5)
lateDataRules: NotRequired[Sequence[LateDataRuleTypeDef]], # (6)
- See DatasetActionTypeDef
- See DatasetTriggerTypeDef
- See DatasetContentDeliveryRuleTypeDef
- See RetentionPeriodTypeDef
- See VersioningConfigurationTypeDef
- See LateDataRuleTypeDef
CreateDatastoreRequestRequestTypeDef#
# CreateDatastoreRequestRequestTypeDef definition
class CreateDatastoreRequestRequestTypeDef(TypedDict):
datastoreName: str,
datastoreStorage: NotRequired[DatastoreStorageTypeDef], # (1)
retentionPeriod: NotRequired[RetentionPeriodTypeDef], # (2)
tags: NotRequired[Sequence[TagTypeDef]], # (3)
fileFormatConfiguration: NotRequired[FileFormatConfigurationTypeDef], # (4)
datastorePartitions: NotRequired[DatastorePartitionsTypeDef], # (5)
- See DatastoreStorageTypeDef
- See RetentionPeriodTypeDef
- See TagTypeDef
- See FileFormatConfigurationTypeDef
- See DatastorePartitionsTypeDef
UpdateDatastoreRequestRequestTypeDef#
# UpdateDatastoreRequestRequestTypeDef definition
class UpdateDatastoreRequestRequestTypeDef(TypedDict):
datastoreName: str,
retentionPeriod: NotRequired[RetentionPeriodTypeDef], # (1)
datastoreStorage: NotRequired[DatastoreStorageTypeDef], # (2)
fileFormatConfiguration: NotRequired[FileFormatConfigurationTypeDef], # (3)
CreateDatasetRequestRequestTypeDef#
# CreateDatasetRequestRequestTypeDef definition
class CreateDatasetRequestRequestTypeDef(TypedDict):
datasetName: str,
actions: Sequence[DatasetActionUnionTypeDef], # (1)
triggers: NotRequired[Sequence[DatasetTriggerTypeDef]], # (2)
contentDeliveryRules: NotRequired[Sequence[DatasetContentDeliveryRuleTypeDef]], # (3)
retentionPeriod: NotRequired[RetentionPeriodTypeDef], # (4)
versioningConfiguration: NotRequired[VersioningConfigurationTypeDef], # (5)
tags: NotRequired[Sequence[TagTypeDef]], # (6)
lateDataRules: NotRequired[Sequence[LateDataRuleTypeDef]], # (7)