|
21 | 21 | BooleanObject = bool
|
22 | 22 | ClientRequestToken = str
|
23 | 23 | ClientToken = str
|
| 24 | +CloudWatchLogGroupArn = str |
24 | 25 | Code = str
|
25 | 26 | ConditionExpression = str
|
26 | 27 | ConsistentRead = bool
|
27 | 28 | ConsumedCapacityUnits = float
|
28 | 29 | ContributorInsightsRule = str
|
| 30 | +CsvDelimiter = str |
| 31 | +CsvHeader = str |
29 | 32 | Double = float
|
30 | 33 | ErrorMessage = str
|
31 | 34 | ExceptionDescription = str
|
|
38 | 41 | FailureCode = str
|
39 | 42 | FailureMessage = str
|
40 | 43 | GlobalTableArnString = str
|
| 44 | +ImportArn = str |
| 45 | +ImportNextToken = str |
41 | 46 | IndexName = str
42 | 47 | Integer = int
|
43 | 48 | IntegerObject = int
|
|
48 | 53 | KeySchemaAttributeName = str
|
49 | 54 | ListContributorInsightsLimit = int
|
50 | 55 | ListExportsMaxLimit = int
|
| 56 | +ListImportsMaxLimit = int |
51 | 57 | ListTablesInputLimit = int
|
52 | 58 | NextTokenString = str
|
53 | 59 | NonKeyAttributeName = str
|
@@ -192,13 +198,33 @@ class GlobalTableStatus(str):
|
192 | 198 | UPDATING = "UPDATING"
|
193 | 199 |
|
194 | 200 |
|
| 201 | +class ImportStatus(str): |
| 202 | + IN_PROGRESS = "IN_PROGRESS" |
| 203 | + COMPLETED = "COMPLETED" |
| 204 | + CANCELLING = "CANCELLING" |
| 205 | + CANCELLED = "CANCELLED" |
| 206 | + FAILED = "FAILED" |
| 207 | + |
| 208 | + |
195 | 209 | class IndexStatus(str):
|
196 | 210 | CREATING = "CREATING"
|
197 | 211 | UPDATING = "UPDATING"
|
198 | 212 | DELETING = "DELETING"
|
199 | 213 | ACTIVE = "ACTIVE"
|
200 | 214 |
|
201 | 215 |
|
| 216 | +class InputCompressionType(str): |
| 217 | + GZIP = "GZIP" |
| 218 | + ZSTD = "ZSTD" |
| 219 | + NONE = "NONE" |
| 220 | + |
| 221 | + |
| 222 | +class InputFormat(str): |
| 223 | + DYNAMODB_JSON = "DYNAMODB_JSON" |
| 224 | + ION = "ION" |
| 225 | + CSV = "CSV" |
| 226 | + |
| 227 | + |
202 | 228 | class KeyType(str):
|
203 | 229 | HASH = "HASH"
|
204 | 230 | RANGE = "RANGE"
|
@@ -369,6 +395,18 @@ class IdempotentParameterMismatchException(ServiceException):
|
369 | 395 | status_code: int = 400
|
370 | 396 |
|
371 | 397 |
|
| 398 | +class ImportConflictException(ServiceException): |
| 399 | + code: str = "ImportConflictException" |
| 400 | + sender_fault: bool = False |
| 401 | + status_code: int = 400 |
| 402 | + |
| 403 | + |
| 404 | +class ImportNotFoundException(ServiceException): |
| 405 | + code: str = "ImportNotFoundException" |
| 406 | + sender_fault: bool = False |
| 407 | + status_code: int = 400 |
| 408 | + |
| 409 | + |
372 | 410 | class IndexNotFoundException(ServiceException):
|
373 | 411 | code: str = "IndexNotFoundException"
|
374 | 412 | sender_fault: bool = False
|
@@ -1103,6 +1141,14 @@ class CreateTableOutput(TypedDict, total=False):
|
1103 | 1141 | TableDescription: Optional[TableDescription]
|
1104 | 1142 |
|
1105 | 1143 |
|
| 1144 | +CsvHeaderList = List[CsvHeader] |
| 1145 | + |
| 1146 | + |
| 1147 | +class CsvOptions(TypedDict, total=False): |
| 1148 | + Delimiter: Optional[CsvDelimiter] |
| 1149 | + HeaderList: Optional[CsvHeaderList] |
| 1150 | + |
| 1151 | + |
1106 | 1152 | class Delete(TypedDict, total=False):
|
1107 | 1153 | Key: Key
|
1108 | 1154 | TableName: TableName
|
@@ -1306,6 +1352,65 @@ class DescribeGlobalTableSettingsOutput(TypedDict, total=False):
|
1306 | 1352 | ReplicaSettings: Optional[ReplicaSettingsDescriptionList]
|
1307 | 1353 |
|
1308 | 1354 |
|
| 1355 | +class DescribeImportInput(ServiceRequest): |
| 1356 | + ImportArn: ImportArn |
| 1357 | + |
| 1358 | + |
| 1359 | +ImportedItemCount = int |
| 1360 | +ProcessedItemCount = int |
| 1361 | +ImportEndTime = datetime |
| 1362 | +ImportStartTime = datetime |
| 1363 | + |
| 1364 | + |
| 1365 | +class TableCreationParameters(TypedDict, total=False): |
| 1366 | + TableName: TableName |
| 1367 | + AttributeDefinitions: AttributeDefinitions |
| 1368 | + KeySchema: KeySchema |
| 1369 | + BillingMode: Optional[BillingMode] |
| 1370 | + ProvisionedThroughput: Optional[ProvisionedThroughput] |
| 1371 | + SSESpecification: Optional[SSESpecification] |
| 1372 | + GlobalSecondaryIndexes: Optional[GlobalSecondaryIndexList] |
| 1373 | + |
| 1374 | + |
| 1375 | +class InputFormatOptions(TypedDict, total=False): |
| 1376 | + Csv: Optional[CsvOptions] |
| 1377 | + |
| 1378 | + |
| 1379 | +ErrorCount = int |
| 1380 | + |
| 1381 | + |
| 1382 | +class S3BucketSource(TypedDict, total=False): |
| 1383 | + S3BucketOwner: Optional[S3BucketOwner] |
| 1384 | + S3Bucket: S3Bucket |
| 1385 | + S3KeyPrefix: Optional[S3Prefix] |
| 1386 | + |
| 1387 | + |
| 1388 | +class ImportTableDescription(TypedDict, total=False): |
| 1389 | + ImportArn: Optional[ImportArn] |
| 1390 | + ImportStatus: Optional[ImportStatus] |
| 1391 | + TableArn: Optional[TableArn] |
| 1392 | + TableId: Optional[TableId] |
| 1393 | + ClientToken: Optional[ClientToken] |
| 1394 | + S3BucketSource: Optional[S3BucketSource] |
| 1395 | + ErrorCount: Optional[ErrorCount] |
| 1396 | + CloudWatchLogGroupArn: Optional[CloudWatchLogGroupArn] |
| 1397 | + InputFormat: Optional[InputFormat] |
| 1398 | + InputFormatOptions: Optional[InputFormatOptions] |
| 1399 | + InputCompressionType: Optional[InputCompressionType] |
| 1400 | + TableCreationParameters: Optional[TableCreationParameters] |
| 1401 | + StartTime: Optional[ImportStartTime] |
| 1402 | + EndTime: Optional[ImportEndTime] |
| 1403 | + ProcessedSizeBytes: Optional[Long] |
| 1404 | + ProcessedItemCount: Optional[ProcessedItemCount] |
| 1405 | + ImportedItemCount: Optional[ImportedItemCount] |
| 1406 | + FailureCode: Optional[FailureCode] |
| 1407 | + FailureMessage: Optional[FailureMessage] |
| 1408 | + |
| 1409 | + |
| 1410 | +class DescribeImportOutput(TypedDict, total=False): |
| 1411 | + ImportTableDescription: ImportTableDescription |
| 1412 | + |
| 1413 | + |
1309 | 1414 | class DescribeKinesisStreamingDestinationInput(ServiceRequest):
|
1310 | 1415 | TableName: TableName
|
1311 | 1416 |
|
@@ -1516,6 +1621,35 @@ class GlobalTableGlobalSecondaryIndexSettingsUpdate(TypedDict, total=False):
|
1516 | 1621 | GlobalTableGlobalSecondaryIndexSettingsUpdate
|
1517 | 1622 | ]
|
1518 | 1623 | GlobalTableList = List[GlobalTable]
|
| 1624 | + |
| 1625 | + |
| 1626 | +class ImportSummary(TypedDict, total=False): |
| 1627 | + ImportArn: Optional[ImportArn] |
| 1628 | + ImportStatus: Optional[ImportStatus] |
| 1629 | + TableArn: Optional[TableArn] |
| 1630 | + S3BucketSource: Optional[S3BucketSource] |
| 1631 | + CloudWatchLogGroupArn: Optional[CloudWatchLogGroupArn] |
| 1632 | + InputFormat: Optional[InputFormat] |
| 1633 | + StartTime: Optional[ImportStartTime] |
| 1634 | + EndTime: Optional[ImportEndTime] |
| 1635 | + |
| 1636 | + |
| 1637 | +ImportSummaryList = List[ImportSummary] |
| 1638 | + |
| 1639 | + |
| 1640 | +class ImportTableInput(ServiceRequest): |
| 1641 | + ClientToken: Optional[ClientToken] |
| 1642 | + S3BucketSource: S3BucketSource |
| 1643 | + InputFormat: InputFormat |
| 1644 | + InputFormatOptions: Optional[InputFormatOptions] |
| 1645 | + InputCompressionType: Optional[InputCompressionType] |
| 1646 | + TableCreationParameters: TableCreationParameters |
| 1647 | + |
| 1648 | + |
| 1649 | +class ImportTableOutput(TypedDict, total=False): |
| 1650 | + ImportTableDescription: ImportTableDescription |
| 1651 | + |
| 1652 | + |
1519 | 1653 | KeyConditions = Dict[AttributeName, Condition]
|
1520 | 1654 |
|
1521 | 1655 |
|
@@ -1581,6 +1715,17 @@ class ListGlobalTablesOutput(TypedDict, total=False):
|
1581 | 1715 | LastEvaluatedGlobalTableName: Optional[TableName]
|
1582 | 1716 |
|
1583 | 1717 |
|
| 1718 | +class ListImportsInput(ServiceRequest): |
| 1719 | + TableArn: Optional[TableArn] |
| 1720 | + PageSize: Optional[ListImportsMaxLimit] |
| 1721 | + NextToken: Optional[ImportNextToken] |
| 1722 | + |
| 1723 | + |
| 1724 | +class ListImportsOutput(TypedDict, total=False): |
| 1725 | + ImportSummaryList: Optional[ImportSummaryList] |
| 1726 | + NextToken: Optional[ImportNextToken] |
| 1727 | + |
| 1728 | + |
1584 | 1729 | class ListTablesInput(ServiceRequest):
|
1585 | 1730 | ExclusiveStartTableName: Optional[TableName]
|
1586 | 1731 | Limit: Optional[ListTablesInputLimit]
|
@@ -2091,6 +2236,12 @@ def describe_global_table_settings(
|
2091 | 2236 | ) -> DescribeGlobalTableSettingsOutput:
|
2092 | 2237 | raise NotImplementedError
|
2093 | 2238 |
|
| 2239 | + @handler("DescribeImport") |
| 2240 | + def describe_import( |
| 2241 | + self, context: RequestContext, import_arn: ImportArn |
| 2242 | + ) -> DescribeImportOutput: |
| 2243 | + raise NotImplementedError |
| 2244 | + |
2094 | 2245 | @handler("DescribeKinesisStreamingDestination")
|
2095 | 2246 | def describe_kinesis_streaming_destination(
|
2096 | 2247 | self, context: RequestContext, table_name: TableName
|
@@ -2185,6 +2336,19 @@ def get_item(
|
2185 | 2336 | ) -> GetItemOutput:
|
2186 | 2337 | raise NotImplementedError
|
2187 | 2338 |
|
| 2339 | + @handler("ImportTable") |
| 2340 | + def import_table( |
| 2341 | + self, |
| 2342 | + context: RequestContext, |
| 2343 | + s3_bucket_source: S3BucketSource, |
| 2344 | + input_format: InputFormat, |
| 2345 | + table_creation_parameters: TableCreationParameters, |
| 2346 | + client_token: ClientToken = None, |
| 2347 | + input_format_options: InputFormatOptions = None, |
| 2348 | + input_compression_type: InputCompressionType = None, |
| 2349 | + ) -> ImportTableOutput: |
| 2350 | + raise NotImplementedError |
| 2351 | + |
2188 | 2352 | @handler("ListBackups")
|
2189 | 2353 | def list_backups(
|
2190 | 2354 | self,
|
@@ -2228,6 +2392,16 @@ def list_global_tables(
|
2228 | 2392 | ) -> ListGlobalTablesOutput:
|
2229 | 2393 | raise NotImplementedError
|
2230 | 2394 |
|
| 2395 | + @handler("ListImports") |
| 2396 | + def list_imports( |
| 2397 | + self, |
| 2398 | + context: RequestContext, |
| 2399 | + table_arn: TableArn = None, |
| 2400 | + page_size: ListImportsMaxLimit = None, |
| 2401 | + next_token: ImportNextToken = None, |
| 2402 | + ) -> ListImportsOutput: |
| 2403 | + raise NotImplementedError |
| 2404 | + |
2231 | 2405 | @handler("ListTables")
|
2232 | 2406 | def list_tables(
|
2233 | 2407 | self,
|
|
0 commit comments