mypydantic.models.firehose

   1# Model Generated: Thu Mar  2 21:56:19 2023
   2
   3from __future__ import annotations
   4
   5from datetime import datetime
   6from typing import (
   7    Any,
   8    Dict,
   9    IO,
  10    List,
  11    Literal,
  12    Mapping,
  13    Optional,
  14    Sequence,
  15    Type,
  16    Union,
  17)
  18
  19from botocore.response import StreamingBody
  20from pydantic import Field
  21
  22from mypydantic.models.base_model import BaseModel
  23
  24
  25class AmazonOpenSearchServerlessBufferingHintsModel(BaseModel):
  26    interval_in_seconds: Optional[int] = Field(default=None, alias="IntervalInSeconds")
  27    size_in_mbs: Optional[int] = Field(default=None, alias="SizeInMBs")
  28
  29
  30class AmazonOpenSearchServerlessRetryOptionsModel(BaseModel):
  31    duration_in_seconds: Optional[int] = Field(default=None, alias="DurationInSeconds")
  32
  33
  34class CloudWatchLoggingOptionsModel(BaseModel):
  35    enabled: Optional[bool] = Field(default=None, alias="Enabled")
  36    log_group_name: Optional[str] = Field(default=None, alias="LogGroupName")
  37    log_stream_name: Optional[str] = Field(default=None, alias="LogStreamName")
  38
  39
  40class VpcConfigurationModel(BaseModel):
  41    subnet_ids: Sequence[str] = Field(alias="SubnetIds")
  42    role_arn: str = Field(alias="RoleARN")
  43    security_group_ids: Sequence[str] = Field(alias="SecurityGroupIds")
  44
  45
  46class VpcConfigurationDescriptionModel(BaseModel):
  47    subnet_ids: List[str] = Field(alias="SubnetIds")
  48    role_arn: str = Field(alias="RoleARN")
  49    security_group_ids: List[str] = Field(alias="SecurityGroupIds")
  50    vpc_id: str = Field(alias="VpcId")
  51
  52
  53class AmazonopensearchserviceBufferingHintsModel(BaseModel):
  54    interval_in_seconds: Optional[int] = Field(default=None, alias="IntervalInSeconds")
  55    size_in_mbs: Optional[int] = Field(default=None, alias="SizeInMBs")
  56
  57
  58class AmazonopensearchserviceRetryOptionsModel(BaseModel):
  59    duration_in_seconds: Optional[int] = Field(default=None, alias="DurationInSeconds")
  60
  61
  62class BufferingHintsModel(BaseModel):
  63    size_in_mbs: Optional[int] = Field(default=None, alias="SizeInMBs")
  64    interval_in_seconds: Optional[int] = Field(default=None, alias="IntervalInSeconds")
  65
  66
  67class CopyCommandModel(BaseModel):
  68    data_table_name: str = Field(alias="DataTableName")
  69    data_table_columns: Optional[str] = Field(default=None, alias="DataTableColumns")
  70    copy_options: Optional[str] = Field(default=None, alias="CopyOptions")
  71
  72
  73class DeliveryStreamEncryptionConfigurationInputModel(BaseModel):
  74    key_type: Literal["AWS_OWNED_CMK", "CUSTOMER_MANAGED_CMK"] = Field(alias="KeyType")
  75    key_arn: Optional[str] = Field(default=None, alias="KeyARN")
  76
  77
  78class KinesisStreamSourceConfigurationModel(BaseModel):
  79    kinesis_stream_arn: str = Field(alias="KinesisStreamARN")
  80    role_arn: str = Field(alias="RoleARN")
  81
  82
  83class TagModel(BaseModel):
  84    key: str = Field(alias="Key")
  85    value: Optional[str] = Field(default=None, alias="Value")
  86
  87
  88class ResponseMetadataModel(BaseModel):
  89    request_id: str = Field(alias="RequestId")
  90    host_id: str = Field(alias="HostId")
  91    http_status_code: int = Field(alias="HTTPStatusCode")
  92    http_headers: Dict[str, str] = Field(alias="HTTPHeaders")
  93    retry_attempts: int = Field(alias="RetryAttempts")
  94
  95
  96class SchemaConfigurationModel(BaseModel):
  97    role_arn: Optional[str] = Field(default=None, alias="RoleARN")
  98    catalog_id: Optional[str] = Field(default=None, alias="CatalogId")
  99    database_name: Optional[str] = Field(default=None, alias="DatabaseName")
 100    table_name: Optional[str] = Field(default=None, alias="TableName")
 101    region: Optional[str] = Field(default=None, alias="Region")
 102    version_id: Optional[str] = Field(default=None, alias="VersionId")
 103
 104
 105class DeleteDeliveryStreamInputRequestModel(BaseModel):
 106    delivery_stream_name: str = Field(alias="DeliveryStreamName")
 107    allow_force_delete: Optional[bool] = Field(default=None, alias="AllowForceDelete")
 108
 109
 110class FailureDescriptionModel(BaseModel):
 111    type: Literal[
 112        "CREATE_ENI_FAILED",
 113        "CREATE_KMS_GRANT_FAILED",
 114        "DELETE_ENI_FAILED",
 115        "DISABLED_KMS_KEY",
 116        "ENI_ACCESS_DENIED",
 117        "INVALID_KMS_KEY",
 118        "KMS_ACCESS_DENIED",
 119        "KMS_KEY_NOT_FOUND",
 120        "KMS_OPT_IN_REQUIRED",
 121        "RETIRE_KMS_GRANT_FAILED",
 122        "SECURITY_GROUP_ACCESS_DENIED",
 123        "SECURITY_GROUP_NOT_FOUND",
 124        "SUBNET_ACCESS_DENIED",
 125        "SUBNET_NOT_FOUND",
 126        "UNKNOWN_ERROR",
 127    ] = Field(alias="Type")
 128    details: str = Field(alias="Details")
 129
 130
 131class DescribeDeliveryStreamInputRequestModel(BaseModel):
 132    delivery_stream_name: str = Field(alias="DeliveryStreamName")
 133    limit: Optional[int] = Field(default=None, alias="Limit")
 134    exclusive_start_destination_id: Optional[str] = Field(
 135        default=None, alias="ExclusiveStartDestinationId"
 136    )
 137
 138
 139class HiveJsonSerDeModel(BaseModel):
 140    timestamp_formats: Optional[Sequence[str]] = Field(
 141        default=None, alias="TimestampFormats"
 142    )
 143
 144
 145class OpenXJsonSerDeModel(BaseModel):
 146    convert_dots_in_json_keys_to_underscores: Optional[bool] = Field(
 147        default=None, alias="ConvertDotsInJsonKeysToUnderscores"
 148    )
 149    case_insensitive: Optional[bool] = Field(default=None, alias="CaseInsensitive")
 150    column_to_json_key_mappings: Optional[Mapping[str, str]] = Field(
 151        default=None, alias="ColumnToJsonKeyMappings"
 152    )
 153
 154
 155class RetryOptionsModel(BaseModel):
 156    duration_in_seconds: Optional[int] = Field(default=None, alias="DurationInSeconds")
 157
 158
 159class ElasticsearchBufferingHintsModel(BaseModel):
 160    interval_in_seconds: Optional[int] = Field(default=None, alias="IntervalInSeconds")
 161    size_in_mbs: Optional[int] = Field(default=None, alias="SizeInMBs")
 162
 163
 164class ElasticsearchRetryOptionsModel(BaseModel):
 165    duration_in_seconds: Optional[int] = Field(default=None, alias="DurationInSeconds")
 166
 167
 168class KMSEncryptionConfigModel(BaseModel):
 169    aws_kms_key_arn: str = Field(alias="AWSKMSKeyARN")
 170
 171
 172class HttpEndpointBufferingHintsModel(BaseModel):
 173    size_in_mbs: Optional[int] = Field(default=None, alias="SizeInMBs")
 174    interval_in_seconds: Optional[int] = Field(default=None, alias="IntervalInSeconds")
 175
 176
 177class HttpEndpointCommonAttributeModel(BaseModel):
 178    attribute_name: str = Field(alias="AttributeName")
 179    attribute_value: str = Field(alias="AttributeValue")
 180
 181
 182class HttpEndpointConfigurationModel(BaseModel):
 183    url: str = Field(alias="Url")
 184    name: Optional[str] = Field(default=None, alias="Name")
 185    access_key: Optional[str] = Field(default=None, alias="AccessKey")
 186
 187
 188class HttpEndpointDescriptionModel(BaseModel):
 189    url: Optional[str] = Field(default=None, alias="Url")
 190    name: Optional[str] = Field(default=None, alias="Name")
 191
 192
 193class HttpEndpointRetryOptionsModel(BaseModel):
 194    duration_in_seconds: Optional[int] = Field(default=None, alias="DurationInSeconds")
 195
 196
 197class KinesisStreamSourceDescriptionModel(BaseModel):
 198    kinesis_stream_arn: Optional[str] = Field(default=None, alias="KinesisStreamARN")
 199    role_arn: Optional[str] = Field(default=None, alias="RoleARN")
 200    delivery_start_timestamp: Optional[datetime] = Field(
 201        default=None, alias="DeliveryStartTimestamp"
 202    )
 203
 204
 205class ListDeliveryStreamsInputRequestModel(BaseModel):
 206    limit: Optional[int] = Field(default=None, alias="Limit")
 207    delivery_stream_type: Optional[
 208        Literal["DirectPut", "KinesisStreamAsSource"]
 209    ] = Field(default=None, alias="DeliveryStreamType")
 210    exclusive_start_delivery_stream_name: Optional[str] = Field(
 211        default=None, alias="ExclusiveStartDeliveryStreamName"
 212    )
 213
 214
 215class ListTagsForDeliveryStreamInputRequestModel(BaseModel):
 216    delivery_stream_name: str = Field(alias="DeliveryStreamName")
 217    exclusive_start_tag_key: Optional[str] = Field(
 218        default=None, alias="ExclusiveStartTagKey"
 219    )
 220    limit: Optional[int] = Field(default=None, alias="Limit")
 221
 222
 223class OrcSerDeModel(BaseModel):
 224    stripe_size_bytes: Optional[int] = Field(default=None, alias="StripeSizeBytes")
 225    block_size_bytes: Optional[int] = Field(default=None, alias="BlockSizeBytes")
 226    row_index_stride: Optional[int] = Field(default=None, alias="RowIndexStride")
 227    enable_padding: Optional[bool] = Field(default=None, alias="EnablePadding")
 228    padding_tolerance: Optional[float] = Field(default=None, alias="PaddingTolerance")
 229    compression: Optional[Literal["NONE", "SNAPPY", "ZLIB"]] = Field(
 230        default=None, alias="Compression"
 231    )
 232    bloom_filter_columns: Optional[Sequence[str]] = Field(
 233        default=None, alias="BloomFilterColumns"
 234    )
 235    bloom_filter_false_positive_probability: Optional[float] = Field(
 236        default=None, alias="BloomFilterFalsePositiveProbability"
 237    )
 238    dictionary_key_threshold: Optional[float] = Field(
 239        default=None, alias="DictionaryKeyThreshold"
 240    )
 241    format_version: Optional[Literal["V0_11", "V0_12"]] = Field(
 242        default=None, alias="FormatVersion"
 243    )
 244
 245
 246class ParquetSerDeModel(BaseModel):
 247    block_size_bytes: Optional[int] = Field(default=None, alias="BlockSizeBytes")
 248    page_size_bytes: Optional[int] = Field(default=None, alias="PageSizeBytes")
 249    compression: Optional[Literal["GZIP", "SNAPPY", "UNCOMPRESSED"]] = Field(
 250        default=None, alias="Compression"
 251    )
 252    enable_dictionary_compression: Optional[bool] = Field(
 253        default=None, alias="EnableDictionaryCompression"
 254    )
 255    max_padding_bytes: Optional[int] = Field(default=None, alias="MaxPaddingBytes")
 256    writer_version: Optional[Literal["V1", "V2"]] = Field(
 257        default=None, alias="WriterVersion"
 258    )
 259
 260
 261class ProcessorParameterModel(BaseModel):
 262    parameter_name: Literal[
 263        "BufferIntervalInSeconds",
 264        "BufferSizeInMBs",
 265        "Delimiter",
 266        "JsonParsingEngine",
 267        "LambdaArn",
 268        "MetadataExtractionQuery",
 269        "NumberOfRetries",
 270        "RoleArn",
 271        "SubRecordType",
 272    ] = Field(alias="ParameterName")
 273    parameter_value: str = Field(alias="ParameterValue")
 274
 275
 276class RecordModel(BaseModel):
 277    data: Union[str, bytes, Type[IO[Any]], Type[StreamingBody]] = Field(alias="Data")
 278
 279
 280class PutRecordBatchResponseEntryModel(BaseModel):
 281    record_id: Optional[str] = Field(default=None, alias="RecordId")
 282    error_code: Optional[str] = Field(default=None, alias="ErrorCode")
 283    error_message: Optional[str] = Field(default=None, alias="ErrorMessage")
 284
 285
 286class RedshiftRetryOptionsModel(BaseModel):
 287    duration_in_seconds: Optional[int] = Field(default=None, alias="DurationInSeconds")
 288
 289
 290class SplunkRetryOptionsModel(BaseModel):
 291    duration_in_seconds: Optional[int] = Field(default=None, alias="DurationInSeconds")
 292
 293
 294class StopDeliveryStreamEncryptionInputRequestModel(BaseModel):
 295    delivery_stream_name: str = Field(alias="DeliveryStreamName")
 296
 297
 298class UntagDeliveryStreamInputRequestModel(BaseModel):
 299    delivery_stream_name: str = Field(alias="DeliveryStreamName")
 300    tag_keys: Sequence[str] = Field(alias="TagKeys")
 301
 302
 303class StartDeliveryStreamEncryptionInputRequestModel(BaseModel):
 304    delivery_stream_name: str = Field(alias="DeliveryStreamName")
 305    delivery_stream_encryption_configuration_input: Optional[
 306        DeliveryStreamEncryptionConfigurationInputModel
 307    ] = Field(default=None, alias="DeliveryStreamEncryptionConfigurationInput")
 308
 309
 310class TagDeliveryStreamInputRequestModel(BaseModel):
 311    delivery_stream_name: str = Field(alias="DeliveryStreamName")
 312    tags: Sequence[TagModel] = Field(alias="Tags")
 313
 314
 315class CreateDeliveryStreamOutputModel(BaseModel):
 316    delivery_stream_arn: str = Field(alias="DeliveryStreamARN")
 317    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 318
 319
 320class ListDeliveryStreamsOutputModel(BaseModel):
 321    delivery_stream_names: List[str] = Field(alias="DeliveryStreamNames")
 322    has_more_delivery_streams: bool = Field(alias="HasMoreDeliveryStreams")
 323    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 324
 325
 326class ListTagsForDeliveryStreamOutputModel(BaseModel):
 327    tags: List[TagModel] = Field(alias="Tags")
 328    has_more_tags: bool = Field(alias="HasMoreTags")
 329    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 330
 331
 332class PutRecordOutputModel(BaseModel):
 333    record_id: str = Field(alias="RecordId")
 334    encrypted: bool = Field(alias="Encrypted")
 335    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 336
 337
 338class DeliveryStreamEncryptionConfigurationModel(BaseModel):
 339    key_arn: Optional[str] = Field(default=None, alias="KeyARN")
 340    key_type: Optional[Literal["AWS_OWNED_CMK", "CUSTOMER_MANAGED_CMK"]] = Field(
 341        default=None, alias="KeyType"
 342    )
 343    status: Optional[
 344        Literal[
 345            "DISABLED",
 346            "DISABLING",
 347            "DISABLING_FAILED",
 348            "ENABLED",
 349            "ENABLING",
 350            "ENABLING_FAILED",
 351        ]
 352    ] = Field(default=None, alias="Status")
 353    failure_description: Optional[FailureDescriptionModel] = Field(
 354        default=None, alias="FailureDescription"
 355    )
 356
 357
 358class DeserializerModel(BaseModel):
 359    open_xjson_ser_de: Optional[OpenXJsonSerDeModel] = Field(
 360        default=None, alias="OpenXJsonSerDe"
 361    )
 362    hive_json_ser_de: Optional[HiveJsonSerDeModel] = Field(
 363        default=None, alias="HiveJsonSerDe"
 364    )
 365
 366
 367class DynamicPartitioningConfigurationModel(BaseModel):
 368    retry_options: Optional[RetryOptionsModel] = Field(
 369        default=None, alias="RetryOptions"
 370    )
 371    enabled: Optional[bool] = Field(default=None, alias="Enabled")
 372
 373
 374class EncryptionConfigurationModel(BaseModel):
 375    no_encryption_config: Optional[Literal["NoEncryption"]] = Field(
 376        default=None, alias="NoEncryptionConfig"
 377    )
 378    kms_encryption_config: Optional[KMSEncryptionConfigModel] = Field(
 379        default=None, alias="KMSEncryptionConfig"
 380    )
 381
 382
 383class HttpEndpointRequestConfigurationModel(BaseModel):
 384    content_encoding: Optional[Literal["GZIP", "NONE"]] = Field(
 385        default=None, alias="ContentEncoding"
 386    )
 387    common_attributes: Optional[Sequence[HttpEndpointCommonAttributeModel]] = Field(
 388        default=None, alias="CommonAttributes"
 389    )
 390
 391
 392class SourceDescriptionModel(BaseModel):
 393    kinesis_stream_source_description: Optional[
 394        KinesisStreamSourceDescriptionModel
 395    ] = Field(default=None, alias="KinesisStreamSourceDescription")
 396
 397
 398class SerializerModel(BaseModel):
 399    parquet_ser_de: Optional[ParquetSerDeModel] = Field(
 400        default=None, alias="ParquetSerDe"
 401    )
 402    orc_ser_de: Optional[OrcSerDeModel] = Field(default=None, alias="OrcSerDe")
 403
 404
 405class ProcessorModel(BaseModel):
 406    type: Literal[
 407        "AppendDelimiterToRecord", "Lambda", "MetadataExtraction", "RecordDeAggregation"
 408    ] = Field(alias="Type")
 409    parameters: Optional[Sequence[ProcessorParameterModel]] = Field(
 410        default=None, alias="Parameters"
 411    )
 412
 413
 414class PutRecordBatchInputRequestModel(BaseModel):
 415    delivery_stream_name: str = Field(alias="DeliveryStreamName")
 416    records: Sequence[RecordModel] = Field(alias="Records")
 417
 418
 419class PutRecordInputRequestModel(BaseModel):
 420    delivery_stream_name: str = Field(alias="DeliveryStreamName")
 421    record: RecordModel = Field(alias="Record")
 422
 423
 424class PutRecordBatchOutputModel(BaseModel):
 425    failed_put_count: int = Field(alias="FailedPutCount")
 426    encrypted: bool = Field(alias="Encrypted")
 427    request_responses: List[PutRecordBatchResponseEntryModel] = Field(
 428        alias="RequestResponses"
 429    )
 430    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 431
 432
 433class InputFormatConfigurationModel(BaseModel):
 434    deserializer: Optional[DeserializerModel] = Field(
 435        default=None, alias="Deserializer"
 436    )
 437
 438
 439class S3DestinationConfigurationModel(BaseModel):
 440    role_arn: str = Field(alias="RoleARN")
 441    bucket_arn: str = Field(alias="BucketARN")
 442    prefix: Optional[str] = Field(default=None, alias="Prefix")
 443    error_output_prefix: Optional[str] = Field(default=None, alias="ErrorOutputPrefix")
 444    buffering_hints: Optional[BufferingHintsModel] = Field(
 445        default=None, alias="BufferingHints"
 446    )
 447    compression_format: Optional[
 448        Literal["GZIP", "HADOOP_SNAPPY", "Snappy", "UNCOMPRESSED", "ZIP"]
 449    ] = Field(default=None, alias="CompressionFormat")
 450    encryption_configuration: Optional[EncryptionConfigurationModel] = Field(
 451        default=None, alias="EncryptionConfiguration"
 452    )
 453    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 454        default=None, alias="CloudWatchLoggingOptions"
 455    )
 456
 457
 458class S3DestinationDescriptionModel(BaseModel):
 459    role_arn: str = Field(alias="RoleARN")
 460    bucket_arn: str = Field(alias="BucketARN")
 461    buffering_hints: BufferingHintsModel = Field(alias="BufferingHints")
 462    compression_format: Literal[
 463        "GZIP", "HADOOP_SNAPPY", "Snappy", "UNCOMPRESSED", "ZIP"
 464    ] = Field(alias="CompressionFormat")
 465    encryption_configuration: EncryptionConfigurationModel = Field(
 466        alias="EncryptionConfiguration"
 467    )
 468    prefix: Optional[str] = Field(default=None, alias="Prefix")
 469    error_output_prefix: Optional[str] = Field(default=None, alias="ErrorOutputPrefix")
 470    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 471        default=None, alias="CloudWatchLoggingOptions"
 472    )
 473
 474
 475class S3DestinationUpdateModel(BaseModel):
 476    role_arn: Optional[str] = Field(default=None, alias="RoleARN")
 477    bucket_arn: Optional[str] = Field(default=None, alias="BucketARN")
 478    prefix: Optional[str] = Field(default=None, alias="Prefix")
 479    error_output_prefix: Optional[str] = Field(default=None, alias="ErrorOutputPrefix")
 480    buffering_hints: Optional[BufferingHintsModel] = Field(
 481        default=None, alias="BufferingHints"
 482    )
 483    compression_format: Optional[
 484        Literal["GZIP", "HADOOP_SNAPPY", "Snappy", "UNCOMPRESSED", "ZIP"]
 485    ] = Field(default=None, alias="CompressionFormat")
 486    encryption_configuration: Optional[EncryptionConfigurationModel] = Field(
 487        default=None, alias="EncryptionConfiguration"
 488    )
 489    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 490        default=None, alias="CloudWatchLoggingOptions"
 491    )
 492
 493
 494class OutputFormatConfigurationModel(BaseModel):
 495    serializer: Optional[SerializerModel] = Field(default=None, alias="Serializer")
 496
 497
 498class ProcessingConfigurationModel(BaseModel):
 499    enabled: Optional[bool] = Field(default=None, alias="Enabled")
 500    processors: Optional[Sequence[ProcessorModel]] = Field(
 501        default=None, alias="Processors"
 502    )
 503
 504
 505class DataFormatConversionConfigurationModel(BaseModel):
 506    schema_configuration: Optional[SchemaConfigurationModel] = Field(
 507        default=None, alias="SchemaConfiguration"
 508    )
 509    input_format_configuration: Optional[InputFormatConfigurationModel] = Field(
 510        default=None, alias="InputFormatConfiguration"
 511    )
 512    output_format_configuration: Optional[OutputFormatConfigurationModel] = Field(
 513        default=None, alias="OutputFormatConfiguration"
 514    )
 515    enabled: Optional[bool] = Field(default=None, alias="Enabled")
 516
 517
 518class AmazonOpenSearchServerlessDestinationConfigurationModel(BaseModel):
 519    role_arn: str = Field(alias="RoleARN")
 520    index_name: str = Field(alias="IndexName")
 521    s3_configuration: S3DestinationConfigurationModel = Field(alias="S3Configuration")
 522    collection_endpoint: Optional[str] = Field(default=None, alias="CollectionEndpoint")
 523    buffering_hints: Optional[AmazonOpenSearchServerlessBufferingHintsModel] = Field(
 524        default=None, alias="BufferingHints"
 525    )
 526    retry_options: Optional[AmazonOpenSearchServerlessRetryOptionsModel] = Field(
 527        default=None, alias="RetryOptions"
 528    )
 529    s3_backup_mode: Optional[Literal["AllDocuments", "FailedDocumentsOnly"]] = Field(
 530        default=None, alias="S3BackupMode"
 531    )
 532    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 533        default=None, alias="ProcessingConfiguration"
 534    )
 535    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 536        default=None, alias="CloudWatchLoggingOptions"
 537    )
 538    vpc_configuration: Optional[VpcConfigurationModel] = Field(
 539        default=None, alias="VpcConfiguration"
 540    )
 541
 542
 543class AmazonOpenSearchServerlessDestinationDescriptionModel(BaseModel):
 544    role_arn: Optional[str] = Field(default=None, alias="RoleARN")
 545    collection_endpoint: Optional[str] = Field(default=None, alias="CollectionEndpoint")
 546    index_name: Optional[str] = Field(default=None, alias="IndexName")
 547    buffering_hints: Optional[AmazonOpenSearchServerlessBufferingHintsModel] = Field(
 548        default=None, alias="BufferingHints"
 549    )
 550    retry_options: Optional[AmazonOpenSearchServerlessRetryOptionsModel] = Field(
 551        default=None, alias="RetryOptions"
 552    )
 553    s3_backup_mode: Optional[Literal["AllDocuments", "FailedDocumentsOnly"]] = Field(
 554        default=None, alias="S3BackupMode"
 555    )
 556    s3_destination_description: Optional[S3DestinationDescriptionModel] = Field(
 557        default=None, alias="S3DestinationDescription"
 558    )
 559    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 560        default=None, alias="ProcessingConfiguration"
 561    )
 562    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 563        default=None, alias="CloudWatchLoggingOptions"
 564    )
 565    vpc_configuration_description: Optional[VpcConfigurationDescriptionModel] = Field(
 566        default=None, alias="VpcConfigurationDescription"
 567    )
 568
 569
 570class AmazonOpenSearchServerlessDestinationUpdateModel(BaseModel):
 571    role_arn: Optional[str] = Field(default=None, alias="RoleARN")
 572    collection_endpoint: Optional[str] = Field(default=None, alias="CollectionEndpoint")
 573    index_name: Optional[str] = Field(default=None, alias="IndexName")
 574    buffering_hints: Optional[AmazonOpenSearchServerlessBufferingHintsModel] = Field(
 575        default=None, alias="BufferingHints"
 576    )
 577    retry_options: Optional[AmazonOpenSearchServerlessRetryOptionsModel] = Field(
 578        default=None, alias="RetryOptions"
 579    )
 580    s3_update: Optional[S3DestinationUpdateModel] = Field(
 581        default=None, alias="S3Update"
 582    )
 583    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 584        default=None, alias="ProcessingConfiguration"
 585    )
 586    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 587        default=None, alias="CloudWatchLoggingOptions"
 588    )
 589
 590
 591class AmazonopensearchserviceDestinationConfigurationModel(BaseModel):
 592    role_arn: str = Field(alias="RoleARN")
 593    index_name: str = Field(alias="IndexName")
 594    s3_configuration: S3DestinationConfigurationModel = Field(alias="S3Configuration")
 595    domain_arn: Optional[str] = Field(default=None, alias="DomainARN")
 596    cluster_endpoint: Optional[str] = Field(default=None, alias="ClusterEndpoint")
 597    type_name: Optional[str] = Field(default=None, alias="TypeName")
 598    index_rotation_period: Optional[
 599        Literal["NoRotation", "OneDay", "OneHour", "OneMonth", "OneWeek"]
 600    ] = Field(default=None, alias="IndexRotationPeriod")
 601    buffering_hints: Optional[AmazonopensearchserviceBufferingHintsModel] = Field(
 602        default=None, alias="BufferingHints"
 603    )
 604    retry_options: Optional[AmazonopensearchserviceRetryOptionsModel] = Field(
 605        default=None, alias="RetryOptions"
 606    )
 607    s3_backup_mode: Optional[Literal["AllDocuments", "FailedDocumentsOnly"]] = Field(
 608        default=None, alias="S3BackupMode"
 609    )
 610    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 611        default=None, alias="ProcessingConfiguration"
 612    )
 613    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 614        default=None, alias="CloudWatchLoggingOptions"
 615    )
 616    vpc_configuration: Optional[VpcConfigurationModel] = Field(
 617        default=None, alias="VpcConfiguration"
 618    )
 619
 620
 621class AmazonopensearchserviceDestinationDescriptionModel(BaseModel):
 622    role_arn: Optional[str] = Field(default=None, alias="RoleARN")
 623    domain_arn: Optional[str] = Field(default=None, alias="DomainARN")
 624    cluster_endpoint: Optional[str] = Field(default=None, alias="ClusterEndpoint")
 625    index_name: Optional[str] = Field(default=None, alias="IndexName")
 626    type_name: Optional[str] = Field(default=None, alias="TypeName")
 627    index_rotation_period: Optional[
 628        Literal["NoRotation", "OneDay", "OneHour", "OneMonth", "OneWeek"]
 629    ] = Field(default=None, alias="IndexRotationPeriod")
 630    buffering_hints: Optional[AmazonopensearchserviceBufferingHintsModel] = Field(
 631        default=None, alias="BufferingHints"
 632    )
 633    retry_options: Optional[AmazonopensearchserviceRetryOptionsModel] = Field(
 634        default=None, alias="RetryOptions"
 635    )
 636    s3_backup_mode: Optional[Literal["AllDocuments", "FailedDocumentsOnly"]] = Field(
 637        default=None, alias="S3BackupMode"
 638    )
 639    s3_destination_description: Optional[S3DestinationDescriptionModel] = Field(
 640        default=None, alias="S3DestinationDescription"
 641    )
 642    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 643        default=None, alias="ProcessingConfiguration"
 644    )
 645    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 646        default=None, alias="CloudWatchLoggingOptions"
 647    )
 648    vpc_configuration_description: Optional[VpcConfigurationDescriptionModel] = Field(
 649        default=None, alias="VpcConfigurationDescription"
 650    )
 651
 652
 653class AmazonopensearchserviceDestinationUpdateModel(BaseModel):
 654    role_arn: Optional[str] = Field(default=None, alias="RoleARN")
 655    domain_arn: Optional[str] = Field(default=None, alias="DomainARN")
 656    cluster_endpoint: Optional[str] = Field(default=None, alias="ClusterEndpoint")
 657    index_name: Optional[str] = Field(default=None, alias="IndexName")
 658    type_name: Optional[str] = Field(default=None, alias="TypeName")
 659    index_rotation_period: Optional[
 660        Literal["NoRotation", "OneDay", "OneHour", "OneMonth", "OneWeek"]
 661    ] = Field(default=None, alias="IndexRotationPeriod")
 662    buffering_hints: Optional[AmazonopensearchserviceBufferingHintsModel] = Field(
 663        default=None, alias="BufferingHints"
 664    )
 665    retry_options: Optional[AmazonopensearchserviceRetryOptionsModel] = Field(
 666        default=None, alias="RetryOptions"
 667    )
 668    s3_update: Optional[S3DestinationUpdateModel] = Field(
 669        default=None, alias="S3Update"
 670    )
 671    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 672        default=None, alias="ProcessingConfiguration"
 673    )
 674    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 675        default=None, alias="CloudWatchLoggingOptions"
 676    )
 677
 678
 679class ElasticsearchDestinationConfigurationModel(BaseModel):
 680    role_arn: str = Field(alias="RoleARN")
 681    index_name: str = Field(alias="IndexName")
 682    s3_configuration: S3DestinationConfigurationModel = Field(alias="S3Configuration")
 683    domain_arn: Optional[str] = Field(default=None, alias="DomainARN")
 684    cluster_endpoint: Optional[str] = Field(default=None, alias="ClusterEndpoint")
 685    type_name: Optional[str] = Field(default=None, alias="TypeName")
 686    index_rotation_period: Optional[
 687        Literal["NoRotation", "OneDay", "OneHour", "OneMonth", "OneWeek"]
 688    ] = Field(default=None, alias="IndexRotationPeriod")
 689    buffering_hints: Optional[ElasticsearchBufferingHintsModel] = Field(
 690        default=None, alias="BufferingHints"
 691    )
 692    retry_options: Optional[ElasticsearchRetryOptionsModel] = Field(
 693        default=None, alias="RetryOptions"
 694    )
 695    s3_backup_mode: Optional[Literal["AllDocuments", "FailedDocumentsOnly"]] = Field(
 696        default=None, alias="S3BackupMode"
 697    )
 698    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 699        default=None, alias="ProcessingConfiguration"
 700    )
 701    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 702        default=None, alias="CloudWatchLoggingOptions"
 703    )
 704    vpc_configuration: Optional[VpcConfigurationModel] = Field(
 705        default=None, alias="VpcConfiguration"
 706    )
 707
 708
 709class ElasticsearchDestinationDescriptionModel(BaseModel):
 710    role_arn: Optional[str] = Field(default=None, alias="RoleARN")
 711    domain_arn: Optional[str] = Field(default=None, alias="DomainARN")
 712    cluster_endpoint: Optional[str] = Field(default=None, alias="ClusterEndpoint")
 713    index_name: Optional[str] = Field(default=None, alias="IndexName")
 714    type_name: Optional[str] = Field(default=None, alias="TypeName")
 715    index_rotation_period: Optional[
 716        Literal["NoRotation", "OneDay", "OneHour", "OneMonth", "OneWeek"]
 717    ] = Field(default=None, alias="IndexRotationPeriod")
 718    buffering_hints: Optional[ElasticsearchBufferingHintsModel] = Field(
 719        default=None, alias="BufferingHints"
 720    )
 721    retry_options: Optional[ElasticsearchRetryOptionsModel] = Field(
 722        default=None, alias="RetryOptions"
 723    )
 724    s3_backup_mode: Optional[Literal["AllDocuments", "FailedDocumentsOnly"]] = Field(
 725        default=None, alias="S3BackupMode"
 726    )
 727    s3_destination_description: Optional[S3DestinationDescriptionModel] = Field(
 728        default=None, alias="S3DestinationDescription"
 729    )
 730    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 731        default=None, alias="ProcessingConfiguration"
 732    )
 733    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 734        default=None, alias="CloudWatchLoggingOptions"
 735    )
 736    vpc_configuration_description: Optional[VpcConfigurationDescriptionModel] = Field(
 737        default=None, alias="VpcConfigurationDescription"
 738    )
 739
 740
 741class ElasticsearchDestinationUpdateModel(BaseModel):
 742    role_arn: Optional[str] = Field(default=None, alias="RoleARN")
 743    domain_arn: Optional[str] = Field(default=None, alias="DomainARN")
 744    cluster_endpoint: Optional[str] = Field(default=None, alias="ClusterEndpoint")
 745    index_name: Optional[str] = Field(default=None, alias="IndexName")
 746    type_name: Optional[str] = Field(default=None, alias="TypeName")
 747    index_rotation_period: Optional[
 748        Literal["NoRotation", "OneDay", "OneHour", "OneMonth", "OneWeek"]
 749    ] = Field(default=None, alias="IndexRotationPeriod")
 750    buffering_hints: Optional[ElasticsearchBufferingHintsModel] = Field(
 751        default=None, alias="BufferingHints"
 752    )
 753    retry_options: Optional[ElasticsearchRetryOptionsModel] = Field(
 754        default=None, alias="RetryOptions"
 755    )
 756    s3_update: Optional[S3DestinationUpdateModel] = Field(
 757        default=None, alias="S3Update"
 758    )
 759    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 760        default=None, alias="ProcessingConfiguration"
 761    )
 762    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 763        default=None, alias="CloudWatchLoggingOptions"
 764    )
 765
 766
 767class HttpEndpointDestinationConfigurationModel(BaseModel):
 768    endpoint_configuration: HttpEndpointConfigurationModel = Field(
 769        alias="EndpointConfiguration"
 770    )
 771    s3_configuration: S3DestinationConfigurationModel = Field(alias="S3Configuration")
 772    buffering_hints: Optional[HttpEndpointBufferingHintsModel] = Field(
 773        default=None, alias="BufferingHints"
 774    )
 775    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 776        default=None, alias="CloudWatchLoggingOptions"
 777    )
 778    request_configuration: Optional[HttpEndpointRequestConfigurationModel] = Field(
 779        default=None, alias="RequestConfiguration"
 780    )
 781    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 782        default=None, alias="ProcessingConfiguration"
 783    )
 784    role_arn: Optional[str] = Field(default=None, alias="RoleARN")
 785    retry_options: Optional[HttpEndpointRetryOptionsModel] = Field(
 786        default=None, alias="RetryOptions"
 787    )
 788    s3_backup_mode: Optional[Literal["AllData", "FailedDataOnly"]] = Field(
 789        default=None, alias="S3BackupMode"
 790    )
 791
 792
 793class HttpEndpointDestinationDescriptionModel(BaseModel):
 794    endpoint_configuration: Optional[HttpEndpointDescriptionModel] = Field(
 795        default=None, alias="EndpointConfiguration"
 796    )
 797    buffering_hints: Optional[HttpEndpointBufferingHintsModel] = Field(
 798        default=None, alias="BufferingHints"
 799    )
 800    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 801        default=None, alias="CloudWatchLoggingOptions"
 802    )
 803    request_configuration: Optional[HttpEndpointRequestConfigurationModel] = Field(
 804        default=None, alias="RequestConfiguration"
 805    )
 806    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 807        default=None, alias="ProcessingConfiguration"
 808    )
 809    role_arn: Optional[str] = Field(default=None, alias="RoleARN")
 810    retry_options: Optional[HttpEndpointRetryOptionsModel] = Field(
 811        default=None, alias="RetryOptions"
 812    )
 813    s3_backup_mode: Optional[Literal["AllData", "FailedDataOnly"]] = Field(
 814        default=None, alias="S3BackupMode"
 815    )
 816    s3_destination_description: Optional[S3DestinationDescriptionModel] = Field(
 817        default=None, alias="S3DestinationDescription"
 818    )
 819
 820
 821class HttpEndpointDestinationUpdateModel(BaseModel):
 822    endpoint_configuration: Optional[HttpEndpointConfigurationModel] = Field(
 823        default=None, alias="EndpointConfiguration"
 824    )
 825    buffering_hints: Optional[HttpEndpointBufferingHintsModel] = Field(
 826        default=None, alias="BufferingHints"
 827    )
 828    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 829        default=None, alias="CloudWatchLoggingOptions"
 830    )
 831    request_configuration: Optional[HttpEndpointRequestConfigurationModel] = Field(
 832        default=None, alias="RequestConfiguration"
 833    )
 834    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 835        default=None, alias="ProcessingConfiguration"
 836    )
 837    role_arn: Optional[str] = Field(default=None, alias="RoleARN")
 838    retry_options: Optional[HttpEndpointRetryOptionsModel] = Field(
 839        default=None, alias="RetryOptions"
 840    )
 841    s3_backup_mode: Optional[Literal["AllData", "FailedDataOnly"]] = Field(
 842        default=None, alias="S3BackupMode"
 843    )
 844    s3_update: Optional[S3DestinationUpdateModel] = Field(
 845        default=None, alias="S3Update"
 846    )
 847
 848
 849class RedshiftDestinationConfigurationModel(BaseModel):
 850    role_arn: str = Field(alias="RoleARN")
 851    cluster_jdbcurl: str = Field(alias="ClusterJDBCURL")
 852    copy_command: CopyCommandModel = Field(alias="CopyCommand")
 853    username: str = Field(alias="Username")
 854    password: str = Field(alias="Password")
 855    s3_configuration: S3DestinationConfigurationModel = Field(alias="S3Configuration")
 856    retry_options: Optional[RedshiftRetryOptionsModel] = Field(
 857        default=None, alias="RetryOptions"
 858    )
 859    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 860        default=None, alias="ProcessingConfiguration"
 861    )
 862    s3_backup_mode: Optional[Literal["Disabled", "Enabled"]] = Field(
 863        default=None, alias="S3BackupMode"
 864    )
 865    s3_backup_configuration: Optional[S3DestinationConfigurationModel] = Field(
 866        default=None, alias="S3BackupConfiguration"
 867    )
 868    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 869        default=None, alias="CloudWatchLoggingOptions"
 870    )
 871
 872
 873class RedshiftDestinationDescriptionModel(BaseModel):
 874    role_arn: str = Field(alias="RoleARN")
 875    cluster_jdbcurl: str = Field(alias="ClusterJDBCURL")
 876    copy_command: CopyCommandModel = Field(alias="CopyCommand")
 877    username: str = Field(alias="Username")
 878    s3_destination_description: S3DestinationDescriptionModel = Field(
 879        alias="S3DestinationDescription"
 880    )
 881    retry_options: Optional[RedshiftRetryOptionsModel] = Field(
 882        default=None, alias="RetryOptions"
 883    )
 884    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 885        default=None, alias="ProcessingConfiguration"
 886    )
 887    s3_backup_mode: Optional[Literal["Disabled", "Enabled"]] = Field(
 888        default=None, alias="S3BackupMode"
 889    )
 890    s3_backup_description: Optional[S3DestinationDescriptionModel] = Field(
 891        default=None, alias="S3BackupDescription"
 892    )
 893    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 894        default=None, alias="CloudWatchLoggingOptions"
 895    )
 896
 897
 898class RedshiftDestinationUpdateModel(BaseModel):
 899    role_arn: Optional[str] = Field(default=None, alias="RoleARN")
 900    cluster_jdbcurl: Optional[str] = Field(default=None, alias="ClusterJDBCURL")
 901    copy_command: Optional[CopyCommandModel] = Field(default=None, alias="CopyCommand")
 902    username: Optional[str] = Field(default=None, alias="Username")
 903    password: Optional[str] = Field(default=None, alias="Password")
 904    retry_options: Optional[RedshiftRetryOptionsModel] = Field(
 905        default=None, alias="RetryOptions"
 906    )
 907    s3_update: Optional[S3DestinationUpdateModel] = Field(
 908        default=None, alias="S3Update"
 909    )
 910    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 911        default=None, alias="ProcessingConfiguration"
 912    )
 913    s3_backup_mode: Optional[Literal["Disabled", "Enabled"]] = Field(
 914        default=None, alias="S3BackupMode"
 915    )
 916    s3_backup_update: Optional[S3DestinationUpdateModel] = Field(
 917        default=None, alias="S3BackupUpdate"
 918    )
 919    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 920        default=None, alias="CloudWatchLoggingOptions"
 921    )
 922
 923
 924class SplunkDestinationConfigurationModel(BaseModel):
 925    hecendpoint: str = Field(alias="HECEndpoint")
 926    hecendpoint_type: Literal["Event", "Raw"] = Field(alias="HECEndpointType")
 927    hectoken: str = Field(alias="HECToken")
 928    s3_configuration: S3DestinationConfigurationModel = Field(alias="S3Configuration")
 929    hecacknowledgment_timeout_in_seconds: Optional[int] = Field(
 930        default=None, alias="HECAcknowledgmentTimeoutInSeconds"
 931    )
 932    retry_options: Optional[SplunkRetryOptionsModel] = Field(
 933        default=None, alias="RetryOptions"
 934    )
 935    s3_backup_mode: Optional[Literal["AllEvents", "FailedEventsOnly"]] = Field(
 936        default=None, alias="S3BackupMode"
 937    )
 938    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 939        default=None, alias="ProcessingConfiguration"
 940    )
 941    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 942        default=None, alias="CloudWatchLoggingOptions"
 943    )
 944
 945
 946class SplunkDestinationDescriptionModel(BaseModel):
 947    hecendpoint: Optional[str] = Field(default=None, alias="HECEndpoint")
 948    hecendpoint_type: Optional[Literal["Event", "Raw"]] = Field(
 949        default=None, alias="HECEndpointType"
 950    )
 951    hectoken: Optional[str] = Field(default=None, alias="HECToken")
 952    hecacknowledgment_timeout_in_seconds: Optional[int] = Field(
 953        default=None, alias="HECAcknowledgmentTimeoutInSeconds"
 954    )
 955    retry_options: Optional[SplunkRetryOptionsModel] = Field(
 956        default=None, alias="RetryOptions"
 957    )
 958    s3_backup_mode: Optional[Literal["AllEvents", "FailedEventsOnly"]] = Field(
 959        default=None, alias="S3BackupMode"
 960    )
 961    s3_destination_description: Optional[S3DestinationDescriptionModel] = Field(
 962        default=None, alias="S3DestinationDescription"
 963    )
 964    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 965        default=None, alias="ProcessingConfiguration"
 966    )
 967    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 968        default=None, alias="CloudWatchLoggingOptions"
 969    )
 970
 971
 972class SplunkDestinationUpdateModel(BaseModel):
 973    hecendpoint: Optional[str] = Field(default=None, alias="HECEndpoint")
 974    hecendpoint_type: Optional[Literal["Event", "Raw"]] = Field(
 975        default=None, alias="HECEndpointType"
 976    )
 977    hectoken: Optional[str] = Field(default=None, alias="HECToken")
 978    hecacknowledgment_timeout_in_seconds: Optional[int] = Field(
 979        default=None, alias="HECAcknowledgmentTimeoutInSeconds"
 980    )
 981    retry_options: Optional[SplunkRetryOptionsModel] = Field(
 982        default=None, alias="RetryOptions"
 983    )
 984    s3_backup_mode: Optional[Literal["AllEvents", "FailedEventsOnly"]] = Field(
 985        default=None, alias="S3BackupMode"
 986    )
 987    s3_update: Optional[S3DestinationUpdateModel] = Field(
 988        default=None, alias="S3Update"
 989    )
 990    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
 991        default=None, alias="ProcessingConfiguration"
 992    )
 993    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
 994        default=None, alias="CloudWatchLoggingOptions"
 995    )
 996
 997
 998class ExtendedS3DestinationConfigurationModel(BaseModel):
 999    role_arn: str = Field(alias="RoleARN")
1000    bucket_arn: str = Field(alias="BucketARN")
1001    prefix: Optional[str] = Field(default=None, alias="Prefix")
1002    error_output_prefix: Optional[str] = Field(default=None, alias="ErrorOutputPrefix")
1003    buffering_hints: Optional[BufferingHintsModel] = Field(
1004        default=None, alias="BufferingHints"
1005    )
1006    compression_format: Optional[
1007        Literal["GZIP", "HADOOP_SNAPPY", "Snappy", "UNCOMPRESSED", "ZIP"]
1008    ] = Field(default=None, alias="CompressionFormat")
1009    encryption_configuration: Optional[EncryptionConfigurationModel] = Field(
1010        default=None, alias="EncryptionConfiguration"
1011    )
1012    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
1013        default=None, alias="CloudWatchLoggingOptions"
1014    )
1015    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
1016        default=None, alias="ProcessingConfiguration"
1017    )
1018    s3_backup_mode: Optional[Literal["Disabled", "Enabled"]] = Field(
1019        default=None, alias="S3BackupMode"
1020    )
1021    s3_backup_configuration: Optional[S3DestinationConfigurationModel] = Field(
1022        default=None, alias="S3BackupConfiguration"
1023    )
1024    data_format_conversion_configuration: Optional[
1025        DataFormatConversionConfigurationModel
1026    ] = Field(default=None, alias="DataFormatConversionConfiguration")
1027    dynamic_partitioning_configuration: Optional[
1028        DynamicPartitioningConfigurationModel
1029    ] = Field(default=None, alias="DynamicPartitioningConfiguration")
1030
1031
1032class ExtendedS3DestinationDescriptionModel(BaseModel):
1033    role_arn: str = Field(alias="RoleARN")
1034    bucket_arn: str = Field(alias="BucketARN")
1035    buffering_hints: BufferingHintsModel = Field(alias="BufferingHints")
1036    compression_format: Literal[
1037        "GZIP", "HADOOP_SNAPPY", "Snappy", "UNCOMPRESSED", "ZIP"
1038    ] = Field(alias="CompressionFormat")
1039    encryption_configuration: EncryptionConfigurationModel = Field(
1040        alias="EncryptionConfiguration"
1041    )
1042    prefix: Optional[str] = Field(default=None, alias="Prefix")
1043    error_output_prefix: Optional[str] = Field(default=None, alias="ErrorOutputPrefix")
1044    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
1045        default=None, alias="CloudWatchLoggingOptions"
1046    )
1047    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
1048        default=None, alias="ProcessingConfiguration"
1049    )
1050    s3_backup_mode: Optional[Literal["Disabled", "Enabled"]] = Field(
1051        default=None, alias="S3BackupMode"
1052    )
1053    s3_backup_description: Optional[S3DestinationDescriptionModel] = Field(
1054        default=None, alias="S3BackupDescription"
1055    )
1056    data_format_conversion_configuration: Optional[
1057        DataFormatConversionConfigurationModel
1058    ] = Field(default=None, alias="DataFormatConversionConfiguration")
1059    dynamic_partitioning_configuration: Optional[
1060        DynamicPartitioningConfigurationModel
1061    ] = Field(default=None, alias="DynamicPartitioningConfiguration")
1062
1063
1064class ExtendedS3DestinationUpdateModel(BaseModel):
1065    role_arn: Optional[str] = Field(default=None, alias="RoleARN")
1066    bucket_arn: Optional[str] = Field(default=None, alias="BucketARN")
1067    prefix: Optional[str] = Field(default=None, alias="Prefix")
1068    error_output_prefix: Optional[str] = Field(default=None, alias="ErrorOutputPrefix")
1069    buffering_hints: Optional[BufferingHintsModel] = Field(
1070        default=None, alias="BufferingHints"
1071    )
1072    compression_format: Optional[
1073        Literal["GZIP", "HADOOP_SNAPPY", "Snappy", "UNCOMPRESSED", "ZIP"]
1074    ] = Field(default=None, alias="CompressionFormat")
1075    encryption_configuration: Optional[EncryptionConfigurationModel] = Field(
1076        default=None, alias="EncryptionConfiguration"
1077    )
1078    cloud_watch_logging_options: Optional[CloudWatchLoggingOptionsModel] = Field(
1079        default=None, alias="CloudWatchLoggingOptions"
1080    )
1081    processing_configuration: Optional[ProcessingConfigurationModel] = Field(
1082        default=None, alias="ProcessingConfiguration"
1083    )
1084    s3_backup_mode: Optional[Literal["Disabled", "Enabled"]] = Field(
1085        default=None, alias="S3BackupMode"
1086    )
1087    s3_backup_update: Optional[S3DestinationUpdateModel] = Field(
1088        default=None, alias="S3BackupUpdate"
1089    )
1090    data_format_conversion_configuration: Optional[
1091        DataFormatConversionConfigurationModel
1092    ] = Field(default=None, alias="DataFormatConversionConfiguration")
1093    dynamic_partitioning_configuration: Optional[
1094        DynamicPartitioningConfigurationModel
1095    ] = Field(default=None, alias="DynamicPartitioningConfiguration")
1096
1097
1098class CreateDeliveryStreamInputRequestModel(BaseModel):
1099    delivery_stream_name: str = Field(alias="DeliveryStreamName")
1100    delivery_stream_type: Optional[
1101        Literal["DirectPut", "KinesisStreamAsSource"]
1102    ] = Field(default=None, alias="DeliveryStreamType")
1103    kinesis_stream_source_configuration: Optional[
1104        KinesisStreamSourceConfigurationModel
1105    ] = Field(default=None, alias="KinesisStreamSourceConfiguration")
1106    delivery_stream_encryption_configuration_input: Optional[
1107        DeliveryStreamEncryptionConfigurationInputModel
1108    ] = Field(default=None, alias="DeliveryStreamEncryptionConfigurationInput")
1109    s3_destination_configuration: Optional[S3DestinationConfigurationModel] = Field(
1110        default=None, alias="S3DestinationConfiguration"
1111    )
1112    extended_s3_destination_configuration: Optional[
1113        ExtendedS3DestinationConfigurationModel
1114    ] = Field(default=None, alias="ExtendedS3DestinationConfiguration")
1115    redshift_destination_configuration: Optional[
1116        RedshiftDestinationConfigurationModel
1117    ] = Field(default=None, alias="RedshiftDestinationConfiguration")
1118    elasticsearch_destination_configuration: Optional[
1119        ElasticsearchDestinationConfigurationModel
1120    ] = Field(default=None, alias="ElasticsearchDestinationConfiguration")
1121    amazonopensearchservice_destination_configuration: Optional[
1122        AmazonopensearchserviceDestinationConfigurationModel
1123    ] = Field(default=None, alias="AmazonopensearchserviceDestinationConfiguration")
1124    splunk_destination_configuration: Optional[
1125        SplunkDestinationConfigurationModel
1126    ] = Field(default=None, alias="SplunkDestinationConfiguration")
1127    http_endpoint_destination_configuration: Optional[
1128        HttpEndpointDestinationConfigurationModel
1129    ] = Field(default=None, alias="HttpEndpointDestinationConfiguration")
1130    tags: Optional[Sequence[TagModel]] = Field(default=None, alias="Tags")
1131    amazon_open_search_serverless_destination_configuration: Optional[
1132        AmazonOpenSearchServerlessDestinationConfigurationModel
1133    ] = Field(default=None, alias="AmazonOpenSearchServerlessDestinationConfiguration")
1134
1135
1136class DestinationDescriptionModel(BaseModel):
1137    destination_id: str = Field(alias="DestinationId")
1138    s3_destination_description: Optional[S3DestinationDescriptionModel] = Field(
1139        default=None, alias="S3DestinationDescription"
1140    )
1141    extended_s3_destination_description: Optional[
1142        ExtendedS3DestinationDescriptionModel
1143    ] = Field(default=None, alias="ExtendedS3DestinationDescription")
1144    redshift_destination_description: Optional[
1145        RedshiftDestinationDescriptionModel
1146    ] = Field(default=None, alias="RedshiftDestinationDescription")
1147    elasticsearch_destination_description: Optional[
1148        ElasticsearchDestinationDescriptionModel
1149    ] = Field(default=None, alias="ElasticsearchDestinationDescription")
1150    amazonopensearchservice_destination_description: Optional[
1151        AmazonopensearchserviceDestinationDescriptionModel
1152    ] = Field(default=None, alias="AmazonopensearchserviceDestinationDescription")
1153    splunk_destination_description: Optional[SplunkDestinationDescriptionModel] = Field(
1154        default=None, alias="SplunkDestinationDescription"
1155    )
1156    http_endpoint_destination_description: Optional[
1157        HttpEndpointDestinationDescriptionModel
1158    ] = Field(default=None, alias="HttpEndpointDestinationDescription")
1159    amazon_open_search_serverless_destination_description: Optional[
1160        AmazonOpenSearchServerlessDestinationDescriptionModel
1161    ] = Field(default=None, alias="AmazonOpenSearchServerlessDestinationDescription")
1162
1163
1164class UpdateDestinationInputRequestModel(BaseModel):
1165    delivery_stream_name: str = Field(alias="DeliveryStreamName")
1166    current_delivery_stream_version_id: str = Field(
1167        alias="CurrentDeliveryStreamVersionId"
1168    )
1169    destination_id: str = Field(alias="DestinationId")
1170    s3_destination_update: Optional[S3DestinationUpdateModel] = Field(
1171        default=None, alias="S3DestinationUpdate"
1172    )
1173    extended_s3_destination_update: Optional[ExtendedS3DestinationUpdateModel] = Field(
1174        default=None, alias="ExtendedS3DestinationUpdate"
1175    )
1176    redshift_destination_update: Optional[RedshiftDestinationUpdateModel] = Field(
1177        default=None, alias="RedshiftDestinationUpdate"
1178    )
1179    elasticsearch_destination_update: Optional[
1180        ElasticsearchDestinationUpdateModel
1181    ] = Field(default=None, alias="ElasticsearchDestinationUpdate")
1182    amazonopensearchservice_destination_update: Optional[
1183        AmazonopensearchserviceDestinationUpdateModel
1184    ] = Field(default=None, alias="AmazonopensearchserviceDestinationUpdate")
1185    splunk_destination_update: Optional[SplunkDestinationUpdateModel] = Field(
1186        default=None, alias="SplunkDestinationUpdate"
1187    )
1188    http_endpoint_destination_update: Optional[
1189        HttpEndpointDestinationUpdateModel
1190    ] = Field(default=None, alias="HttpEndpointDestinationUpdate")
1191    amazon_open_search_serverless_destination_update: Optional[
1192        AmazonOpenSearchServerlessDestinationUpdateModel
1193    ] = Field(default=None, alias="AmazonOpenSearchServerlessDestinationUpdate")
1194
1195
1196class DeliveryStreamDescriptionModel(BaseModel):
1197    delivery_stream_name: str = Field(alias="DeliveryStreamName")
1198    delivery_stream_arn: str = Field(alias="DeliveryStreamARN")
1199    delivery_stream_status: Literal[
1200        "ACTIVE", "CREATING", "CREATING_FAILED", "DELETING", "DELETING_FAILED"
1201    ] = Field(alias="DeliveryStreamStatus")
1202    delivery_stream_type: Literal["DirectPut", "KinesisStreamAsSource"] = Field(
1203        alias="DeliveryStreamType"
1204    )
1205    version_id: str = Field(alias="VersionId")
1206    destinations: List[DestinationDescriptionModel] = Field(alias="Destinations")
1207    has_more_destinations: bool = Field(alias="HasMoreDestinations")
1208    failure_description: Optional[FailureDescriptionModel] = Field(
1209        default=None, alias="FailureDescription"
1210    )
1211    delivery_stream_encryption_configuration: Optional[
1212        DeliveryStreamEncryptionConfigurationModel
1213    ] = Field(default=None, alias="DeliveryStreamEncryptionConfiguration")
1214    create_timestamp: Optional[datetime] = Field(default=None, alias="CreateTimestamp")
1215    last_update_timestamp: Optional[datetime] = Field(
1216        default=None, alias="LastUpdateTimestamp"
1217    )
1218    source: Optional[SourceDescriptionModel] = Field(default=None, alias="Source")
1219
1220
1221class DescribeDeliveryStreamOutputModel(BaseModel):
1222    delivery_stream_description: DeliveryStreamDescriptionModel = Field(
1223        alias="DeliveryStreamDescription"
1224    )
1225    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")