mypydantic.models.appflow
1# Model Generated: Thu Mar 2 21:56:16 2023 2 3from __future__ import annotations 4 5from datetime import datetime 6from typing import Any, Dict, List, Literal, Mapping, Optional, Sequence, Union 7 8from pydantic import Field 9 10from mypydantic.models.base_model import BaseModel 11 12 13class AggregationConfigModel(BaseModel): 14 aggregation_type: Optional[Literal["None", "SingleFile"]] = Field( 15 default=None, alias="aggregationType" 16 ) 17 target_file_size: Optional[int] = Field(default=None, alias="targetFileSize") 18 19 20class AmplitudeConnectorProfileCredentialsModel(BaseModel): 21 api_key: str = Field(alias="apiKey") 22 secret_key: str = Field(alias="secretKey") 23 24 25class AmplitudeSourcePropertiesModel(BaseModel): 26 object: str = Field(alias="object") 27 28 29class ApiKeyCredentialsModel(BaseModel): 30 api_key: str = Field(alias="apiKey") 31 api_secret_key: Optional[str] = Field(default=None, alias="apiSecretKey") 32 33 34class AuthParameterModel(BaseModel): 35 key: Optional[str] = Field(default=None, alias="key") 36 is_required: Optional[bool] = Field(default=None, alias="isRequired") 37 label: Optional[str] = Field(default=None, alias="label") 38 description: Optional[str] = Field(default=None, alias="description") 39 is_sensitive_field: Optional[bool] = Field(default=None, alias="isSensitiveField") 40 connector_supplied_values: Optional[List[str]] = Field( 41 default=None, alias="connectorSuppliedValues" 42 ) 43 44 45class BasicAuthCredentialsModel(BaseModel): 46 username: str = Field(alias="username") 47 password: str = Field(alias="password") 48 49 50class ConnectorRuntimeSettingModel(BaseModel): 51 key: Optional[str] = Field(default=None, alias="key") 52 data_type: Optional[str] = Field(default=None, alias="dataType") 53 is_required: Optional[bool] = Field(default=None, alias="isRequired") 54 label: Optional[str] = Field(default=None, alias="label") 55 description: Optional[str] = Field(default=None, alias="description") 56 scope: Optional[str] = Field(default=None, alias="scope") 57 connector_supplied_value_options: Optional[List[str]] = Field( 58 default=None, alias="connectorSuppliedValueOptions" 59 ) 60 61 62class ConnectorDetailModel(BaseModel): 63 connector_description: Optional[str] = Field( 64 default=None, alias="connectorDescription" 65 ) 66 connector_name: Optional[str] = Field(default=None, alias="connectorName") 67 connector_owner: Optional[str] = Field(default=None, alias="connectorOwner") 68 connector_version: Optional[str] = Field(default=None, alias="connectorVersion") 69 application_type: Optional[str] = Field(default=None, alias="applicationType") 70 connector_type: Optional[ 71 Literal[ 72 "Amplitude", 73 "CustomConnector", 74 "CustomerProfiles", 75 "Datadog", 76 "Dynatrace", 77 "EventBridge", 78 "Googleanalytics", 79 "Honeycode", 80 "Infornexus", 81 "LookoutMetrics", 82 "Marketo", 83 "Pardot", 84 "Redshift", 85 "S3", 86 "SAPOData", 87 "Salesforce", 88 "Servicenow", 89 "Singular", 90 "Slack", 91 "Snowflake", 92 "Trendmicro", 93 "Upsolver", 94 "Veeva", 95 "Zendesk", 96 ] 97 ] = Field(default=None, alias="connectorType") 98 connector_label: Optional[str] = Field(default=None, alias="connectorLabel") 99 registered_at: Optional[datetime] = Field(default=None, alias="registeredAt") 100 registered_by: Optional[str] = Field(default=None, alias="registeredBy") 101 connector_provisioning_type: Optional[Literal["LAMBDA"]] = Field( 102 default=None, alias="connectorProvisioningType" 103 ) 104 connector_modes: Optional[List[str]] = Field(default=None, alias="connectorModes") 105 106 107class DestinationFieldPropertiesModel(BaseModel): 108 is_creatable: Optional[bool] = Field(default=None, alias="isCreatable") 109 is_nullable: Optional[bool] = Field(default=None, alias="isNullable") 110 is_upsertable: Optional[bool] = Field(default=None, alias="isUpsertable") 111 is_updatable: Optional[bool] = Field(default=None, alias="isUpdatable") 112 is_defaulted_on_create: Optional[bool] = Field( 113 default=None, alias="isDefaultedOnCreate" 114 ) 115 supported_write_operations: Optional[ 116 List[Literal["DELETE", "INSERT", "UPDATE", "UPSERT"]] 117 ] = Field(default=None, alias="supportedWriteOperations") 118 119 120class SourceFieldPropertiesModel(BaseModel): 121 is_retrievable: Optional[bool] = Field(default=None, alias="isRetrievable") 122 is_queryable: Optional[bool] = Field(default=None, alias="isQueryable") 123 is_timestamp_field_for_incremental_queries: Optional[bool] = Field( 124 default=None, alias="isTimestampFieldForIncrementalQueries" 125 ) 126 127 128class ConnectorEntityModel(BaseModel): 129 name: str = Field(alias="name") 130 label: Optional[str] = Field(default=None, alias="label") 131 has_nested_entities: Optional[bool] = Field(default=None, alias="hasNestedEntities") 132 133 134class GoogleAnalyticsMetadataModel(BaseModel): 135 oauth_scopes: Optional[List[str]] = Field(default=None, alias="oAuthScopes") 136 137 138class HoneycodeMetadataModel(BaseModel): 139 oauth_scopes: Optional[List[str]] = Field(default=None, alias="oAuthScopes") 140 141 142class SalesforceMetadataModel(BaseModel): 143 oauth_scopes: Optional[List[str]] = Field(default=None, alias="oAuthScopes") 144 data_transfer_apis: Optional[ 145 List[Literal["AUTOMATIC", "BULKV2", "REST_SYNC"]] 146 ] = Field(default=None, alias="dataTransferApis") 147 148 149class SlackMetadataModel(BaseModel): 150 oauth_scopes: Optional[List[str]] = Field(default=None, alias="oAuthScopes") 151 152 153class SnowflakeMetadataModel(BaseModel): 154 supported_regions: Optional[List[str]] = Field( 155 default=None, alias="supportedRegions" 156 ) 157 158 159class ZendeskMetadataModel(BaseModel): 160 oauth_scopes: Optional[List[str]] = Field(default=None, alias="oAuthScopes") 161 162 163class ConnectorOAuthRequestModel(BaseModel): 164 auth_code: Optional[str] = Field(default=None, alias="authCode") 165 redirect_uri: Optional[str] = Field(default=None, alias="redirectUri") 166 167 168class ConnectorOperatorModel(BaseModel): 169 amplitude: Optional[Literal["BETWEEN"]] = Field(default=None, alias="Amplitude") 170 datadog: Optional[ 171 Literal[ 172 "ADDITION", 173 "BETWEEN", 174 "DIVISION", 175 "EQUAL_TO", 176 "MASK_ALL", 177 "MASK_FIRST_N", 178 "MASK_LAST_N", 179 "MULTIPLICATION", 180 "NO_OP", 181 "PROJECTION", 182 "SUBTRACTION", 183 "VALIDATE_NON_NEGATIVE", 184 "VALIDATE_NON_NULL", 185 "VALIDATE_NON_ZERO", 186 "VALIDATE_NUMERIC", 187 ] 188 ] = Field(default=None, alias="Datadog") 189 dynatrace: Optional[ 190 Literal[ 191 "ADDITION", 192 "BETWEEN", 193 "DIVISION", 194 "EQUAL_TO", 195 "MASK_ALL", 196 "MASK_FIRST_N", 197 "MASK_LAST_N", 198 "MULTIPLICATION", 199 "NO_OP", 200 "PROJECTION", 201 "SUBTRACTION", 202 "VALIDATE_NON_NEGATIVE", 203 "VALIDATE_NON_NULL", 204 "VALIDATE_NON_ZERO", 205 "VALIDATE_NUMERIC", 206 ] 207 ] = Field(default=None, alias="Dynatrace") 208 google_analytics: Optional[Literal["BETWEEN", "PROJECTION"]] = Field( 209 default=None, alias="GoogleAnalytics" 210 ) 211 infor_nexus: Optional[ 212 Literal[ 213 "ADDITION", 214 "BETWEEN", 215 "DIVISION", 216 "EQUAL_TO", 217 "MASK_ALL", 218 "MASK_FIRST_N", 219 "MASK_LAST_N", 220 "MULTIPLICATION", 221 "NO_OP", 222 "PROJECTION", 223 "SUBTRACTION", 224 "VALIDATE_NON_NEGATIVE", 225 "VALIDATE_NON_NULL", 226 "VALIDATE_NON_ZERO", 227 "VALIDATE_NUMERIC", 228 ] 229 ] = Field(default=None, alias="InforNexus") 230 marketo: Optional[ 231 Literal[ 232 "ADDITION", 233 "BETWEEN", 234 "DIVISION", 235 "GREATER_THAN", 236 "LESS_THAN", 237 "MASK_ALL", 238 "MASK_FIRST_N", 239 "MASK_LAST_N", 240 "MULTIPLICATION", 241 "NO_OP", 242 "PROJECTION", 243 "SUBTRACTION", 244 "VALIDATE_NON_NEGATIVE", 245 "VALIDATE_NON_NULL", 246 "VALIDATE_NON_ZERO", 247 "VALIDATE_NUMERIC", 248 ] 249 ] = Field(default=None, alias="Marketo") 250 s3: Optional[ 251 Literal[ 252 "ADDITION", 253 "BETWEEN", 254 "DIVISION", 255 "EQUAL_TO", 256 "GREATER_THAN", 257 "GREATER_THAN_OR_EQUAL_TO", 258 "LESS_THAN", 259 "LESS_THAN_OR_EQUAL_TO", 260 "MASK_ALL", 261 "MASK_FIRST_N", 262 "MASK_LAST_N", 263 "MULTIPLICATION", 264 "NOT_EQUAL_TO", 265 "NO_OP", 266 "PROJECTION", 267 "SUBTRACTION", 268 "VALIDATE_NON_NEGATIVE", 269 "VALIDATE_NON_NULL", 270 "VALIDATE_NON_ZERO", 271 "VALIDATE_NUMERIC", 272 ] 273 ] = Field(default=None, alias="S3") 274 salesforce: Optional[ 275 Literal[ 276 "ADDITION", 277 "BETWEEN", 278 "CONTAINS", 279 "DIVISION", 280 "EQUAL_TO", 281 "GREATER_THAN", 282 "GREATER_THAN_OR_EQUAL_TO", 283 "LESS_THAN", 284 "LESS_THAN_OR_EQUAL_TO", 285 "MASK_ALL", 286 "MASK_FIRST_N", 287 "MASK_LAST_N", 288 "MULTIPLICATION", 289 "NOT_EQUAL_TO", 290 "NO_OP", 291 "PROJECTION", 292 "SUBTRACTION", 293 "VALIDATE_NON_NEGATIVE", 294 "VALIDATE_NON_NULL", 295 "VALIDATE_NON_ZERO", 296 "VALIDATE_NUMERIC", 297 ] 298 ] = Field(default=None, alias="Salesforce") 299 service_now: Optional[ 300 Literal[ 301 "ADDITION", 302 "BETWEEN", 303 "CONTAINS", 304 "DIVISION", 305 "EQUAL_TO", 306 "GREATER_THAN", 307 "GREATER_THAN_OR_EQUAL_TO", 308 "LESS_THAN", 309 "LESS_THAN_OR_EQUAL_TO", 310 "MASK_ALL", 311 "MASK_FIRST_N", 312 "MASK_LAST_N", 313 "MULTIPLICATION", 314 "NOT_EQUAL_TO", 315 "NO_OP", 316 "PROJECTION", 317 "SUBTRACTION", 318 "VALIDATE_NON_NEGATIVE", 319 "VALIDATE_NON_NULL", 320 "VALIDATE_NON_ZERO", 321 "VALIDATE_NUMERIC", 322 ] 323 ] = Field(default=None, alias="ServiceNow") 324 singular: Optional[ 325 Literal[ 326 "ADDITION", 327 "DIVISION", 328 "EQUAL_TO", 329 "MASK_ALL", 330 "MASK_FIRST_N", 331 "MASK_LAST_N", 332 "MULTIPLICATION", 333 "NO_OP", 334 "PROJECTION", 335 "SUBTRACTION", 336 "VALIDATE_NON_NEGATIVE", 337 "VALIDATE_NON_NULL", 338 "VALIDATE_NON_ZERO", 339 "VALIDATE_NUMERIC", 340 ] 341 ] = Field(default=None, alias="Singular") 342 slack: Optional[ 343 Literal[ 344 "ADDITION", 345 "BETWEEN", 346 "DIVISION", 347 "EQUAL_TO", 348 "GREATER_THAN", 349 "GREATER_THAN_OR_EQUAL_TO", 350 "LESS_THAN", 351 "LESS_THAN_OR_EQUAL_TO", 352 "MASK_ALL", 353 "MASK_FIRST_N", 354 "MASK_LAST_N", 355 "MULTIPLICATION", 356 "NO_OP", 357 "PROJECTION", 358 "SUBTRACTION", 359 "VALIDATE_NON_NEGATIVE", 360 "VALIDATE_NON_NULL", 361 "VALIDATE_NON_ZERO", 362 "VALIDATE_NUMERIC", 363 ] 364 ] = Field(default=None, alias="Slack") 365 trendmicro: Optional[ 366 Literal[ 367 "ADDITION", 368 "DIVISION", 369 "EQUAL_TO", 370 "MASK_ALL", 371 "MASK_FIRST_N", 372 "MASK_LAST_N", 373 "MULTIPLICATION", 374 "NO_OP", 375 "PROJECTION", 376 "SUBTRACTION", 377 "VALIDATE_NON_NEGATIVE", 378 "VALIDATE_NON_NULL", 379 "VALIDATE_NON_ZERO", 380 "VALIDATE_NUMERIC", 381 ] 382 ] = Field(default=None, alias="Trendmicro") 383 veeva: Optional[ 384 Literal[ 385 "ADDITION", 386 "BETWEEN", 387 "CONTAINS", 388 "DIVISION", 389 "EQUAL_TO", 390 "GREATER_THAN", 391 "GREATER_THAN_OR_EQUAL_TO", 392 "LESS_THAN", 393 "LESS_THAN_OR_EQUAL_TO", 394 "MASK_ALL", 395 "MASK_FIRST_N", 396 "MASK_LAST_N", 397 "MULTIPLICATION", 398 "NOT_EQUAL_TO", 399 "NO_OP", 400 "PROJECTION", 401 "SUBTRACTION", 402 "VALIDATE_NON_NEGATIVE", 403 "VALIDATE_NON_NULL", 404 "VALIDATE_NON_ZERO", 405 "VALIDATE_NUMERIC", 406 ] 407 ] = Field(default=None, alias="Veeva") 408 zendesk: Optional[ 409 Literal[ 410 "ADDITION", 411 "DIVISION", 412 "GREATER_THAN", 413 "MASK_ALL", 414 "MASK_FIRST_N", 415 "MASK_LAST_N", 416 "MULTIPLICATION", 417 "NO_OP", 418 "PROJECTION", 419 "SUBTRACTION", 420 "VALIDATE_NON_NEGATIVE", 421 "VALIDATE_NON_NULL", 422 "VALIDATE_NON_ZERO", 423 "VALIDATE_NUMERIC", 424 ] 425 ] = Field(default=None, alias="Zendesk") 426 s_ap_odata: Optional[ 427 Literal[ 428 "ADDITION", 429 "BETWEEN", 430 "CONTAINS", 431 "DIVISION", 432 "EQUAL_TO", 433 "GREATER_THAN", 434 "GREATER_THAN_OR_EQUAL_TO", 435 "LESS_THAN", 436 "LESS_THAN_OR_EQUAL_TO", 437 "MASK_ALL", 438 "MASK_FIRST_N", 439 "MASK_LAST_N", 440 "MULTIPLICATION", 441 "NOT_EQUAL_TO", 442 "NO_OP", 443 "PROJECTION", 444 "SUBTRACTION", 445 "VALIDATE_NON_NEGATIVE", 446 "VALIDATE_NON_NULL", 447 "VALIDATE_NON_ZERO", 448 "VALIDATE_NUMERIC", 449 ] 450 ] = Field(default=None, alias="SAPOData") 451 custom_connector: Optional[ 452 Literal[ 453 "ADDITION", 454 "BETWEEN", 455 "CONTAINS", 456 "DIVISION", 457 "EQUAL_TO", 458 "GREATER_THAN", 459 "GREATER_THAN_OR_EQUAL_TO", 460 "LESS_THAN", 461 "LESS_THAN_OR_EQUAL_TO", 462 "MASK_ALL", 463 "MASK_FIRST_N", 464 "MASK_LAST_N", 465 "MULTIPLICATION", 466 "NOT_EQUAL_TO", 467 "NO_OP", 468 "PROJECTION", 469 "SUBTRACTION", 470 "VALIDATE_NON_NEGATIVE", 471 "VALIDATE_NON_NULL", 472 "VALIDATE_NON_ZERO", 473 "VALIDATE_NUMERIC", 474 ] 475 ] = Field(default=None, alias="CustomConnector") 476 pardot: Optional[ 477 Literal[ 478 "ADDITION", 479 "DIVISION", 480 "EQUAL_TO", 481 "MASK_ALL", 482 "MASK_FIRST_N", 483 "MASK_LAST_N", 484 "MULTIPLICATION", 485 "NO_OP", 486 "PROJECTION", 487 "SUBTRACTION", 488 "VALIDATE_NON_NEGATIVE", 489 "VALIDATE_NON_NULL", 490 "VALIDATE_NON_ZERO", 491 "VALIDATE_NUMERIC", 492 ] 493 ] = Field(default=None, alias="Pardot") 494 495 496class DatadogConnectorProfileCredentialsModel(BaseModel): 497 api_key: str = Field(alias="apiKey") 498 application_key: str = Field(alias="applicationKey") 499 500 501class DynatraceConnectorProfileCredentialsModel(BaseModel): 502 api_token: str = Field(alias="apiToken") 503 504 505class InforNexusConnectorProfileCredentialsModel(BaseModel): 506 access_key_id: str = Field(alias="accessKeyId") 507 user_id: str = Field(alias="userId") 508 secret_access_key: str = Field(alias="secretAccessKey") 509 datakey: str = Field(alias="datakey") 510 511 512class RedshiftConnectorProfileCredentialsModel(BaseModel): 513 username: Optional[str] = Field(default=None, alias="username") 514 password: Optional[str] = Field(default=None, alias="password") 515 516 517class ServiceNowConnectorProfileCredentialsModel(BaseModel): 518 username: str = Field(alias="username") 519 password: str = Field(alias="password") 520 521 522class SingularConnectorProfileCredentialsModel(BaseModel): 523 api_key: str = Field(alias="apiKey") 524 525 526class SnowflakeConnectorProfileCredentialsModel(BaseModel): 527 username: str = Field(alias="username") 528 password: str = Field(alias="password") 529 530 531class TrendmicroConnectorProfileCredentialsModel(BaseModel): 532 api_secret_key: str = Field(alias="apiSecretKey") 533 534 535class VeevaConnectorProfileCredentialsModel(BaseModel): 536 username: str = Field(alias="username") 537 password: str = Field(alias="password") 538 539 540class DatadogConnectorProfilePropertiesModel(BaseModel): 541 instance_url: str = Field(alias="instanceUrl") 542 543 544class DynatraceConnectorProfilePropertiesModel(BaseModel): 545 instance_url: str = Field(alias="instanceUrl") 546 547 548class InforNexusConnectorProfilePropertiesModel(BaseModel): 549 instance_url: str = Field(alias="instanceUrl") 550 551 552class MarketoConnectorProfilePropertiesModel(BaseModel): 553 instance_url: str = Field(alias="instanceUrl") 554 555 556class PardotConnectorProfilePropertiesModel(BaseModel): 557 instance_url: Optional[str] = Field(default=None, alias="instanceUrl") 558 is_sandbox_environment: Optional[bool] = Field( 559 default=None, alias="isSandboxEnvironment" 560 ) 561 business_unit_id: Optional[str] = Field(default=None, alias="businessUnitId") 562 563 564class RedshiftConnectorProfilePropertiesModel(BaseModel): 565 bucket_name: str = Field(alias="bucketName") 566 role_arn: str = Field(alias="roleArn") 567 database_url: Optional[str] = Field(default=None, alias="databaseUrl") 568 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 569 data_api_role_arn: Optional[str] = Field(default=None, alias="dataApiRoleArn") 570 is_redshift_serverless: Optional[bool] = Field( 571 default=None, alias="isRedshiftServerless" 572 ) 573 cluster_identifier: Optional[str] = Field(default=None, alias="clusterIdentifier") 574 workgroup_name: Optional[str] = Field(default=None, alias="workgroupName") 575 database_name: Optional[str] = Field(default=None, alias="databaseName") 576 577 578class SalesforceConnectorProfilePropertiesModel(BaseModel): 579 instance_url: Optional[str] = Field(default=None, alias="instanceUrl") 580 is_sandbox_environment: Optional[bool] = Field( 581 default=None, alias="isSandboxEnvironment" 582 ) 583 use_private_link_for_metadata_and_authorization: Optional[bool] = Field( 584 default=None, alias="usePrivateLinkForMetadataAndAuthorization" 585 ) 586 587 588class ServiceNowConnectorProfilePropertiesModel(BaseModel): 589 instance_url: str = Field(alias="instanceUrl") 590 591 592class SlackConnectorProfilePropertiesModel(BaseModel): 593 instance_url: str = Field(alias="instanceUrl") 594 595 596class SnowflakeConnectorProfilePropertiesModel(BaseModel): 597 warehouse: str = Field(alias="warehouse") 598 stage: str = Field(alias="stage") 599 bucket_name: str = Field(alias="bucketName") 600 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 601 private_link_service_name: Optional[str] = Field( 602 default=None, alias="privateLinkServiceName" 603 ) 604 account_name: Optional[str] = Field(default=None, alias="accountName") 605 region: Optional[str] = Field(default=None, alias="region") 606 607 608class VeevaConnectorProfilePropertiesModel(BaseModel): 609 instance_url: str = Field(alias="instanceUrl") 610 611 612class ZendeskConnectorProfilePropertiesModel(BaseModel): 613 instance_url: str = Field(alias="instanceUrl") 614 615 616class PrivateConnectionProvisioningStateModel(BaseModel): 617 status: Optional[Literal["CREATED", "FAILED", "PENDING"]] = Field( 618 default=None, alias="status" 619 ) 620 failure_message: Optional[str] = Field(default=None, alias="failureMessage") 621 failure_cause: Optional[ 622 Literal[ 623 "ACCESS_DENIED", 624 "CONNECTOR_AUTHENTICATION", 625 "CONNECTOR_SERVER", 626 "INTERNAL_SERVER", 627 "VALIDATION", 628 ] 629 ] = Field(default=None, alias="failureCause") 630 631 632class LambdaConnectorProvisioningConfigModel(BaseModel): 633 lambda_arn: str = Field(alias="lambdaArn") 634 635 636class ResponseMetadataModel(BaseModel): 637 request_id: str = Field(alias="RequestId") 638 host_id: str = Field(alias="HostId") 639 http_status_code: int = Field(alias="HTTPStatusCode") 640 http_headers: Dict[str, str] = Field(alias="HTTPHeaders") 641 retry_attempts: int = Field(alias="RetryAttempts") 642 643 644class CustomAuthCredentialsModel(BaseModel): 645 custom_authentication_type: str = Field(alias="customAuthenticationType") 646 credentials_map: Optional[Mapping[str, str]] = Field( 647 default=None, alias="credentialsMap" 648 ) 649 650 651class ErrorHandlingConfigModel(BaseModel): 652 fail_on_first_destination_error: Optional[bool] = Field( 653 default=None, alias="failOnFirstDestinationError" 654 ) 655 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 656 bucket_name: Optional[str] = Field(default=None, alias="bucketName") 657 658 659class OAuth2PropertiesModel(BaseModel): 660 token_url: str = Field(alias="tokenUrl") 661 oauth2_grant_type: Literal["AUTHORIZATION_CODE", "CLIENT_CREDENTIALS"] = Field( 662 alias="oAuth2GrantType" 663 ) 664 token_url_custom_properties: Optional[Mapping[str, str]] = Field( 665 default=None, alias="tokenUrlCustomProperties" 666 ) 667 668 669class CustomConnectorSourcePropertiesModel(BaseModel): 670 entity_name: str = Field(alias="entityName") 671 custom_properties: Optional[Mapping[str, str]] = Field( 672 default=None, alias="customProperties" 673 ) 674 675 676class CustomerProfilesDestinationPropertiesModel(BaseModel): 677 domain_name: str = Field(alias="domainName") 678 object_type_name: Optional[str] = Field(default=None, alias="objectTypeName") 679 680 681class DatadogSourcePropertiesModel(BaseModel): 682 object: str = Field(alias="object") 683 684 685class DeleteConnectorProfileRequestModel(BaseModel): 686 connector_profile_name: str = Field(alias="connectorProfileName") 687 force_delete: Optional[bool] = Field(default=None, alias="forceDelete") 688 689 690class DeleteFlowRequestModel(BaseModel): 691 flow_name: str = Field(alias="flowName") 692 force_delete: Optional[bool] = Field(default=None, alias="forceDelete") 693 694 695class DescribeConnectorEntityRequestModel(BaseModel): 696 connector_entity_name: str = Field(alias="connectorEntityName") 697 connector_type: Optional[ 698 Literal[ 699 "Amplitude", 700 "CustomConnector", 701 "CustomerProfiles", 702 "Datadog", 703 "Dynatrace", 704 "EventBridge", 705 "Googleanalytics", 706 "Honeycode", 707 "Infornexus", 708 "LookoutMetrics", 709 "Marketo", 710 "Pardot", 711 "Redshift", 712 "S3", 713 "SAPOData", 714 "Salesforce", 715 "Servicenow", 716 "Singular", 717 "Slack", 718 "Snowflake", 719 "Trendmicro", 720 "Upsolver", 721 "Veeva", 722 "Zendesk", 723 ] 724 ] = Field(default=None, alias="connectorType") 725 connector_profile_name: Optional[str] = Field( 726 default=None, alias="connectorProfileName" 727 ) 728 api_version: Optional[str] = Field(default=None, alias="apiVersion") 729 730 731class DescribeConnectorProfilesRequestModel(BaseModel): 732 connector_profile_names: Optional[Sequence[str]] = Field( 733 default=None, alias="connectorProfileNames" 734 ) 735 connector_type: Optional[ 736 Literal[ 737 "Amplitude", 738 "CustomConnector", 739 "CustomerProfiles", 740 "Datadog", 741 "Dynatrace", 742 "EventBridge", 743 "Googleanalytics", 744 "Honeycode", 745 "Infornexus", 746 "LookoutMetrics", 747 "Marketo", 748 "Pardot", 749 "Redshift", 750 "S3", 751 "SAPOData", 752 "Salesforce", 753 "Servicenow", 754 "Singular", 755 "Slack", 756 "Snowflake", 757 "Trendmicro", 758 "Upsolver", 759 "Veeva", 760 "Zendesk", 761 ] 762 ] = Field(default=None, alias="connectorType") 763 connector_label: Optional[str] = Field(default=None, alias="connectorLabel") 764 max_results: Optional[int] = Field(default=None, alias="maxResults") 765 next_token: Optional[str] = Field(default=None, alias="nextToken") 766 767 768class DescribeConnectorRequestModel(BaseModel): 769 connector_type: Literal[ 770 "Amplitude", 771 "CustomConnector", 772 "CustomerProfiles", 773 "Datadog", 774 "Dynatrace", 775 "EventBridge", 776 "Googleanalytics", 777 "Honeycode", 778 "Infornexus", 779 "LookoutMetrics", 780 "Marketo", 781 "Pardot", 782 "Redshift", 783 "S3", 784 "SAPOData", 785 "Salesforce", 786 "Servicenow", 787 "Singular", 788 "Slack", 789 "Snowflake", 790 "Trendmicro", 791 "Upsolver", 792 "Veeva", 793 "Zendesk", 794 ] = Field(alias="connectorType") 795 connector_label: Optional[str] = Field(default=None, alias="connectorLabel") 796 797 798class DescribeConnectorsRequestModel(BaseModel): 799 connector_types: Optional[ 800 Sequence[ 801 Literal[ 802 "Amplitude", 803 "CustomConnector", 804 "CustomerProfiles", 805 "Datadog", 806 "Dynatrace", 807 "EventBridge", 808 "Googleanalytics", 809 "Honeycode", 810 "Infornexus", 811 "LookoutMetrics", 812 "Marketo", 813 "Pardot", 814 "Redshift", 815 "S3", 816 "SAPOData", 817 "Salesforce", 818 "Servicenow", 819 "Singular", 820 "Slack", 821 "Snowflake", 822 "Trendmicro", 823 "Upsolver", 824 "Veeva", 825 "Zendesk", 826 ] 827 ] 828 ] = Field(default=None, alias="connectorTypes") 829 max_results: Optional[int] = Field(default=None, alias="maxResults") 830 next_token: Optional[str] = Field(default=None, alias="nextToken") 831 832 833class DescribeFlowExecutionRecordsRequestModel(BaseModel): 834 flow_name: str = Field(alias="flowName") 835 max_results: Optional[int] = Field(default=None, alias="maxResults") 836 next_token: Optional[str] = Field(default=None, alias="nextToken") 837 838 839class DescribeFlowRequestModel(BaseModel): 840 flow_name: str = Field(alias="flowName") 841 842 843class ExecutionDetailsModel(BaseModel): 844 most_recent_execution_message: Optional[str] = Field( 845 default=None, alias="mostRecentExecutionMessage" 846 ) 847 most_recent_execution_time: Optional[datetime] = Field( 848 default=None, alias="mostRecentExecutionTime" 849 ) 850 most_recent_execution_status: Optional[ 851 Literal["Error", "InProgress", "Successful"] 852 ] = Field(default=None, alias="mostRecentExecutionStatus") 853 854 855class DynatraceSourcePropertiesModel(BaseModel): 856 object: str = Field(alias="object") 857 858 859class ErrorInfoModel(BaseModel): 860 put_failures_count: Optional[int] = Field(default=None, alias="putFailuresCount") 861 execution_message: Optional[str] = Field(default=None, alias="executionMessage") 862 863 864class RangeModel(BaseModel): 865 maximum: Optional[float] = Field(default=None, alias="maximum") 866 minimum: Optional[float] = Field(default=None, alias="minimum") 867 868 869class GlueDataCatalogConfigModel(BaseModel): 870 role_arn: str = Field(alias="roleArn") 871 database_name: str = Field(alias="databaseName") 872 table_prefix: str = Field(alias="tablePrefix") 873 874 875class GoogleAnalyticsSourcePropertiesModel(BaseModel): 876 object: str = Field(alias="object") 877 878 879class IncrementalPullConfigModel(BaseModel): 880 datetime_type_field_name: Optional[str] = Field( 881 default=None, alias="datetimeTypeFieldName" 882 ) 883 884 885class InforNexusSourcePropertiesModel(BaseModel): 886 object: str = Field(alias="object") 887 888 889class ListConnectorEntitiesRequestModel(BaseModel): 890 connector_profile_name: Optional[str] = Field( 891 default=None, alias="connectorProfileName" 892 ) 893 connector_type: Optional[ 894 Literal[ 895 "Amplitude", 896 "CustomConnector", 897 "CustomerProfiles", 898 "Datadog", 899 "Dynatrace", 900 "EventBridge", 901 "Googleanalytics", 902 "Honeycode", 903 "Infornexus", 904 "LookoutMetrics", 905 "Marketo", 906 "Pardot", 907 "Redshift", 908 "S3", 909 "SAPOData", 910 "Salesforce", 911 "Servicenow", 912 "Singular", 913 "Slack", 914 "Snowflake", 915 "Trendmicro", 916 "Upsolver", 917 "Veeva", 918 "Zendesk", 919 ] 920 ] = Field(default=None, alias="connectorType") 921 entities_path: Optional[str] = Field(default=None, alias="entitiesPath") 922 api_version: Optional[str] = Field(default=None, alias="apiVersion") 923 max_results: Optional[int] = Field(default=None, alias="maxResults") 924 next_token: Optional[str] = Field(default=None, alias="nextToken") 925 926 927class ListConnectorsRequestModel(BaseModel): 928 max_results: Optional[int] = Field(default=None, alias="maxResults") 929 next_token: Optional[str] = Field(default=None, alias="nextToken") 930 931 932class ListFlowsRequestModel(BaseModel): 933 max_results: Optional[int] = Field(default=None, alias="maxResults") 934 next_token: Optional[str] = Field(default=None, alias="nextToken") 935 936 937class ListTagsForResourceRequestModel(BaseModel): 938 resource_arn: str = Field(alias="resourceArn") 939 940 941class MarketoSourcePropertiesModel(BaseModel): 942 object: str = Field(alias="object") 943 944 945class RegistrationOutputModel(BaseModel): 946 message: Optional[str] = Field(default=None, alias="message") 947 result: Optional[str] = Field(default=None, alias="result") 948 status: Optional[Literal["Error", "InProgress", "Successful"]] = Field( 949 default=None, alias="status" 950 ) 951 952 953class OAuth2CustomParameterModel(BaseModel): 954 key: Optional[str] = Field(default=None, alias="key") 955 is_required: Optional[bool] = Field(default=None, alias="isRequired") 956 label: Optional[str] = Field(default=None, alias="label") 957 description: Optional[str] = Field(default=None, alias="description") 958 is_sensitive_field: Optional[bool] = Field(default=None, alias="isSensitiveField") 959 connector_supplied_values: Optional[List[str]] = Field( 960 default=None, alias="connectorSuppliedValues" 961 ) 962 type: Optional[Literal["AUTH_URL", "TOKEN_URL"]] = Field(default=None, alias="type") 963 964 965class OAuthPropertiesModel(BaseModel): 966 token_url: str = Field(alias="tokenUrl") 967 auth_code_url: str = Field(alias="authCodeUrl") 968 oauth_scopes: Sequence[str] = Field(alias="oAuthScopes") 969 970 971class PardotSourcePropertiesModel(BaseModel): 972 object: str = Field(alias="object") 973 974 975class PrefixConfigModel(BaseModel): 976 prefix_type: Optional[Literal["FILENAME", "PATH", "PATH_AND_FILENAME"]] = Field( 977 default=None, alias="prefixType" 978 ) 979 prefix_format: Optional[Literal["DAY", "HOUR", "MINUTE", "MONTH", "YEAR"]] = Field( 980 default=None, alias="prefixFormat" 981 ) 982 path_prefix_hierarchy: Optional[ 983 Sequence[Literal["EXECUTION_ID", "SCHEMA_VERSION"]] 984 ] = Field(default=None, alias="pathPrefixHierarchy") 985 986 987class S3InputFormatConfigModel(BaseModel): 988 s3_input_file_type: Optional[Literal["CSV", "JSON"]] = Field( 989 default=None, alias="s3InputFileType" 990 ) 991 992 993class SuccessResponseHandlingConfigModel(BaseModel): 994 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 995 bucket_name: Optional[str] = Field(default=None, alias="bucketName") 996 997 998class SAPODataSourcePropertiesModel(BaseModel): 999 object_path: Optional[str] = Field(default=None, alias="objectPath") 1000 1001 1002class SalesforceSourcePropertiesModel(BaseModel): 1003 object: str = Field(alias="object") 1004 enable_dynamic_field_update: Optional[bool] = Field( 1005 default=None, alias="enableDynamicFieldUpdate" 1006 ) 1007 include_deleted_records: Optional[bool] = Field( 1008 default=None, alias="includeDeletedRecords" 1009 ) 1010 data_transfer_api: Optional[Literal["AUTOMATIC", "BULKV2", "REST_SYNC"]] = Field( 1011 default=None, alias="dataTransferApi" 1012 ) 1013 1014 1015class ScheduledTriggerPropertiesModel(BaseModel): 1016 schedule_expression: str = Field(alias="scheduleExpression") 1017 data_pull_mode: Optional[Literal["Complete", "Incremental"]] = Field( 1018 default=None, alias="dataPullMode" 1019 ) 1020 schedule_start_time: Optional[Union[datetime, str]] = Field( 1021 default=None, alias="scheduleStartTime" 1022 ) 1023 schedule_end_time: Optional[Union[datetime, str]] = Field( 1024 default=None, alias="scheduleEndTime" 1025 ) 1026 timezone: Optional[str] = Field(default=None, alias="timezone") 1027 schedule_offset: Optional[int] = Field(default=None, alias="scheduleOffset") 1028 first_execution_from: Optional[Union[datetime, str]] = Field( 1029 default=None, alias="firstExecutionFrom" 1030 ) 1031 flow_error_deactivation_threshold: Optional[int] = Field( 1032 default=None, alias="flowErrorDeactivationThreshold" 1033 ) 1034 1035 1036class ServiceNowSourcePropertiesModel(BaseModel): 1037 object: str = Field(alias="object") 1038 1039 1040class SingularSourcePropertiesModel(BaseModel): 1041 object: str = Field(alias="object") 1042 1043 1044class SlackSourcePropertiesModel(BaseModel): 1045 object: str = Field(alias="object") 1046 1047 1048class TrendmicroSourcePropertiesModel(BaseModel): 1049 object: str = Field(alias="object") 1050 1051 1052class VeevaSourcePropertiesModel(BaseModel): 1053 object: str = Field(alias="object") 1054 document_type: Optional[str] = Field(default=None, alias="documentType") 1055 include_source_files: Optional[bool] = Field( 1056 default=None, alias="includeSourceFiles" 1057 ) 1058 include_renditions: Optional[bool] = Field(default=None, alias="includeRenditions") 1059 include_all_versions: Optional[bool] = Field( 1060 default=None, alias="includeAllVersions" 1061 ) 1062 1063 1064class ZendeskSourcePropertiesModel(BaseModel): 1065 object: str = Field(alias="object") 1066 1067 1068class StartFlowRequestModel(BaseModel): 1069 flow_name: str = Field(alias="flowName") 1070 1071 1072class StopFlowRequestModel(BaseModel): 1073 flow_name: str = Field(alias="flowName") 1074 1075 1076class TagResourceRequestModel(BaseModel): 1077 resource_arn: str = Field(alias="resourceArn") 1078 tags: Mapping[str, str] = Field(alias="tags") 1079 1080 1081class UnregisterConnectorRequestModel(BaseModel): 1082 connector_label: str = Field(alias="connectorLabel") 1083 force_delete: Optional[bool] = Field(default=None, alias="forceDelete") 1084 1085 1086class UntagResourceRequestModel(BaseModel): 1087 resource_arn: str = Field(alias="resourceArn") 1088 tag_keys: Sequence[str] = Field(alias="tagKeys") 1089 1090 1091class CustomAuthConfigModel(BaseModel): 1092 custom_authentication_type: Optional[str] = Field( 1093 default=None, alias="customAuthenticationType" 1094 ) 1095 auth_parameters: Optional[List[AuthParameterModel]] = Field( 1096 default=None, alias="authParameters" 1097 ) 1098 1099 1100class ConnectorMetadataModel(BaseModel): 1101 amplitude: Optional[Dict[str, Any]] = Field(default=None, alias="Amplitude") 1102 datadog: Optional[Dict[str, Any]] = Field(default=None, alias="Datadog") 1103 dynatrace: Optional[Dict[str, Any]] = Field(default=None, alias="Dynatrace") 1104 google_analytics: Optional[GoogleAnalyticsMetadataModel] = Field( 1105 default=None, alias="GoogleAnalytics" 1106 ) 1107 infor_nexus: Optional[Dict[str, Any]] = Field(default=None, alias="InforNexus") 1108 marketo: Optional[Dict[str, Any]] = Field(default=None, alias="Marketo") 1109 redshift: Optional[Dict[str, Any]] = Field(default=None, alias="Redshift") 1110 s3: Optional[Dict[str, Any]] = Field(default=None, alias="S3") 1111 salesforce: Optional[SalesforceMetadataModel] = Field( 1112 default=None, alias="Salesforce" 1113 ) 1114 service_now: Optional[Dict[str, Any]] = Field(default=None, alias="ServiceNow") 1115 singular: Optional[Dict[str, Any]] = Field(default=None, alias="Singular") 1116 slack: Optional[SlackMetadataModel] = Field(default=None, alias="Slack") 1117 snowflake: Optional[SnowflakeMetadataModel] = Field(default=None, alias="Snowflake") 1118 trendmicro: Optional[Dict[str, Any]] = Field(default=None, alias="Trendmicro") 1119 veeva: Optional[Dict[str, Any]] = Field(default=None, alias="Veeva") 1120 zendesk: Optional[ZendeskMetadataModel] = Field(default=None, alias="Zendesk") 1121 event_bridge: Optional[Dict[str, Any]] = Field(default=None, alias="EventBridge") 1122 upsolver: Optional[Dict[str, Any]] = Field(default=None, alias="Upsolver") 1123 customer_profiles: Optional[Dict[str, Any]] = Field( 1124 default=None, alias="CustomerProfiles" 1125 ) 1126 honeycode: Optional[HoneycodeMetadataModel] = Field(default=None, alias="Honeycode") 1127 s_ap_odata: Optional[Dict[str, Any]] = Field(default=None, alias="SAPOData") 1128 pardot: Optional[Dict[str, Any]] = Field(default=None, alias="Pardot") 1129 1130 1131class GoogleAnalyticsConnectorProfileCredentialsModel(BaseModel): 1132 client_id: str = Field(alias="clientId") 1133 client_secret: str = Field(alias="clientSecret") 1134 access_token: Optional[str] = Field(default=None, alias="accessToken") 1135 refresh_token: Optional[str] = Field(default=None, alias="refreshToken") 1136 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1137 default=None, alias="oAuthRequest" 1138 ) 1139 1140 1141class HoneycodeConnectorProfileCredentialsModel(BaseModel): 1142 access_token: Optional[str] = Field(default=None, alias="accessToken") 1143 refresh_token: Optional[str] = Field(default=None, alias="refreshToken") 1144 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1145 default=None, alias="oAuthRequest" 1146 ) 1147 1148 1149class MarketoConnectorProfileCredentialsModel(BaseModel): 1150 client_id: str = Field(alias="clientId") 1151 client_secret: str = Field(alias="clientSecret") 1152 access_token: Optional[str] = Field(default=None, alias="accessToken") 1153 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1154 default=None, alias="oAuthRequest" 1155 ) 1156 1157 1158class OAuth2CredentialsModel(BaseModel): 1159 client_id: Optional[str] = Field(default=None, alias="clientId") 1160 client_secret: Optional[str] = Field(default=None, alias="clientSecret") 1161 access_token: Optional[str] = Field(default=None, alias="accessToken") 1162 refresh_token: Optional[str] = Field(default=None, alias="refreshToken") 1163 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1164 default=None, alias="oAuthRequest" 1165 ) 1166 1167 1168class OAuthCredentialsModel(BaseModel): 1169 client_id: str = Field(alias="clientId") 1170 client_secret: str = Field(alias="clientSecret") 1171 access_token: Optional[str] = Field(default=None, alias="accessToken") 1172 refresh_token: Optional[str] = Field(default=None, alias="refreshToken") 1173 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1174 default=None, alias="oAuthRequest" 1175 ) 1176 1177 1178class PardotConnectorProfileCredentialsModel(BaseModel): 1179 access_token: Optional[str] = Field(default=None, alias="accessToken") 1180 refresh_token: Optional[str] = Field(default=None, alias="refreshToken") 1181 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1182 default=None, alias="oAuthRequest" 1183 ) 1184 client_credentials_arn: Optional[str] = Field( 1185 default=None, alias="clientCredentialsArn" 1186 ) 1187 1188 1189class SalesforceConnectorProfileCredentialsModel(BaseModel): 1190 access_token: Optional[str] = Field(default=None, alias="accessToken") 1191 refresh_token: Optional[str] = Field(default=None, alias="refreshToken") 1192 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1193 default=None, alias="oAuthRequest" 1194 ) 1195 client_credentials_arn: Optional[str] = Field( 1196 default=None, alias="clientCredentialsArn" 1197 ) 1198 1199 1200class SlackConnectorProfileCredentialsModel(BaseModel): 1201 client_id: str = Field(alias="clientId") 1202 client_secret: str = Field(alias="clientSecret") 1203 access_token: Optional[str] = Field(default=None, alias="accessToken") 1204 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1205 default=None, alias="oAuthRequest" 1206 ) 1207 1208 1209class ZendeskConnectorProfileCredentialsModel(BaseModel): 1210 client_id: str = Field(alias="clientId") 1211 client_secret: str = Field(alias="clientSecret") 1212 access_token: Optional[str] = Field(default=None, alias="accessToken") 1213 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1214 default=None, alias="oAuthRequest" 1215 ) 1216 1217 1218class TaskModel(BaseModel): 1219 source_fields: Sequence[str] = Field(alias="sourceFields") 1220 task_type: Literal[ 1221 "Arithmetic", 1222 "Filter", 1223 "Map", 1224 "Map_all", 1225 "Mask", 1226 "Merge", 1227 "Partition", 1228 "Passthrough", 1229 "Truncate", 1230 "Validate", 1231 ] = Field(alias="taskType") 1232 connector_operator: Optional[ConnectorOperatorModel] = Field( 1233 default=None, alias="connectorOperator" 1234 ) 1235 destination_field: Optional[str] = Field(default=None, alias="destinationField") 1236 task_properties: Optional[ 1237 Mapping[ 1238 Literal[ 1239 "CONCAT_FORMAT", 1240 "DATA_TYPE", 1241 "DESTINATION_DATA_TYPE", 1242 "EXCLUDE_SOURCE_FIELDS_LIST", 1243 "INCLUDE_NEW_FIELDS", 1244 "LOWER_BOUND", 1245 "MASK_LENGTH", 1246 "MASK_VALUE", 1247 "MATH_OPERATION_FIELDS_ORDER", 1248 "ORDERED_PARTITION_KEYS_LIST", 1249 "SOURCE_DATA_TYPE", 1250 "SUBFIELD_CATEGORY_MAP", 1251 "TRUNCATE_LENGTH", 1252 "UPPER_BOUND", 1253 "VALIDATION_ACTION", 1254 "VALUE", 1255 "VALUES", 1256 ], 1257 str, 1258 ] 1259 ] = Field(default=None, alias="taskProperties") 1260 1261 1262class ConnectorProvisioningConfigModel(BaseModel): 1263 lambda_: Optional[LambdaConnectorProvisioningConfigModel] = Field( 1264 default=None, alias="lambda" 1265 ) 1266 1267 1268class CreateConnectorProfileResponseModel(BaseModel): 1269 connector_profile_arn: str = Field(alias="connectorProfileArn") 1270 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 1271 1272 1273class CreateFlowResponseModel(BaseModel): 1274 flow_arn: str = Field(alias="flowArn") 1275 flow_status: Literal[ 1276 "Active", "Deleted", "Deprecated", "Draft", "Errored", "Suspended" 1277 ] = Field(alias="flowStatus") 1278 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 1279 1280 1281class ListConnectorEntitiesResponseModel(BaseModel): 1282 connector_entity_map: Dict[str, List[ConnectorEntityModel]] = Field( 1283 alias="connectorEntityMap" 1284 ) 1285 next_token: str = Field(alias="nextToken") 1286 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 1287 1288 1289class ListConnectorsResponseModel(BaseModel): 1290 connectors: List[ConnectorDetailModel] = Field(alias="connectors") 1291 next_token: str = Field(alias="nextToken") 1292 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 1293 1294 1295class ListTagsForResourceResponseModel(BaseModel): 1296 tags: Dict[str, str] = Field(alias="tags") 1297 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 1298 1299 1300class RegisterConnectorResponseModel(BaseModel): 1301 connector_arn: str = Field(alias="connectorArn") 1302 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 1303 1304 1305class StartFlowResponseModel(BaseModel): 1306 flow_arn: str = Field(alias="flowArn") 1307 flow_status: Literal[ 1308 "Active", "Deleted", "Deprecated", "Draft", "Errored", "Suspended" 1309 ] = Field(alias="flowStatus") 1310 execution_id: str = Field(alias="executionId") 1311 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 1312 1313 1314class StopFlowResponseModel(BaseModel): 1315 flow_arn: str = Field(alias="flowArn") 1316 flow_status: Literal[ 1317 "Active", "Deleted", "Deprecated", "Draft", "Errored", "Suspended" 1318 ] = Field(alias="flowStatus") 1319 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 1320 1321 1322class UpdateConnectorProfileResponseModel(BaseModel): 1323 connector_profile_arn: str = Field(alias="connectorProfileArn") 1324 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 1325 1326 1327class UpdateConnectorRegistrationResponseModel(BaseModel): 1328 connector_arn: str = Field(alias="connectorArn") 1329 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 1330 1331 1332class UpdateFlowResponseModel(BaseModel): 1333 flow_status: Literal[ 1334 "Active", "Deleted", "Deprecated", "Draft", "Errored", "Suspended" 1335 ] = Field(alias="flowStatus") 1336 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 1337 1338 1339class CustomConnectorDestinationPropertiesModel(BaseModel): 1340 entity_name: str = Field(alias="entityName") 1341 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1342 default=None, alias="errorHandlingConfig" 1343 ) 1344 write_operation_type: Optional[ 1345 Literal["DELETE", "INSERT", "UPDATE", "UPSERT"] 1346 ] = Field(default=None, alias="writeOperationType") 1347 id_field_names: Optional[Sequence[str]] = Field(default=None, alias="idFieldNames") 1348 custom_properties: Optional[Mapping[str, str]] = Field( 1349 default=None, alias="customProperties" 1350 ) 1351 1352 1353class EventBridgeDestinationPropertiesModel(BaseModel): 1354 object: str = Field(alias="object") 1355 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1356 default=None, alias="errorHandlingConfig" 1357 ) 1358 1359 1360class HoneycodeDestinationPropertiesModel(BaseModel): 1361 object: str = Field(alias="object") 1362 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1363 default=None, alias="errorHandlingConfig" 1364 ) 1365 1366 1367class MarketoDestinationPropertiesModel(BaseModel): 1368 object: str = Field(alias="object") 1369 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1370 default=None, alias="errorHandlingConfig" 1371 ) 1372 1373 1374class RedshiftDestinationPropertiesModel(BaseModel): 1375 object: str = Field(alias="object") 1376 intermediate_bucket_name: str = Field(alias="intermediateBucketName") 1377 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 1378 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1379 default=None, alias="errorHandlingConfig" 1380 ) 1381 1382 1383class SalesforceDestinationPropertiesModel(BaseModel): 1384 object: str = Field(alias="object") 1385 id_field_names: Optional[Sequence[str]] = Field(default=None, alias="idFieldNames") 1386 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1387 default=None, alias="errorHandlingConfig" 1388 ) 1389 write_operation_type: Optional[ 1390 Literal["DELETE", "INSERT", "UPDATE", "UPSERT"] 1391 ] = Field(default=None, alias="writeOperationType") 1392 data_transfer_api: Optional[Literal["AUTOMATIC", "BULKV2", "REST_SYNC"]] = Field( 1393 default=None, alias="dataTransferApi" 1394 ) 1395 1396 1397class SnowflakeDestinationPropertiesModel(BaseModel): 1398 object: str = Field(alias="object") 1399 intermediate_bucket_name: str = Field(alias="intermediateBucketName") 1400 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 1401 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1402 default=None, alias="errorHandlingConfig" 1403 ) 1404 1405 1406class ZendeskDestinationPropertiesModel(BaseModel): 1407 object: str = Field(alias="object") 1408 id_field_names: Optional[Sequence[str]] = Field(default=None, alias="idFieldNames") 1409 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1410 default=None, alias="errorHandlingConfig" 1411 ) 1412 write_operation_type: Optional[ 1413 Literal["DELETE", "INSERT", "UPDATE", "UPSERT"] 1414 ] = Field(default=None, alias="writeOperationType") 1415 1416 1417class CustomConnectorProfilePropertiesModel(BaseModel): 1418 profile_properties: Optional[Mapping[str, str]] = Field( 1419 default=None, alias="profileProperties" 1420 ) 1421 oauth2_properties: Optional[OAuth2PropertiesModel] = Field( 1422 default=None, alias="oAuth2Properties" 1423 ) 1424 1425 1426class FlowDefinitionModel(BaseModel): 1427 flow_arn: Optional[str] = Field(default=None, alias="flowArn") 1428 description: Optional[str] = Field(default=None, alias="description") 1429 flow_name: Optional[str] = Field(default=None, alias="flowName") 1430 flow_status: Optional[ 1431 Literal["Active", "Deleted", "Deprecated", "Draft", "Errored", "Suspended"] 1432 ] = Field(default=None, alias="flowStatus") 1433 source_connector_type: Optional[ 1434 Literal[ 1435 "Amplitude", 1436 "CustomConnector", 1437 "CustomerProfiles", 1438 "Datadog", 1439 "Dynatrace", 1440 "EventBridge", 1441 "Googleanalytics", 1442 "Honeycode", 1443 "Infornexus", 1444 "LookoutMetrics", 1445 "Marketo", 1446 "Pardot", 1447 "Redshift", 1448 "S3", 1449 "SAPOData", 1450 "Salesforce", 1451 "Servicenow", 1452 "Singular", 1453 "Slack", 1454 "Snowflake", 1455 "Trendmicro", 1456 "Upsolver", 1457 "Veeva", 1458 "Zendesk", 1459 ] 1460 ] = Field(default=None, alias="sourceConnectorType") 1461 source_connector_label: Optional[str] = Field( 1462 default=None, alias="sourceConnectorLabel" 1463 ) 1464 destination_connector_type: Optional[ 1465 Literal[ 1466 "Amplitude", 1467 "CustomConnector", 1468 "CustomerProfiles", 1469 "Datadog", 1470 "Dynatrace", 1471 "EventBridge", 1472 "Googleanalytics", 1473 "Honeycode", 1474 "Infornexus", 1475 "LookoutMetrics", 1476 "Marketo", 1477 "Pardot", 1478 "Redshift", 1479 "S3", 1480 "SAPOData", 1481 "Salesforce", 1482 "Servicenow", 1483 "Singular", 1484 "Slack", 1485 "Snowflake", 1486 "Trendmicro", 1487 "Upsolver", 1488 "Veeva", 1489 "Zendesk", 1490 ] 1491 ] = Field(default=None, alias="destinationConnectorType") 1492 destination_connector_label: Optional[str] = Field( 1493 default=None, alias="destinationConnectorLabel" 1494 ) 1495 trigger_type: Optional[Literal["Event", "OnDemand", "Scheduled"]] = Field( 1496 default=None, alias="triggerType" 1497 ) 1498 created_at: Optional[datetime] = Field(default=None, alias="createdAt") 1499 last_updated_at: Optional[datetime] = Field(default=None, alias="lastUpdatedAt") 1500 created_by: Optional[str] = Field(default=None, alias="createdBy") 1501 last_updated_by: Optional[str] = Field(default=None, alias="lastUpdatedBy") 1502 tags: Optional[Dict[str, str]] = Field(default=None, alias="tags") 1503 last_run_execution_details: Optional[ExecutionDetailsModel] = Field( 1504 default=None, alias="lastRunExecutionDetails" 1505 ) 1506 1507 1508class ExecutionResultModel(BaseModel): 1509 error_info: Optional[ErrorInfoModel] = Field(default=None, alias="errorInfo") 1510 bytes_processed: Optional[int] = Field(default=None, alias="bytesProcessed") 1511 bytes_written: Optional[int] = Field(default=None, alias="bytesWritten") 1512 records_processed: Optional[int] = Field(default=None, alias="recordsProcessed") 1513 1514 1515class FieldTypeDetailsModel(BaseModel): 1516 field_type: str = Field(alias="fieldType") 1517 filter_operators: List[ 1518 Literal[ 1519 "ADDITION", 1520 "BETWEEN", 1521 "CONTAINS", 1522 "DIVISION", 1523 "EQUAL_TO", 1524 "GREATER_THAN", 1525 "GREATER_THAN_OR_EQUAL_TO", 1526 "LESS_THAN", 1527 "LESS_THAN_OR_EQUAL_TO", 1528 "MASK_ALL", 1529 "MASK_FIRST_N", 1530 "MASK_LAST_N", 1531 "MULTIPLICATION", 1532 "NOT_EQUAL_TO", 1533 "NO_OP", 1534 "PROJECTION", 1535 "SUBTRACTION", 1536 "VALIDATE_NON_NEGATIVE", 1537 "VALIDATE_NON_NULL", 1538 "VALIDATE_NON_ZERO", 1539 "VALIDATE_NUMERIC", 1540 ] 1541 ] = Field(alias="filterOperators") 1542 supported_values: Optional[List[str]] = Field(default=None, alias="supportedValues") 1543 value_regex_pattern: Optional[str] = Field(default=None, alias="valueRegexPattern") 1544 supported_date_format: Optional[str] = Field( 1545 default=None, alias="supportedDateFormat" 1546 ) 1547 field_value_range: Optional[RangeModel] = Field( 1548 default=None, alias="fieldValueRange" 1549 ) 1550 field_length_range: Optional[RangeModel] = Field( 1551 default=None, alias="fieldLengthRange" 1552 ) 1553 1554 1555class MetadataCatalogConfigModel(BaseModel): 1556 glue_data_catalog: Optional[GlueDataCatalogConfigModel] = Field( 1557 default=None, alias="glueDataCatalog" 1558 ) 1559 1560 1561class MetadataCatalogDetailModel(BaseModel): 1562 catalog_type: Optional[Literal["GLUE"]] = Field(default=None, alias="catalogType") 1563 table_name: Optional[str] = Field(default=None, alias="tableName") 1564 table_registration_output: Optional[RegistrationOutputModel] = Field( 1565 default=None, alias="tableRegistrationOutput" 1566 ) 1567 partition_registration_output: Optional[RegistrationOutputModel] = Field( 1568 default=None, alias="partitionRegistrationOutput" 1569 ) 1570 1571 1572class OAuth2DefaultsModel(BaseModel): 1573 oauth_scopes: Optional[List[str]] = Field(default=None, alias="oauthScopes") 1574 token_urls: Optional[List[str]] = Field(default=None, alias="tokenUrls") 1575 auth_code_urls: Optional[List[str]] = Field(default=None, alias="authCodeUrls") 1576 oauth2_grant_types_supported: Optional[ 1577 List[Literal["AUTHORIZATION_CODE", "CLIENT_CREDENTIALS"]] 1578 ] = Field(default=None, alias="oauth2GrantTypesSupported") 1579 oauth2_custom_properties: Optional[List[OAuth2CustomParameterModel]] = Field( 1580 default=None, alias="oauth2CustomProperties" 1581 ) 1582 1583 1584class SAPODataConnectorProfilePropertiesModel(BaseModel): 1585 application_host_url: str = Field(alias="applicationHostUrl") 1586 application_service_path: str = Field(alias="applicationServicePath") 1587 port_number: int = Field(alias="portNumber") 1588 client_number: str = Field(alias="clientNumber") 1589 logon_language: Optional[str] = Field(default=None, alias="logonLanguage") 1590 private_link_service_name: Optional[str] = Field( 1591 default=None, alias="privateLinkServiceName" 1592 ) 1593 oauth_properties: Optional[OAuthPropertiesModel] = Field( 1594 default=None, alias="oAuthProperties" 1595 ) 1596 1597 1598class S3OutputFormatConfigModel(BaseModel): 1599 file_type: Optional[Literal["CSV", "JSON", "PARQUET"]] = Field( 1600 default=None, alias="fileType" 1601 ) 1602 prefix_config: Optional[PrefixConfigModel] = Field( 1603 default=None, alias="prefixConfig" 1604 ) 1605 aggregation_config: Optional[AggregationConfigModel] = Field( 1606 default=None, alias="aggregationConfig" 1607 ) 1608 preserve_source_data_typing: Optional[bool] = Field( 1609 default=None, alias="preserveSourceDataTyping" 1610 ) 1611 1612 1613class UpsolverS3OutputFormatConfigModel(BaseModel): 1614 prefix_config: PrefixConfigModel = Field(alias="prefixConfig") 1615 file_type: Optional[Literal["CSV", "JSON", "PARQUET"]] = Field( 1616 default=None, alias="fileType" 1617 ) 1618 aggregation_config: Optional[AggregationConfigModel] = Field( 1619 default=None, alias="aggregationConfig" 1620 ) 1621 1622 1623class S3SourcePropertiesModel(BaseModel): 1624 bucket_name: str = Field(alias="bucketName") 1625 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 1626 s3_input_format_config: Optional[S3InputFormatConfigModel] = Field( 1627 default=None, alias="s3InputFormatConfig" 1628 ) 1629 1630 1631class SAPODataDestinationPropertiesModel(BaseModel): 1632 object_path: str = Field(alias="objectPath") 1633 success_response_handling_config: Optional[ 1634 SuccessResponseHandlingConfigModel 1635 ] = Field(default=None, alias="successResponseHandlingConfig") 1636 id_field_names: Optional[Sequence[str]] = Field(default=None, alias="idFieldNames") 1637 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1638 default=None, alias="errorHandlingConfig" 1639 ) 1640 write_operation_type: Optional[ 1641 Literal["DELETE", "INSERT", "UPDATE", "UPSERT"] 1642 ] = Field(default=None, alias="writeOperationType") 1643 1644 1645class TriggerPropertiesModel(BaseModel): 1646 scheduled: Optional[ScheduledTriggerPropertiesModel] = Field( 1647 default=None, alias="Scheduled" 1648 ) 1649 1650 1651class CustomConnectorProfileCredentialsModel(BaseModel): 1652 authentication_type: Literal["APIKEY", "BASIC", "CUSTOM", "OAUTH2"] = Field( 1653 alias="authenticationType" 1654 ) 1655 basic: Optional[BasicAuthCredentialsModel] = Field(default=None, alias="basic") 1656 oauth2: Optional[OAuth2CredentialsModel] = Field(default=None, alias="oauth2") 1657 api_key: Optional[ApiKeyCredentialsModel] = Field(default=None, alias="apiKey") 1658 custom: Optional[CustomAuthCredentialsModel] = Field(default=None, alias="custom") 1659 1660 1661class SAPODataConnectorProfileCredentialsModel(BaseModel): 1662 basic_auth_credentials: Optional[BasicAuthCredentialsModel] = Field( 1663 default=None, alias="basicAuthCredentials" 1664 ) 1665 oauth_credentials: Optional[OAuthCredentialsModel] = Field( 1666 default=None, alias="oAuthCredentials" 1667 ) 1668 1669 1670class RegisterConnectorRequestModel(BaseModel): 1671 connector_label: Optional[str] = Field(default=None, alias="connectorLabel") 1672 description: Optional[str] = Field(default=None, alias="description") 1673 connector_provisioning_type: Optional[Literal["LAMBDA"]] = Field( 1674 default=None, alias="connectorProvisioningType" 1675 ) 1676 connector_provisioning_config: Optional[ConnectorProvisioningConfigModel] = Field( 1677 default=None, alias="connectorProvisioningConfig" 1678 ) 1679 1680 1681class UpdateConnectorRegistrationRequestModel(BaseModel): 1682 connector_label: str = Field(alias="connectorLabel") 1683 description: Optional[str] = Field(default=None, alias="description") 1684 connector_provisioning_config: Optional[ConnectorProvisioningConfigModel] = Field( 1685 default=None, alias="connectorProvisioningConfig" 1686 ) 1687 1688 1689class ListFlowsResponseModel(BaseModel): 1690 flows: List[FlowDefinitionModel] = Field(alias="flows") 1691 next_token: str = Field(alias="nextToken") 1692 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 1693 1694 1695class SupportedFieldTypeDetailsModel(BaseModel): 1696 v1: FieldTypeDetailsModel = Field(alias="v1") 1697 1698 1699class ExecutionRecordModel(BaseModel): 1700 execution_id: Optional[str] = Field(default=None, alias="executionId") 1701 execution_status: Optional[Literal["Error", "InProgress", "Successful"]] = Field( 1702 default=None, alias="executionStatus" 1703 ) 1704 execution_result: Optional[ExecutionResultModel] = Field( 1705 default=None, alias="executionResult" 1706 ) 1707 started_at: Optional[datetime] = Field(default=None, alias="startedAt") 1708 last_updated_at: Optional[datetime] = Field(default=None, alias="lastUpdatedAt") 1709 data_pull_start_time: Optional[datetime] = Field( 1710 default=None, alias="dataPullStartTime" 1711 ) 1712 data_pull_end_time: Optional[datetime] = Field( 1713 default=None, alias="dataPullEndTime" 1714 ) 1715 metadata_catalog_details: Optional[List[MetadataCatalogDetailModel]] = Field( 1716 default=None, alias="metadataCatalogDetails" 1717 ) 1718 1719 1720class AuthenticationConfigModel(BaseModel): 1721 is_basic_auth_supported: Optional[bool] = Field( 1722 default=None, alias="isBasicAuthSupported" 1723 ) 1724 is_api_key_auth_supported: Optional[bool] = Field( 1725 default=None, alias="isApiKeyAuthSupported" 1726 ) 1727 is_oauth2_supported: Optional[bool] = Field(default=None, alias="isOAuth2Supported") 1728 is_custom_auth_supported: Optional[bool] = Field( 1729 default=None, alias="isCustomAuthSupported" 1730 ) 1731 oauth2_defaults: Optional[OAuth2DefaultsModel] = Field( 1732 default=None, alias="oAuth2Defaults" 1733 ) 1734 custom_auth_configs: Optional[List[CustomAuthConfigModel]] = Field( 1735 default=None, alias="customAuthConfigs" 1736 ) 1737 1738 1739class ConnectorProfilePropertiesModel(BaseModel): 1740 amplitude: Optional[Mapping[str, Any]] = Field(default=None, alias="Amplitude") 1741 datadog: Optional[DatadogConnectorProfilePropertiesModel] = Field( 1742 default=None, alias="Datadog" 1743 ) 1744 dynatrace: Optional[DynatraceConnectorProfilePropertiesModel] = Field( 1745 default=None, alias="Dynatrace" 1746 ) 1747 google_analytics: Optional[Mapping[str, Any]] = Field( 1748 default=None, alias="GoogleAnalytics" 1749 ) 1750 honeycode: Optional[Mapping[str, Any]] = Field(default=None, alias="Honeycode") 1751 infor_nexus: Optional[InforNexusConnectorProfilePropertiesModel] = Field( 1752 default=None, alias="InforNexus" 1753 ) 1754 marketo: Optional[MarketoConnectorProfilePropertiesModel] = Field( 1755 default=None, alias="Marketo" 1756 ) 1757 redshift: Optional[RedshiftConnectorProfilePropertiesModel] = Field( 1758 default=None, alias="Redshift" 1759 ) 1760 salesforce: Optional[SalesforceConnectorProfilePropertiesModel] = Field( 1761 default=None, alias="Salesforce" 1762 ) 1763 service_now: Optional[ServiceNowConnectorProfilePropertiesModel] = Field( 1764 default=None, alias="ServiceNow" 1765 ) 1766 singular: Optional[Mapping[str, Any]] = Field(default=None, alias="Singular") 1767 slack: Optional[SlackConnectorProfilePropertiesModel] = Field( 1768 default=None, alias="Slack" 1769 ) 1770 snowflake: Optional[SnowflakeConnectorProfilePropertiesModel] = Field( 1771 default=None, alias="Snowflake" 1772 ) 1773 trendmicro: Optional[Mapping[str, Any]] = Field(default=None, alias="Trendmicro") 1774 veeva: Optional[VeevaConnectorProfilePropertiesModel] = Field( 1775 default=None, alias="Veeva" 1776 ) 1777 zendesk: Optional[ZendeskConnectorProfilePropertiesModel] = Field( 1778 default=None, alias="Zendesk" 1779 ) 1780 s_ap_odata: Optional[SAPODataConnectorProfilePropertiesModel] = Field( 1781 default=None, alias="SAPOData" 1782 ) 1783 custom_connector: Optional[CustomConnectorProfilePropertiesModel] = Field( 1784 default=None, alias="CustomConnector" 1785 ) 1786 pardot: Optional[PardotConnectorProfilePropertiesModel] = Field( 1787 default=None, alias="Pardot" 1788 ) 1789 1790 1791class S3DestinationPropertiesModel(BaseModel): 1792 bucket_name: str = Field(alias="bucketName") 1793 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 1794 s3_output_format_config: Optional[S3OutputFormatConfigModel] = Field( 1795 default=None, alias="s3OutputFormatConfig" 1796 ) 1797 1798 1799class UpsolverDestinationPropertiesModel(BaseModel): 1800 bucket_name: str = Field(alias="bucketName") 1801 s3_output_format_config: UpsolverS3OutputFormatConfigModel = Field( 1802 alias="s3OutputFormatConfig" 1803 ) 1804 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 1805 1806 1807class SourceConnectorPropertiesModel(BaseModel): 1808 amplitude: Optional[AmplitudeSourcePropertiesModel] = Field( 1809 default=None, alias="Amplitude" 1810 ) 1811 datadog: Optional[DatadogSourcePropertiesModel] = Field( 1812 default=None, alias="Datadog" 1813 ) 1814 dynatrace: Optional[DynatraceSourcePropertiesModel] = Field( 1815 default=None, alias="Dynatrace" 1816 ) 1817 google_analytics: Optional[GoogleAnalyticsSourcePropertiesModel] = Field( 1818 default=None, alias="GoogleAnalytics" 1819 ) 1820 infor_nexus: Optional[InforNexusSourcePropertiesModel] = Field( 1821 default=None, alias="InforNexus" 1822 ) 1823 marketo: Optional[MarketoSourcePropertiesModel] = Field( 1824 default=None, alias="Marketo" 1825 ) 1826 s3: Optional[S3SourcePropertiesModel] = Field(default=None, alias="S3") 1827 salesforce: Optional[SalesforceSourcePropertiesModel] = Field( 1828 default=None, alias="Salesforce" 1829 ) 1830 service_now: Optional[ServiceNowSourcePropertiesModel] = Field( 1831 default=None, alias="ServiceNow" 1832 ) 1833 singular: Optional[SingularSourcePropertiesModel] = Field( 1834 default=None, alias="Singular" 1835 ) 1836 slack: Optional[SlackSourcePropertiesModel] = Field(default=None, alias="Slack") 1837 trendmicro: Optional[TrendmicroSourcePropertiesModel] = Field( 1838 default=None, alias="Trendmicro" 1839 ) 1840 veeva: Optional[VeevaSourcePropertiesModel] = Field(default=None, alias="Veeva") 1841 zendesk: Optional[ZendeskSourcePropertiesModel] = Field( 1842 default=None, alias="Zendesk" 1843 ) 1844 s_ap_odata: Optional[SAPODataSourcePropertiesModel] = Field( 1845 default=None, alias="SAPOData" 1846 ) 1847 custom_connector: Optional[CustomConnectorSourcePropertiesModel] = Field( 1848 default=None, alias="CustomConnector" 1849 ) 1850 pardot: Optional[PardotSourcePropertiesModel] = Field(default=None, alias="Pardot") 1851 1852 1853class TriggerConfigModel(BaseModel): 1854 trigger_type: Literal["Event", "OnDemand", "Scheduled"] = Field(alias="triggerType") 1855 trigger_properties: Optional[TriggerPropertiesModel] = Field( 1856 default=None, alias="triggerProperties" 1857 ) 1858 1859 1860class ConnectorProfileCredentialsModel(BaseModel): 1861 amplitude: Optional[AmplitudeConnectorProfileCredentialsModel] = Field( 1862 default=None, alias="Amplitude" 1863 ) 1864 datadog: Optional[DatadogConnectorProfileCredentialsModel] = Field( 1865 default=None, alias="Datadog" 1866 ) 1867 dynatrace: Optional[DynatraceConnectorProfileCredentialsModel] = Field( 1868 default=None, alias="Dynatrace" 1869 ) 1870 google_analytics: Optional[GoogleAnalyticsConnectorProfileCredentialsModel] = Field( 1871 default=None, alias="GoogleAnalytics" 1872 ) 1873 honeycode: Optional[HoneycodeConnectorProfileCredentialsModel] = Field( 1874 default=None, alias="Honeycode" 1875 ) 1876 infor_nexus: Optional[InforNexusConnectorProfileCredentialsModel] = Field( 1877 default=None, alias="InforNexus" 1878 ) 1879 marketo: Optional[MarketoConnectorProfileCredentialsModel] = Field( 1880 default=None, alias="Marketo" 1881 ) 1882 redshift: Optional[RedshiftConnectorProfileCredentialsModel] = Field( 1883 default=None, alias="Redshift" 1884 ) 1885 salesforce: Optional[SalesforceConnectorProfileCredentialsModel] = Field( 1886 default=None, alias="Salesforce" 1887 ) 1888 service_now: Optional[ServiceNowConnectorProfileCredentialsModel] = Field( 1889 default=None, alias="ServiceNow" 1890 ) 1891 singular: Optional[SingularConnectorProfileCredentialsModel] = Field( 1892 default=None, alias="Singular" 1893 ) 1894 slack: Optional[SlackConnectorProfileCredentialsModel] = Field( 1895 default=None, alias="Slack" 1896 ) 1897 snowflake: Optional[SnowflakeConnectorProfileCredentialsModel] = Field( 1898 default=None, alias="Snowflake" 1899 ) 1900 trendmicro: Optional[TrendmicroConnectorProfileCredentialsModel] = Field( 1901 default=None, alias="Trendmicro" 1902 ) 1903 veeva: Optional[VeevaConnectorProfileCredentialsModel] = Field( 1904 default=None, alias="Veeva" 1905 ) 1906 zendesk: Optional[ZendeskConnectorProfileCredentialsModel] = Field( 1907 default=None, alias="Zendesk" 1908 ) 1909 s_ap_odata: Optional[SAPODataConnectorProfileCredentialsModel] = Field( 1910 default=None, alias="SAPOData" 1911 ) 1912 custom_connector: Optional[CustomConnectorProfileCredentialsModel] = Field( 1913 default=None, alias="CustomConnector" 1914 ) 1915 pardot: Optional[PardotConnectorProfileCredentialsModel] = Field( 1916 default=None, alias="Pardot" 1917 ) 1918 1919 1920class ConnectorEntityFieldModel(BaseModel): 1921 identifier: str = Field(alias="identifier") 1922 parent_identifier: Optional[str] = Field(default=None, alias="parentIdentifier") 1923 label: Optional[str] = Field(default=None, alias="label") 1924 is_primary_key: Optional[bool] = Field(default=None, alias="isPrimaryKey") 1925 default_value: Optional[str] = Field(default=None, alias="defaultValue") 1926 is_deprecated: Optional[bool] = Field(default=None, alias="isDeprecated") 1927 supported_field_type_details: Optional[SupportedFieldTypeDetailsModel] = Field( 1928 default=None, alias="supportedFieldTypeDetails" 1929 ) 1930 description: Optional[str] = Field(default=None, alias="description") 1931 source_properties: Optional[SourceFieldPropertiesModel] = Field( 1932 default=None, alias="sourceProperties" 1933 ) 1934 destination_properties: Optional[DestinationFieldPropertiesModel] = Field( 1935 default=None, alias="destinationProperties" 1936 ) 1937 custom_properties: Optional[Dict[str, str]] = Field( 1938 default=None, alias="customProperties" 1939 ) 1940 1941 1942class DescribeFlowExecutionRecordsResponseModel(BaseModel): 1943 flow_executions: List[ExecutionRecordModel] = Field(alias="flowExecutions") 1944 next_token: str = Field(alias="nextToken") 1945 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 1946 1947 1948class ConnectorConfigurationModel(BaseModel): 1949 can_use_as_source: Optional[bool] = Field(default=None, alias="canUseAsSource") 1950 can_use_as_destination: Optional[bool] = Field( 1951 default=None, alias="canUseAsDestination" 1952 ) 1953 supported_destination_connectors: Optional[ 1954 List[ 1955 Literal[ 1956 "Amplitude", 1957 "CustomConnector", 1958 "CustomerProfiles", 1959 "Datadog", 1960 "Dynatrace", 1961 "EventBridge", 1962 "Googleanalytics", 1963 "Honeycode", 1964 "Infornexus", 1965 "LookoutMetrics", 1966 "Marketo", 1967 "Pardot", 1968 "Redshift", 1969 "S3", 1970 "SAPOData", 1971 "Salesforce", 1972 "Servicenow", 1973 "Singular", 1974 "Slack", 1975 "Snowflake", 1976 "Trendmicro", 1977 "Upsolver", 1978 "Veeva", 1979 "Zendesk", 1980 ] 1981 ] 1982 ] = Field(default=None, alias="supportedDestinationConnectors") 1983 supported_scheduling_frequencies: Optional[ 1984 List[Literal["BYMINUTE", "DAILY", "HOURLY", "MONTHLY", "ONCE", "WEEKLY"]] 1985 ] = Field(default=None, alias="supportedSchedulingFrequencies") 1986 is_private_link_enabled: Optional[bool] = Field( 1987 default=None, alias="isPrivateLinkEnabled" 1988 ) 1989 is_private_link_endpoint_url_required: Optional[bool] = Field( 1990 default=None, alias="isPrivateLinkEndpointUrlRequired" 1991 ) 1992 supported_trigger_types: Optional[ 1993 List[Literal["Event", "OnDemand", "Scheduled"]] 1994 ] = Field(default=None, alias="supportedTriggerTypes") 1995 connector_metadata: Optional[ConnectorMetadataModel] = Field( 1996 default=None, alias="connectorMetadata" 1997 ) 1998 connector_type: Optional[ 1999 Literal[ 2000 "Amplitude", 2001 "CustomConnector", 2002 "CustomerProfiles", 2003 "Datadog", 2004 "Dynatrace", 2005 "EventBridge", 2006 "Googleanalytics", 2007 "Honeycode", 2008 "Infornexus", 2009 "LookoutMetrics", 2010 "Marketo", 2011 "Pardot", 2012 "Redshift", 2013 "S3", 2014 "SAPOData", 2015 "Salesforce", 2016 "Servicenow", 2017 "Singular", 2018 "Slack", 2019 "Snowflake", 2020 "Trendmicro", 2021 "Upsolver", 2022 "Veeva", 2023 "Zendesk", 2024 ] 2025 ] = Field(default=None, alias="connectorType") 2026 connector_label: Optional[str] = Field(default=None, alias="connectorLabel") 2027 connector_description: Optional[str] = Field( 2028 default=None, alias="connectorDescription" 2029 ) 2030 connector_owner: Optional[str] = Field(default=None, alias="connectorOwner") 2031 connector_name: Optional[str] = Field(default=None, alias="connectorName") 2032 connector_version: Optional[str] = Field(default=None, alias="connectorVersion") 2033 connector_arn: Optional[str] = Field(default=None, alias="connectorArn") 2034 connector_modes: Optional[List[str]] = Field(default=None, alias="connectorModes") 2035 authentication_config: Optional[AuthenticationConfigModel] = Field( 2036 default=None, alias="authenticationConfig" 2037 ) 2038 connector_runtime_settings: Optional[List[ConnectorRuntimeSettingModel]] = Field( 2039 default=None, alias="connectorRuntimeSettings" 2040 ) 2041 supported_api_versions: Optional[List[str]] = Field( 2042 default=None, alias="supportedApiVersions" 2043 ) 2044 supported_operators: Optional[ 2045 List[ 2046 Literal[ 2047 "ADDITION", 2048 "BETWEEN", 2049 "CONTAINS", 2050 "DIVISION", 2051 "EQUAL_TO", 2052 "GREATER_THAN", 2053 "GREATER_THAN_OR_EQUAL_TO", 2054 "LESS_THAN", 2055 "LESS_THAN_OR_EQUAL_TO", 2056 "MASK_ALL", 2057 "MASK_FIRST_N", 2058 "MASK_LAST_N", 2059 "MULTIPLICATION", 2060 "NOT_EQUAL_TO", 2061 "NO_OP", 2062 "PROJECTION", 2063 "SUBTRACTION", 2064 "VALIDATE_NON_NEGATIVE", 2065 "VALIDATE_NON_NULL", 2066 "VALIDATE_NON_ZERO", 2067 "VALIDATE_NUMERIC", 2068 ] 2069 ] 2070 ] = Field(default=None, alias="supportedOperators") 2071 supported_write_operations: Optional[ 2072 List[Literal["DELETE", "INSERT", "UPDATE", "UPSERT"]] 2073 ] = Field(default=None, alias="supportedWriteOperations") 2074 connector_provisioning_type: Optional[Literal["LAMBDA"]] = Field( 2075 default=None, alias="connectorProvisioningType" 2076 ) 2077 connector_provisioning_config: Optional[ConnectorProvisioningConfigModel] = Field( 2078 default=None, alias="connectorProvisioningConfig" 2079 ) 2080 logo_url: Optional[str] = Field(default=None, alias="logoURL") 2081 registered_at: Optional[datetime] = Field(default=None, alias="registeredAt") 2082 registered_by: Optional[str] = Field(default=None, alias="registeredBy") 2083 2084 2085class ConnectorProfileModel(BaseModel): 2086 connector_profile_arn: Optional[str] = Field( 2087 default=None, alias="connectorProfileArn" 2088 ) 2089 connector_profile_name: Optional[str] = Field( 2090 default=None, alias="connectorProfileName" 2091 ) 2092 connector_type: Optional[ 2093 Literal[ 2094 "Amplitude", 2095 "CustomConnector", 2096 "CustomerProfiles", 2097 "Datadog", 2098 "Dynatrace", 2099 "EventBridge", 2100 "Googleanalytics", 2101 "Honeycode", 2102 "Infornexus", 2103 "LookoutMetrics", 2104 "Marketo", 2105 "Pardot", 2106 "Redshift", 2107 "S3", 2108 "SAPOData", 2109 "Salesforce", 2110 "Servicenow", 2111 "Singular", 2112 "Slack", 2113 "Snowflake", 2114 "Trendmicro", 2115 "Upsolver", 2116 "Veeva", 2117 "Zendesk", 2118 ] 2119 ] = Field(default=None, alias="connectorType") 2120 connector_label: Optional[str] = Field(default=None, alias="connectorLabel") 2121 connection_mode: Optional[Literal["Private", "Public"]] = Field( 2122 default=None, alias="connectionMode" 2123 ) 2124 credentials_arn: Optional[str] = Field(default=None, alias="credentialsArn") 2125 connector_profile_properties: Optional[ConnectorProfilePropertiesModel] = Field( 2126 default=None, alias="connectorProfileProperties" 2127 ) 2128 created_at: Optional[datetime] = Field(default=None, alias="createdAt") 2129 last_updated_at: Optional[datetime] = Field(default=None, alias="lastUpdatedAt") 2130 private_connection_provisioning_state: Optional[ 2131 PrivateConnectionProvisioningStateModel 2132 ] = Field(default=None, alias="privateConnectionProvisioningState") 2133 2134 2135class DestinationConnectorPropertiesModel(BaseModel): 2136 redshift: Optional[RedshiftDestinationPropertiesModel] = Field( 2137 default=None, alias="Redshift" 2138 ) 2139 s3: Optional[S3DestinationPropertiesModel] = Field(default=None, alias="S3") 2140 salesforce: Optional[SalesforceDestinationPropertiesModel] = Field( 2141 default=None, alias="Salesforce" 2142 ) 2143 snowflake: Optional[SnowflakeDestinationPropertiesModel] = Field( 2144 default=None, alias="Snowflake" 2145 ) 2146 event_bridge: Optional[EventBridgeDestinationPropertiesModel] = Field( 2147 default=None, alias="EventBridge" 2148 ) 2149 lookout_metrics: Optional[Mapping[str, Any]] = Field( 2150 default=None, alias="LookoutMetrics" 2151 ) 2152 upsolver: Optional[UpsolverDestinationPropertiesModel] = Field( 2153 default=None, alias="Upsolver" 2154 ) 2155 honeycode: Optional[HoneycodeDestinationPropertiesModel] = Field( 2156 default=None, alias="Honeycode" 2157 ) 2158 customer_profiles: Optional[CustomerProfilesDestinationPropertiesModel] = Field( 2159 default=None, alias="CustomerProfiles" 2160 ) 2161 zendesk: Optional[ZendeskDestinationPropertiesModel] = Field( 2162 default=None, alias="Zendesk" 2163 ) 2164 marketo: Optional[MarketoDestinationPropertiesModel] = Field( 2165 default=None, alias="Marketo" 2166 ) 2167 custom_connector: Optional[CustomConnectorDestinationPropertiesModel] = Field( 2168 default=None, alias="CustomConnector" 2169 ) 2170 s_ap_odata: Optional[SAPODataDestinationPropertiesModel] = Field( 2171 default=None, alias="SAPOData" 2172 ) 2173 2174 2175class SourceFlowConfigModel(BaseModel): 2176 connector_type: Literal[ 2177 "Amplitude", 2178 "CustomConnector", 2179 "CustomerProfiles", 2180 "Datadog", 2181 "Dynatrace", 2182 "EventBridge", 2183 "Googleanalytics", 2184 "Honeycode", 2185 "Infornexus", 2186 "LookoutMetrics", 2187 "Marketo", 2188 "Pardot", 2189 "Redshift", 2190 "S3", 2191 "SAPOData", 2192 "Salesforce", 2193 "Servicenow", 2194 "Singular", 2195 "Slack", 2196 "Snowflake", 2197 "Trendmicro", 2198 "Upsolver", 2199 "Veeva", 2200 "Zendesk", 2201 ] = Field(alias="connectorType") 2202 source_connector_properties: SourceConnectorPropertiesModel = Field( 2203 alias="sourceConnectorProperties" 2204 ) 2205 api_version: Optional[str] = Field(default=None, alias="apiVersion") 2206 connector_profile_name: Optional[str] = Field( 2207 default=None, alias="connectorProfileName" 2208 ) 2209 incremental_pull_config: Optional[IncrementalPullConfigModel] = Field( 2210 default=None, alias="incrementalPullConfig" 2211 ) 2212 2213 2214class ConnectorProfileConfigModel(BaseModel): 2215 connector_profile_properties: ConnectorProfilePropertiesModel = Field( 2216 alias="connectorProfileProperties" 2217 ) 2218 connector_profile_credentials: Optional[ConnectorProfileCredentialsModel] = Field( 2219 default=None, alias="connectorProfileCredentials" 2220 ) 2221 2222 2223class DescribeConnectorEntityResponseModel(BaseModel): 2224 connector_entity_fields: List[ConnectorEntityFieldModel] = Field( 2225 alias="connectorEntityFields" 2226 ) 2227 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 2228 2229 2230class DescribeConnectorResponseModel(BaseModel): 2231 connector_configuration: ConnectorConfigurationModel = Field( 2232 alias="connectorConfiguration" 2233 ) 2234 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 2235 2236 2237class DescribeConnectorsResponseModel(BaseModel): 2238 connector_configurations: Dict[ 2239 Literal[ 2240 "Amplitude", 2241 "CustomConnector", 2242 "CustomerProfiles", 2243 "Datadog", 2244 "Dynatrace", 2245 "EventBridge", 2246 "Googleanalytics", 2247 "Honeycode", 2248 "Infornexus", 2249 "LookoutMetrics", 2250 "Marketo", 2251 "Pardot", 2252 "Redshift", 2253 "S3", 2254 "SAPOData", 2255 "Salesforce", 2256 "Servicenow", 2257 "Singular", 2258 "Slack", 2259 "Snowflake", 2260 "Trendmicro", 2261 "Upsolver", 2262 "Veeva", 2263 "Zendesk", 2264 ], 2265 ConnectorConfigurationModel, 2266 ] = Field(alias="connectorConfigurations") 2267 connectors: List[ConnectorDetailModel] = Field(alias="connectors") 2268 next_token: str = Field(alias="nextToken") 2269 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 2270 2271 2272class DescribeConnectorProfilesResponseModel(BaseModel): 2273 connector_profile_details: List[ConnectorProfileModel] = Field( 2274 alias="connectorProfileDetails" 2275 ) 2276 next_token: str = Field(alias="nextToken") 2277 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 2278 2279 2280class DestinationFlowConfigModel(BaseModel): 2281 connector_type: Literal[ 2282 "Amplitude", 2283 "CustomConnector", 2284 "CustomerProfiles", 2285 "Datadog", 2286 "Dynatrace", 2287 "EventBridge", 2288 "Googleanalytics", 2289 "Honeycode", 2290 "Infornexus", 2291 "LookoutMetrics", 2292 "Marketo", 2293 "Pardot", 2294 "Redshift", 2295 "S3", 2296 "SAPOData", 2297 "Salesforce", 2298 "Servicenow", 2299 "Singular", 2300 "Slack", 2301 "Snowflake", 2302 "Trendmicro", 2303 "Upsolver", 2304 "Veeva", 2305 "Zendesk", 2306 ] = Field(alias="connectorType") 2307 destination_connector_properties: DestinationConnectorPropertiesModel = Field( 2308 alias="destinationConnectorProperties" 2309 ) 2310 api_version: Optional[str] = Field(default=None, alias="apiVersion") 2311 connector_profile_name: Optional[str] = Field( 2312 default=None, alias="connectorProfileName" 2313 ) 2314 2315 2316class CreateConnectorProfileRequestModel(BaseModel): 2317 connector_profile_name: str = Field(alias="connectorProfileName") 2318 connector_type: Literal[ 2319 "Amplitude", 2320 "CustomConnector", 2321 "CustomerProfiles", 2322 "Datadog", 2323 "Dynatrace", 2324 "EventBridge", 2325 "Googleanalytics", 2326 "Honeycode", 2327 "Infornexus", 2328 "LookoutMetrics", 2329 "Marketo", 2330 "Pardot", 2331 "Redshift", 2332 "S3", 2333 "SAPOData", 2334 "Salesforce", 2335 "Servicenow", 2336 "Singular", 2337 "Slack", 2338 "Snowflake", 2339 "Trendmicro", 2340 "Upsolver", 2341 "Veeva", 2342 "Zendesk", 2343 ] = Field(alias="connectorType") 2344 connection_mode: Literal["Private", "Public"] = Field(alias="connectionMode") 2345 connector_profile_config: ConnectorProfileConfigModel = Field( 2346 alias="connectorProfileConfig" 2347 ) 2348 kms_arn: Optional[str] = Field(default=None, alias="kmsArn") 2349 connector_label: Optional[str] = Field(default=None, alias="connectorLabel") 2350 2351 2352class UpdateConnectorProfileRequestModel(BaseModel): 2353 connector_profile_name: str = Field(alias="connectorProfileName") 2354 connection_mode: Literal["Private", "Public"] = Field(alias="connectionMode") 2355 connector_profile_config: ConnectorProfileConfigModel = Field( 2356 alias="connectorProfileConfig" 2357 ) 2358 2359 2360class CreateFlowRequestModel(BaseModel): 2361 flow_name: str = Field(alias="flowName") 2362 trigger_config: TriggerConfigModel = Field(alias="triggerConfig") 2363 source_flow_config: SourceFlowConfigModel = Field(alias="sourceFlowConfig") 2364 destination_flow_config_list: Sequence[DestinationFlowConfigModel] = Field( 2365 alias="destinationFlowConfigList" 2366 ) 2367 tasks: Sequence[TaskModel] = Field(alias="tasks") 2368 description: Optional[str] = Field(default=None, alias="description") 2369 kms_arn: Optional[str] = Field(default=None, alias="kmsArn") 2370 tags: Optional[Mapping[str, str]] = Field(default=None, alias="tags") 2371 metadata_catalog_config: Optional[MetadataCatalogConfigModel] = Field( 2372 default=None, alias="metadataCatalogConfig" 2373 ) 2374 2375 2376class DescribeFlowResponseModel(BaseModel): 2377 flow_arn: str = Field(alias="flowArn") 2378 description: str = Field(alias="description") 2379 flow_name: str = Field(alias="flowName") 2380 kms_arn: str = Field(alias="kmsArn") 2381 flow_status: Literal[ 2382 "Active", "Deleted", "Deprecated", "Draft", "Errored", "Suspended" 2383 ] = Field(alias="flowStatus") 2384 flow_status_message: str = Field(alias="flowStatusMessage") 2385 source_flow_config: SourceFlowConfigModel = Field(alias="sourceFlowConfig") 2386 destination_flow_config_list: List[DestinationFlowConfigModel] = Field( 2387 alias="destinationFlowConfigList" 2388 ) 2389 last_run_execution_details: ExecutionDetailsModel = Field( 2390 alias="lastRunExecutionDetails" 2391 ) 2392 trigger_config: TriggerConfigModel = Field(alias="triggerConfig") 2393 tasks: List[TaskModel] = Field(alias="tasks") 2394 created_at: datetime = Field(alias="createdAt") 2395 last_updated_at: datetime = Field(alias="lastUpdatedAt") 2396 created_by: str = Field(alias="createdBy") 2397 last_updated_by: str = Field(alias="lastUpdatedBy") 2398 tags: Dict[str, str] = Field(alias="tags") 2399 metadata_catalog_config: MetadataCatalogConfigModel = Field( 2400 alias="metadataCatalogConfig" 2401 ) 2402 last_run_metadata_catalog_details: List[MetadataCatalogDetailModel] = Field( 2403 alias="lastRunMetadataCatalogDetails" 2404 ) 2405 schema_version: int = Field(alias="schemaVersion") 2406 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata") 2407 2408 2409class UpdateFlowRequestModel(BaseModel): 2410 flow_name: str = Field(alias="flowName") 2411 trigger_config: TriggerConfigModel = Field(alias="triggerConfig") 2412 source_flow_config: SourceFlowConfigModel = Field(alias="sourceFlowConfig") 2413 destination_flow_config_list: Sequence[DestinationFlowConfigModel] = Field( 2414 alias="destinationFlowConfigList" 2415 ) 2416 tasks: Sequence[TaskModel] = Field(alias="tasks") 2417 description: Optional[str] = Field(default=None, alias="description") 2418 metadata_catalog_config: Optional[MetadataCatalogConfigModel] = Field( 2419 default=None, alias="metadataCatalogConfig" 2420 )
14class AggregationConfigModel(BaseModel): 15 aggregation_type: Optional[Literal["None", "SingleFile"]] = Field( 16 default=None, alias="aggregationType" 17 ) 18 target_file_size: Optional[int] = Field(default=None, alias="targetFileSize")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
21class AmplitudeConnectorProfileCredentialsModel(BaseModel): 22 api_key: str = Field(alias="apiKey") 23 secret_key: str = Field(alias="secretKey")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
30class ApiKeyCredentialsModel(BaseModel): 31 api_key: str = Field(alias="apiKey") 32 api_secret_key: Optional[str] = Field(default=None, alias="apiSecretKey")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
35class AuthParameterModel(BaseModel): 36 key: Optional[str] = Field(default=None, alias="key") 37 is_required: Optional[bool] = Field(default=None, alias="isRequired") 38 label: Optional[str] = Field(default=None, alias="label") 39 description: Optional[str] = Field(default=None, alias="description") 40 is_sensitive_field: Optional[bool] = Field(default=None, alias="isSensitiveField") 41 connector_supplied_values: Optional[List[str]] = Field( 42 default=None, alias="connectorSuppliedValues" 43 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
46class BasicAuthCredentialsModel(BaseModel): 47 username: str = Field(alias="username") 48 password: str = Field(alias="password")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
51class ConnectorRuntimeSettingModel(BaseModel): 52 key: Optional[str] = Field(default=None, alias="key") 53 data_type: Optional[str] = Field(default=None, alias="dataType") 54 is_required: Optional[bool] = Field(default=None, alias="isRequired") 55 label: Optional[str] = Field(default=None, alias="label") 56 description: Optional[str] = Field(default=None, alias="description") 57 scope: Optional[str] = Field(default=None, alias="scope") 58 connector_supplied_value_options: Optional[List[str]] = Field( 59 default=None, alias="connectorSuppliedValueOptions" 60 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
63class ConnectorDetailModel(BaseModel): 64 connector_description: Optional[str] = Field( 65 default=None, alias="connectorDescription" 66 ) 67 connector_name: Optional[str] = Field(default=None, alias="connectorName") 68 connector_owner: Optional[str] = Field(default=None, alias="connectorOwner") 69 connector_version: Optional[str] = Field(default=None, alias="connectorVersion") 70 application_type: Optional[str] = Field(default=None, alias="applicationType") 71 connector_type: Optional[ 72 Literal[ 73 "Amplitude", 74 "CustomConnector", 75 "CustomerProfiles", 76 "Datadog", 77 "Dynatrace", 78 "EventBridge", 79 "Googleanalytics", 80 "Honeycode", 81 "Infornexus", 82 "LookoutMetrics", 83 "Marketo", 84 "Pardot", 85 "Redshift", 86 "S3", 87 "SAPOData", 88 "Salesforce", 89 "Servicenow", 90 "Singular", 91 "Slack", 92 "Snowflake", 93 "Trendmicro", 94 "Upsolver", 95 "Veeva", 96 "Zendesk", 97 ] 98 ] = Field(default=None, alias="connectorType") 99 connector_label: Optional[str] = Field(default=None, alias="connectorLabel") 100 registered_at: Optional[datetime] = Field(default=None, alias="registeredAt") 101 registered_by: Optional[str] = Field(default=None, alias="registeredBy") 102 connector_provisioning_type: Optional[Literal["LAMBDA"]] = Field( 103 default=None, alias="connectorProvisioningType" 104 ) 105 connector_modes: Optional[List[str]] = Field(default=None, alias="connectorModes")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
108class DestinationFieldPropertiesModel(BaseModel): 109 is_creatable: Optional[bool] = Field(default=None, alias="isCreatable") 110 is_nullable: Optional[bool] = Field(default=None, alias="isNullable") 111 is_upsertable: Optional[bool] = Field(default=None, alias="isUpsertable") 112 is_updatable: Optional[bool] = Field(default=None, alias="isUpdatable") 113 is_defaulted_on_create: Optional[bool] = Field( 114 default=None, alias="isDefaultedOnCreate" 115 ) 116 supported_write_operations: Optional[ 117 List[Literal["DELETE", "INSERT", "UPDATE", "UPSERT"]] 118 ] = Field(default=None, alias="supportedWriteOperations")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
121class SourceFieldPropertiesModel(BaseModel): 122 is_retrievable: Optional[bool] = Field(default=None, alias="isRetrievable") 123 is_queryable: Optional[bool] = Field(default=None, alias="isQueryable") 124 is_timestamp_field_for_incremental_queries: Optional[bool] = Field( 125 default=None, alias="isTimestampFieldForIncrementalQueries" 126 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
129class ConnectorEntityModel(BaseModel): 130 name: str = Field(alias="name") 131 label: Optional[str] = Field(default=None, alias="label") 132 has_nested_entities: Optional[bool] = Field(default=None, alias="hasNestedEntities")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
135class GoogleAnalyticsMetadataModel(BaseModel): 136 oauth_scopes: Optional[List[str]] = Field(default=None, alias="oAuthScopes")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
139class HoneycodeMetadataModel(BaseModel): 140 oauth_scopes: Optional[List[str]] = Field(default=None, alias="oAuthScopes")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
143class SalesforceMetadataModel(BaseModel): 144 oauth_scopes: Optional[List[str]] = Field(default=None, alias="oAuthScopes") 145 data_transfer_apis: Optional[ 146 List[Literal["AUTOMATIC", "BULKV2", "REST_SYNC"]] 147 ] = Field(default=None, alias="dataTransferApis")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
150class SlackMetadataModel(BaseModel): 151 oauth_scopes: Optional[List[str]] = Field(default=None, alias="oAuthScopes")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
154class SnowflakeMetadataModel(BaseModel): 155 supported_regions: Optional[List[str]] = Field( 156 default=None, alias="supportedRegions" 157 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
160class ZendeskMetadataModel(BaseModel): 161 oauth_scopes: Optional[List[str]] = Field(default=None, alias="oAuthScopes")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
164class ConnectorOAuthRequestModel(BaseModel): 165 auth_code: Optional[str] = Field(default=None, alias="authCode") 166 redirect_uri: Optional[str] = Field(default=None, alias="redirectUri")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
169class ConnectorOperatorModel(BaseModel): 170 amplitude: Optional[Literal["BETWEEN"]] = Field(default=None, alias="Amplitude") 171 datadog: Optional[ 172 Literal[ 173 "ADDITION", 174 "BETWEEN", 175 "DIVISION", 176 "EQUAL_TO", 177 "MASK_ALL", 178 "MASK_FIRST_N", 179 "MASK_LAST_N", 180 "MULTIPLICATION", 181 "NO_OP", 182 "PROJECTION", 183 "SUBTRACTION", 184 "VALIDATE_NON_NEGATIVE", 185 "VALIDATE_NON_NULL", 186 "VALIDATE_NON_ZERO", 187 "VALIDATE_NUMERIC", 188 ] 189 ] = Field(default=None, alias="Datadog") 190 dynatrace: Optional[ 191 Literal[ 192 "ADDITION", 193 "BETWEEN", 194 "DIVISION", 195 "EQUAL_TO", 196 "MASK_ALL", 197 "MASK_FIRST_N", 198 "MASK_LAST_N", 199 "MULTIPLICATION", 200 "NO_OP", 201 "PROJECTION", 202 "SUBTRACTION", 203 "VALIDATE_NON_NEGATIVE", 204 "VALIDATE_NON_NULL", 205 "VALIDATE_NON_ZERO", 206 "VALIDATE_NUMERIC", 207 ] 208 ] = Field(default=None, alias="Dynatrace") 209 google_analytics: Optional[Literal["BETWEEN", "PROJECTION"]] = Field( 210 default=None, alias="GoogleAnalytics" 211 ) 212 infor_nexus: Optional[ 213 Literal[ 214 "ADDITION", 215 "BETWEEN", 216 "DIVISION", 217 "EQUAL_TO", 218 "MASK_ALL", 219 "MASK_FIRST_N", 220 "MASK_LAST_N", 221 "MULTIPLICATION", 222 "NO_OP", 223 "PROJECTION", 224 "SUBTRACTION", 225 "VALIDATE_NON_NEGATIVE", 226 "VALIDATE_NON_NULL", 227 "VALIDATE_NON_ZERO", 228 "VALIDATE_NUMERIC", 229 ] 230 ] = Field(default=None, alias="InforNexus") 231 marketo: Optional[ 232 Literal[ 233 "ADDITION", 234 "BETWEEN", 235 "DIVISION", 236 "GREATER_THAN", 237 "LESS_THAN", 238 "MASK_ALL", 239 "MASK_FIRST_N", 240 "MASK_LAST_N", 241 "MULTIPLICATION", 242 "NO_OP", 243 "PROJECTION", 244 "SUBTRACTION", 245 "VALIDATE_NON_NEGATIVE", 246 "VALIDATE_NON_NULL", 247 "VALIDATE_NON_ZERO", 248 "VALIDATE_NUMERIC", 249 ] 250 ] = Field(default=None, alias="Marketo") 251 s3: Optional[ 252 Literal[ 253 "ADDITION", 254 "BETWEEN", 255 "DIVISION", 256 "EQUAL_TO", 257 "GREATER_THAN", 258 "GREATER_THAN_OR_EQUAL_TO", 259 "LESS_THAN", 260 "LESS_THAN_OR_EQUAL_TO", 261 "MASK_ALL", 262 "MASK_FIRST_N", 263 "MASK_LAST_N", 264 "MULTIPLICATION", 265 "NOT_EQUAL_TO", 266 "NO_OP", 267 "PROJECTION", 268 "SUBTRACTION", 269 "VALIDATE_NON_NEGATIVE", 270 "VALIDATE_NON_NULL", 271 "VALIDATE_NON_ZERO", 272 "VALIDATE_NUMERIC", 273 ] 274 ] = Field(default=None, alias="S3") 275 salesforce: Optional[ 276 Literal[ 277 "ADDITION", 278 "BETWEEN", 279 "CONTAINS", 280 "DIVISION", 281 "EQUAL_TO", 282 "GREATER_THAN", 283 "GREATER_THAN_OR_EQUAL_TO", 284 "LESS_THAN", 285 "LESS_THAN_OR_EQUAL_TO", 286 "MASK_ALL", 287 "MASK_FIRST_N", 288 "MASK_LAST_N", 289 "MULTIPLICATION", 290 "NOT_EQUAL_TO", 291 "NO_OP", 292 "PROJECTION", 293 "SUBTRACTION", 294 "VALIDATE_NON_NEGATIVE", 295 "VALIDATE_NON_NULL", 296 "VALIDATE_NON_ZERO", 297 "VALIDATE_NUMERIC", 298 ] 299 ] = Field(default=None, alias="Salesforce") 300 service_now: Optional[ 301 Literal[ 302 "ADDITION", 303 "BETWEEN", 304 "CONTAINS", 305 "DIVISION", 306 "EQUAL_TO", 307 "GREATER_THAN", 308 "GREATER_THAN_OR_EQUAL_TO", 309 "LESS_THAN", 310 "LESS_THAN_OR_EQUAL_TO", 311 "MASK_ALL", 312 "MASK_FIRST_N", 313 "MASK_LAST_N", 314 "MULTIPLICATION", 315 "NOT_EQUAL_TO", 316 "NO_OP", 317 "PROJECTION", 318 "SUBTRACTION", 319 "VALIDATE_NON_NEGATIVE", 320 "VALIDATE_NON_NULL", 321 "VALIDATE_NON_ZERO", 322 "VALIDATE_NUMERIC", 323 ] 324 ] = Field(default=None, alias="ServiceNow") 325 singular: Optional[ 326 Literal[ 327 "ADDITION", 328 "DIVISION", 329 "EQUAL_TO", 330 "MASK_ALL", 331 "MASK_FIRST_N", 332 "MASK_LAST_N", 333 "MULTIPLICATION", 334 "NO_OP", 335 "PROJECTION", 336 "SUBTRACTION", 337 "VALIDATE_NON_NEGATIVE", 338 "VALIDATE_NON_NULL", 339 "VALIDATE_NON_ZERO", 340 "VALIDATE_NUMERIC", 341 ] 342 ] = Field(default=None, alias="Singular") 343 slack: Optional[ 344 Literal[ 345 "ADDITION", 346 "BETWEEN", 347 "DIVISION", 348 "EQUAL_TO", 349 "GREATER_THAN", 350 "GREATER_THAN_OR_EQUAL_TO", 351 "LESS_THAN", 352 "LESS_THAN_OR_EQUAL_TO", 353 "MASK_ALL", 354 "MASK_FIRST_N", 355 "MASK_LAST_N", 356 "MULTIPLICATION", 357 "NO_OP", 358 "PROJECTION", 359 "SUBTRACTION", 360 "VALIDATE_NON_NEGATIVE", 361 "VALIDATE_NON_NULL", 362 "VALIDATE_NON_ZERO", 363 "VALIDATE_NUMERIC", 364 ] 365 ] = Field(default=None, alias="Slack") 366 trendmicro: Optional[ 367 Literal[ 368 "ADDITION", 369 "DIVISION", 370 "EQUAL_TO", 371 "MASK_ALL", 372 "MASK_FIRST_N", 373 "MASK_LAST_N", 374 "MULTIPLICATION", 375 "NO_OP", 376 "PROJECTION", 377 "SUBTRACTION", 378 "VALIDATE_NON_NEGATIVE", 379 "VALIDATE_NON_NULL", 380 "VALIDATE_NON_ZERO", 381 "VALIDATE_NUMERIC", 382 ] 383 ] = Field(default=None, alias="Trendmicro") 384 veeva: Optional[ 385 Literal[ 386 "ADDITION", 387 "BETWEEN", 388 "CONTAINS", 389 "DIVISION", 390 "EQUAL_TO", 391 "GREATER_THAN", 392 "GREATER_THAN_OR_EQUAL_TO", 393 "LESS_THAN", 394 "LESS_THAN_OR_EQUAL_TO", 395 "MASK_ALL", 396 "MASK_FIRST_N", 397 "MASK_LAST_N", 398 "MULTIPLICATION", 399 "NOT_EQUAL_TO", 400 "NO_OP", 401 "PROJECTION", 402 "SUBTRACTION", 403 "VALIDATE_NON_NEGATIVE", 404 "VALIDATE_NON_NULL", 405 "VALIDATE_NON_ZERO", 406 "VALIDATE_NUMERIC", 407 ] 408 ] = Field(default=None, alias="Veeva") 409 zendesk: Optional[ 410 Literal[ 411 "ADDITION", 412 "DIVISION", 413 "GREATER_THAN", 414 "MASK_ALL", 415 "MASK_FIRST_N", 416 "MASK_LAST_N", 417 "MULTIPLICATION", 418 "NO_OP", 419 "PROJECTION", 420 "SUBTRACTION", 421 "VALIDATE_NON_NEGATIVE", 422 "VALIDATE_NON_NULL", 423 "VALIDATE_NON_ZERO", 424 "VALIDATE_NUMERIC", 425 ] 426 ] = Field(default=None, alias="Zendesk") 427 s_ap_odata: Optional[ 428 Literal[ 429 "ADDITION", 430 "BETWEEN", 431 "CONTAINS", 432 "DIVISION", 433 "EQUAL_TO", 434 "GREATER_THAN", 435 "GREATER_THAN_OR_EQUAL_TO", 436 "LESS_THAN", 437 "LESS_THAN_OR_EQUAL_TO", 438 "MASK_ALL", 439 "MASK_FIRST_N", 440 "MASK_LAST_N", 441 "MULTIPLICATION", 442 "NOT_EQUAL_TO", 443 "NO_OP", 444 "PROJECTION", 445 "SUBTRACTION", 446 "VALIDATE_NON_NEGATIVE", 447 "VALIDATE_NON_NULL", 448 "VALIDATE_NON_ZERO", 449 "VALIDATE_NUMERIC", 450 ] 451 ] = Field(default=None, alias="SAPOData") 452 custom_connector: Optional[ 453 Literal[ 454 "ADDITION", 455 "BETWEEN", 456 "CONTAINS", 457 "DIVISION", 458 "EQUAL_TO", 459 "GREATER_THAN", 460 "GREATER_THAN_OR_EQUAL_TO", 461 "LESS_THAN", 462 "LESS_THAN_OR_EQUAL_TO", 463 "MASK_ALL", 464 "MASK_FIRST_N", 465 "MASK_LAST_N", 466 "MULTIPLICATION", 467 "NOT_EQUAL_TO", 468 "NO_OP", 469 "PROJECTION", 470 "SUBTRACTION", 471 "VALIDATE_NON_NEGATIVE", 472 "VALIDATE_NON_NULL", 473 "VALIDATE_NON_ZERO", 474 "VALIDATE_NUMERIC", 475 ] 476 ] = Field(default=None, alias="CustomConnector") 477 pardot: Optional[ 478 Literal[ 479 "ADDITION", 480 "DIVISION", 481 "EQUAL_TO", 482 "MASK_ALL", 483 "MASK_FIRST_N", 484 "MASK_LAST_N", 485 "MULTIPLICATION", 486 "NO_OP", 487 "PROJECTION", 488 "SUBTRACTION", 489 "VALIDATE_NON_NEGATIVE", 490 "VALIDATE_NON_NULL", 491 "VALIDATE_NON_ZERO", 492 "VALIDATE_NUMERIC", 493 ] 494 ] = Field(default=None, alias="Pardot")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
497class DatadogConnectorProfileCredentialsModel(BaseModel): 498 api_key: str = Field(alias="apiKey") 499 application_key: str = Field(alias="applicationKey")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
502class DynatraceConnectorProfileCredentialsModel(BaseModel): 503 api_token: str = Field(alias="apiToken")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
506class InforNexusConnectorProfileCredentialsModel(BaseModel): 507 access_key_id: str = Field(alias="accessKeyId") 508 user_id: str = Field(alias="userId") 509 secret_access_key: str = Field(alias="secretAccessKey") 510 datakey: str = Field(alias="datakey")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
513class RedshiftConnectorProfileCredentialsModel(BaseModel): 514 username: Optional[str] = Field(default=None, alias="username") 515 password: Optional[str] = Field(default=None, alias="password")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
518class ServiceNowConnectorProfileCredentialsModel(BaseModel): 519 username: str = Field(alias="username") 520 password: str = Field(alias="password")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
523class SingularConnectorProfileCredentialsModel(BaseModel): 524 api_key: str = Field(alias="apiKey")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
527class SnowflakeConnectorProfileCredentialsModel(BaseModel): 528 username: str = Field(alias="username") 529 password: str = Field(alias="password")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
532class TrendmicroConnectorProfileCredentialsModel(BaseModel): 533 api_secret_key: str = Field(alias="apiSecretKey")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
536class VeevaConnectorProfileCredentialsModel(BaseModel): 537 username: str = Field(alias="username") 538 password: str = Field(alias="password")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
541class DatadogConnectorProfilePropertiesModel(BaseModel): 542 instance_url: str = Field(alias="instanceUrl")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
545class DynatraceConnectorProfilePropertiesModel(BaseModel): 546 instance_url: str = Field(alias="instanceUrl")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
549class InforNexusConnectorProfilePropertiesModel(BaseModel): 550 instance_url: str = Field(alias="instanceUrl")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
553class MarketoConnectorProfilePropertiesModel(BaseModel): 554 instance_url: str = Field(alias="instanceUrl")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
557class PardotConnectorProfilePropertiesModel(BaseModel): 558 instance_url: Optional[str] = Field(default=None, alias="instanceUrl") 559 is_sandbox_environment: Optional[bool] = Field( 560 default=None, alias="isSandboxEnvironment" 561 ) 562 business_unit_id: Optional[str] = Field(default=None, alias="businessUnitId")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
565class RedshiftConnectorProfilePropertiesModel(BaseModel): 566 bucket_name: str = Field(alias="bucketName") 567 role_arn: str = Field(alias="roleArn") 568 database_url: Optional[str] = Field(default=None, alias="databaseUrl") 569 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 570 data_api_role_arn: Optional[str] = Field(default=None, alias="dataApiRoleArn") 571 is_redshift_serverless: Optional[bool] = Field( 572 default=None, alias="isRedshiftServerless" 573 ) 574 cluster_identifier: Optional[str] = Field(default=None, alias="clusterIdentifier") 575 workgroup_name: Optional[str] = Field(default=None, alias="workgroupName") 576 database_name: Optional[str] = Field(default=None, alias="databaseName")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
579class SalesforceConnectorProfilePropertiesModel(BaseModel): 580 instance_url: Optional[str] = Field(default=None, alias="instanceUrl") 581 is_sandbox_environment: Optional[bool] = Field( 582 default=None, alias="isSandboxEnvironment" 583 ) 584 use_private_link_for_metadata_and_authorization: Optional[bool] = Field( 585 default=None, alias="usePrivateLinkForMetadataAndAuthorization" 586 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
589class ServiceNowConnectorProfilePropertiesModel(BaseModel): 590 instance_url: str = Field(alias="instanceUrl")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
593class SlackConnectorProfilePropertiesModel(BaseModel): 594 instance_url: str = Field(alias="instanceUrl")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
597class SnowflakeConnectorProfilePropertiesModel(BaseModel): 598 warehouse: str = Field(alias="warehouse") 599 stage: str = Field(alias="stage") 600 bucket_name: str = Field(alias="bucketName") 601 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 602 private_link_service_name: Optional[str] = Field( 603 default=None, alias="privateLinkServiceName" 604 ) 605 account_name: Optional[str] = Field(default=None, alias="accountName") 606 region: Optional[str] = Field(default=None, alias="region")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
609class VeevaConnectorProfilePropertiesModel(BaseModel): 610 instance_url: str = Field(alias="instanceUrl")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
613class ZendeskConnectorProfilePropertiesModel(BaseModel): 614 instance_url: str = Field(alias="instanceUrl")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
617class PrivateConnectionProvisioningStateModel(BaseModel): 618 status: Optional[Literal["CREATED", "FAILED", "PENDING"]] = Field( 619 default=None, alias="status" 620 ) 621 failure_message: Optional[str] = Field(default=None, alias="failureMessage") 622 failure_cause: Optional[ 623 Literal[ 624 "ACCESS_DENIED", 625 "CONNECTOR_AUTHENTICATION", 626 "CONNECTOR_SERVER", 627 "INTERNAL_SERVER", 628 "VALIDATION", 629 ] 630 ] = Field(default=None, alias="failureCause")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
633class LambdaConnectorProvisioningConfigModel(BaseModel): 634 lambda_arn: str = Field(alias="lambdaArn")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
637class ResponseMetadataModel(BaseModel): 638 request_id: str = Field(alias="RequestId") 639 host_id: str = Field(alias="HostId") 640 http_status_code: int = Field(alias="HTTPStatusCode") 641 http_headers: Dict[str, str] = Field(alias="HTTPHeaders") 642 retry_attempts: int = Field(alias="RetryAttempts")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
645class CustomAuthCredentialsModel(BaseModel): 646 custom_authentication_type: str = Field(alias="customAuthenticationType") 647 credentials_map: Optional[Mapping[str, str]] = Field( 648 default=None, alias="credentialsMap" 649 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
652class ErrorHandlingConfigModel(BaseModel): 653 fail_on_first_destination_error: Optional[bool] = Field( 654 default=None, alias="failOnFirstDestinationError" 655 ) 656 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 657 bucket_name: Optional[str] = Field(default=None, alias="bucketName")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
660class OAuth2PropertiesModel(BaseModel): 661 token_url: str = Field(alias="tokenUrl") 662 oauth2_grant_type: Literal["AUTHORIZATION_CODE", "CLIENT_CREDENTIALS"] = Field( 663 alias="oAuth2GrantType" 664 ) 665 token_url_custom_properties: Optional[Mapping[str, str]] = Field( 666 default=None, alias="tokenUrlCustomProperties" 667 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
670class CustomConnectorSourcePropertiesModel(BaseModel): 671 entity_name: str = Field(alias="entityName") 672 custom_properties: Optional[Mapping[str, str]] = Field( 673 default=None, alias="customProperties" 674 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
677class CustomerProfilesDestinationPropertiesModel(BaseModel): 678 domain_name: str = Field(alias="domainName") 679 object_type_name: Optional[str] = Field(default=None, alias="objectTypeName")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
686class DeleteConnectorProfileRequestModel(BaseModel): 687 connector_profile_name: str = Field(alias="connectorProfileName") 688 force_delete: Optional[bool] = Field(default=None, alias="forceDelete")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
691class DeleteFlowRequestModel(BaseModel): 692 flow_name: str = Field(alias="flowName") 693 force_delete: Optional[bool] = Field(default=None, alias="forceDelete")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
696class DescribeConnectorEntityRequestModel(BaseModel): 697 connector_entity_name: str = Field(alias="connectorEntityName") 698 connector_type: Optional[ 699 Literal[ 700 "Amplitude", 701 "CustomConnector", 702 "CustomerProfiles", 703 "Datadog", 704 "Dynatrace", 705 "EventBridge", 706 "Googleanalytics", 707 "Honeycode", 708 "Infornexus", 709 "LookoutMetrics", 710 "Marketo", 711 "Pardot", 712 "Redshift", 713 "S3", 714 "SAPOData", 715 "Salesforce", 716 "Servicenow", 717 "Singular", 718 "Slack", 719 "Snowflake", 720 "Trendmicro", 721 "Upsolver", 722 "Veeva", 723 "Zendesk", 724 ] 725 ] = Field(default=None, alias="connectorType") 726 connector_profile_name: Optional[str] = Field( 727 default=None, alias="connectorProfileName" 728 ) 729 api_version: Optional[str] = Field(default=None, alias="apiVersion")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
732class DescribeConnectorProfilesRequestModel(BaseModel): 733 connector_profile_names: Optional[Sequence[str]] = Field( 734 default=None, alias="connectorProfileNames" 735 ) 736 connector_type: Optional[ 737 Literal[ 738 "Amplitude", 739 "CustomConnector", 740 "CustomerProfiles", 741 "Datadog", 742 "Dynatrace", 743 "EventBridge", 744 "Googleanalytics", 745 "Honeycode", 746 "Infornexus", 747 "LookoutMetrics", 748 "Marketo", 749 "Pardot", 750 "Redshift", 751 "S3", 752 "SAPOData", 753 "Salesforce", 754 "Servicenow", 755 "Singular", 756 "Slack", 757 "Snowflake", 758 "Trendmicro", 759 "Upsolver", 760 "Veeva", 761 "Zendesk", 762 ] 763 ] = Field(default=None, alias="connectorType") 764 connector_label: Optional[str] = Field(default=None, alias="connectorLabel") 765 max_results: Optional[int] = Field(default=None, alias="maxResults") 766 next_token: Optional[str] = Field(default=None, alias="nextToken")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
769class DescribeConnectorRequestModel(BaseModel): 770 connector_type: Literal[ 771 "Amplitude", 772 "CustomConnector", 773 "CustomerProfiles", 774 "Datadog", 775 "Dynatrace", 776 "EventBridge", 777 "Googleanalytics", 778 "Honeycode", 779 "Infornexus", 780 "LookoutMetrics", 781 "Marketo", 782 "Pardot", 783 "Redshift", 784 "S3", 785 "SAPOData", 786 "Salesforce", 787 "Servicenow", 788 "Singular", 789 "Slack", 790 "Snowflake", 791 "Trendmicro", 792 "Upsolver", 793 "Veeva", 794 "Zendesk", 795 ] = Field(alias="connectorType") 796 connector_label: Optional[str] = Field(default=None, alias="connectorLabel")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
799class DescribeConnectorsRequestModel(BaseModel): 800 connector_types: Optional[ 801 Sequence[ 802 Literal[ 803 "Amplitude", 804 "CustomConnector", 805 "CustomerProfiles", 806 "Datadog", 807 "Dynatrace", 808 "EventBridge", 809 "Googleanalytics", 810 "Honeycode", 811 "Infornexus", 812 "LookoutMetrics", 813 "Marketo", 814 "Pardot", 815 "Redshift", 816 "S3", 817 "SAPOData", 818 "Salesforce", 819 "Servicenow", 820 "Singular", 821 "Slack", 822 "Snowflake", 823 "Trendmicro", 824 "Upsolver", 825 "Veeva", 826 "Zendesk", 827 ] 828 ] 829 ] = Field(default=None, alias="connectorTypes") 830 max_results: Optional[int] = Field(default=None, alias="maxResults") 831 next_token: Optional[str] = Field(default=None, alias="nextToken")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
834class DescribeFlowExecutionRecordsRequestModel(BaseModel): 835 flow_name: str = Field(alias="flowName") 836 max_results: Optional[int] = Field(default=None, alias="maxResults") 837 next_token: Optional[str] = Field(default=None, alias="nextToken")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
844class ExecutionDetailsModel(BaseModel): 845 most_recent_execution_message: Optional[str] = Field( 846 default=None, alias="mostRecentExecutionMessage" 847 ) 848 most_recent_execution_time: Optional[datetime] = Field( 849 default=None, alias="mostRecentExecutionTime" 850 ) 851 most_recent_execution_status: Optional[ 852 Literal["Error", "InProgress", "Successful"] 853 ] = Field(default=None, alias="mostRecentExecutionStatus")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
860class ErrorInfoModel(BaseModel): 861 put_failures_count: Optional[int] = Field(default=None, alias="putFailuresCount") 862 execution_message: Optional[str] = Field(default=None, alias="executionMessage")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
865class RangeModel(BaseModel): 866 maximum: Optional[float] = Field(default=None, alias="maximum") 867 minimum: Optional[float] = Field(default=None, alias="minimum")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
870class GlueDataCatalogConfigModel(BaseModel): 871 role_arn: str = Field(alias="roleArn") 872 database_name: str = Field(alias="databaseName") 873 table_prefix: str = Field(alias="tablePrefix")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
880class IncrementalPullConfigModel(BaseModel): 881 datetime_type_field_name: Optional[str] = Field( 882 default=None, alias="datetimeTypeFieldName" 883 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
890class ListConnectorEntitiesRequestModel(BaseModel): 891 connector_profile_name: Optional[str] = Field( 892 default=None, alias="connectorProfileName" 893 ) 894 connector_type: Optional[ 895 Literal[ 896 "Amplitude", 897 "CustomConnector", 898 "CustomerProfiles", 899 "Datadog", 900 "Dynatrace", 901 "EventBridge", 902 "Googleanalytics", 903 "Honeycode", 904 "Infornexus", 905 "LookoutMetrics", 906 "Marketo", 907 "Pardot", 908 "Redshift", 909 "S3", 910 "SAPOData", 911 "Salesforce", 912 "Servicenow", 913 "Singular", 914 "Slack", 915 "Snowflake", 916 "Trendmicro", 917 "Upsolver", 918 "Veeva", 919 "Zendesk", 920 ] 921 ] = Field(default=None, alias="connectorType") 922 entities_path: Optional[str] = Field(default=None, alias="entitiesPath") 923 api_version: Optional[str] = Field(default=None, alias="apiVersion") 924 max_results: Optional[int] = Field(default=None, alias="maxResults") 925 next_token: Optional[str] = Field(default=None, alias="nextToken")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
928class ListConnectorsRequestModel(BaseModel): 929 max_results: Optional[int] = Field(default=None, alias="maxResults") 930 next_token: Optional[str] = Field(default=None, alias="nextToken")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
933class ListFlowsRequestModel(BaseModel): 934 max_results: Optional[int] = Field(default=None, alias="maxResults") 935 next_token: Optional[str] = Field(default=None, alias="nextToken")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
938class ListTagsForResourceRequestModel(BaseModel): 939 resource_arn: str = Field(alias="resourceArn")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
946class RegistrationOutputModel(BaseModel): 947 message: Optional[str] = Field(default=None, alias="message") 948 result: Optional[str] = Field(default=None, alias="result") 949 status: Optional[Literal["Error", "InProgress", "Successful"]] = Field( 950 default=None, alias="status" 951 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
954class OAuth2CustomParameterModel(BaseModel): 955 key: Optional[str] = Field(default=None, alias="key") 956 is_required: Optional[bool] = Field(default=None, alias="isRequired") 957 label: Optional[str] = Field(default=None, alias="label") 958 description: Optional[str] = Field(default=None, alias="description") 959 is_sensitive_field: Optional[bool] = Field(default=None, alias="isSensitiveField") 960 connector_supplied_values: Optional[List[str]] = Field( 961 default=None, alias="connectorSuppliedValues" 962 ) 963 type: Optional[Literal["AUTH_URL", "TOKEN_URL"]] = Field(default=None, alias="type")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
966class OAuthPropertiesModel(BaseModel): 967 token_url: str = Field(alias="tokenUrl") 968 auth_code_url: str = Field(alias="authCodeUrl") 969 oauth_scopes: Sequence[str] = Field(alias="oAuthScopes")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
976class PrefixConfigModel(BaseModel): 977 prefix_type: Optional[Literal["FILENAME", "PATH", "PATH_AND_FILENAME"]] = Field( 978 default=None, alias="prefixType" 979 ) 980 prefix_format: Optional[Literal["DAY", "HOUR", "MINUTE", "MONTH", "YEAR"]] = Field( 981 default=None, alias="prefixFormat" 982 ) 983 path_prefix_hierarchy: Optional[ 984 Sequence[Literal["EXECUTION_ID", "SCHEMA_VERSION"]] 985 ] = Field(default=None, alias="pathPrefixHierarchy")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
988class S3InputFormatConfigModel(BaseModel): 989 s3_input_file_type: Optional[Literal["CSV", "JSON"]] = Field( 990 default=None, alias="s3InputFileType" 991 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
994class SuccessResponseHandlingConfigModel(BaseModel): 995 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 996 bucket_name: Optional[str] = Field(default=None, alias="bucketName")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
999class SAPODataSourcePropertiesModel(BaseModel): 1000 object_path: Optional[str] = Field(default=None, alias="objectPath")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1003class SalesforceSourcePropertiesModel(BaseModel): 1004 object: str = Field(alias="object") 1005 enable_dynamic_field_update: Optional[bool] = Field( 1006 default=None, alias="enableDynamicFieldUpdate" 1007 ) 1008 include_deleted_records: Optional[bool] = Field( 1009 default=None, alias="includeDeletedRecords" 1010 ) 1011 data_transfer_api: Optional[Literal["AUTOMATIC", "BULKV2", "REST_SYNC"]] = Field( 1012 default=None, alias="dataTransferApi" 1013 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1016class ScheduledTriggerPropertiesModel(BaseModel): 1017 schedule_expression: str = Field(alias="scheduleExpression") 1018 data_pull_mode: Optional[Literal["Complete", "Incremental"]] = Field( 1019 default=None, alias="dataPullMode" 1020 ) 1021 schedule_start_time: Optional[Union[datetime, str]] = Field( 1022 default=None, alias="scheduleStartTime" 1023 ) 1024 schedule_end_time: Optional[Union[datetime, str]] = Field( 1025 default=None, alias="scheduleEndTime" 1026 ) 1027 timezone: Optional[str] = Field(default=None, alias="timezone") 1028 schedule_offset: Optional[int] = Field(default=None, alias="scheduleOffset") 1029 first_execution_from: Optional[Union[datetime, str]] = Field( 1030 default=None, alias="firstExecutionFrom" 1031 ) 1032 flow_error_deactivation_threshold: Optional[int] = Field( 1033 default=None, alias="flowErrorDeactivationThreshold" 1034 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1053class VeevaSourcePropertiesModel(BaseModel): 1054 object: str = Field(alias="object") 1055 document_type: Optional[str] = Field(default=None, alias="documentType") 1056 include_source_files: Optional[bool] = Field( 1057 default=None, alias="includeSourceFiles" 1058 ) 1059 include_renditions: Optional[bool] = Field(default=None, alias="includeRenditions") 1060 include_all_versions: Optional[bool] = Field( 1061 default=None, alias="includeAllVersions" 1062 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1077class TagResourceRequestModel(BaseModel): 1078 resource_arn: str = Field(alias="resourceArn") 1079 tags: Mapping[str, str] = Field(alias="tags")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1082class UnregisterConnectorRequestModel(BaseModel): 1083 connector_label: str = Field(alias="connectorLabel") 1084 force_delete: Optional[bool] = Field(default=None, alias="forceDelete")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1087class UntagResourceRequestModel(BaseModel): 1088 resource_arn: str = Field(alias="resourceArn") 1089 tag_keys: Sequence[str] = Field(alias="tagKeys")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1092class CustomAuthConfigModel(BaseModel): 1093 custom_authentication_type: Optional[str] = Field( 1094 default=None, alias="customAuthenticationType" 1095 ) 1096 auth_parameters: Optional[List[AuthParameterModel]] = Field( 1097 default=None, alias="authParameters" 1098 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1101class ConnectorMetadataModel(BaseModel): 1102 amplitude: Optional[Dict[str, Any]] = Field(default=None, alias="Amplitude") 1103 datadog: Optional[Dict[str, Any]] = Field(default=None, alias="Datadog") 1104 dynatrace: Optional[Dict[str, Any]] = Field(default=None, alias="Dynatrace") 1105 google_analytics: Optional[GoogleAnalyticsMetadataModel] = Field( 1106 default=None, alias="GoogleAnalytics" 1107 ) 1108 infor_nexus: Optional[Dict[str, Any]] = Field(default=None, alias="InforNexus") 1109 marketo: Optional[Dict[str, Any]] = Field(default=None, alias="Marketo") 1110 redshift: Optional[Dict[str, Any]] = Field(default=None, alias="Redshift") 1111 s3: Optional[Dict[str, Any]] = Field(default=None, alias="S3") 1112 salesforce: Optional[SalesforceMetadataModel] = Field( 1113 default=None, alias="Salesforce" 1114 ) 1115 service_now: Optional[Dict[str, Any]] = Field(default=None, alias="ServiceNow") 1116 singular: Optional[Dict[str, Any]] = Field(default=None, alias="Singular") 1117 slack: Optional[SlackMetadataModel] = Field(default=None, alias="Slack") 1118 snowflake: Optional[SnowflakeMetadataModel] = Field(default=None, alias="Snowflake") 1119 trendmicro: Optional[Dict[str, Any]] = Field(default=None, alias="Trendmicro") 1120 veeva: Optional[Dict[str, Any]] = Field(default=None, alias="Veeva") 1121 zendesk: Optional[ZendeskMetadataModel] = Field(default=None, alias="Zendesk") 1122 event_bridge: Optional[Dict[str, Any]] = Field(default=None, alias="EventBridge") 1123 upsolver: Optional[Dict[str, Any]] = Field(default=None, alias="Upsolver") 1124 customer_profiles: Optional[Dict[str, Any]] = Field( 1125 default=None, alias="CustomerProfiles" 1126 ) 1127 honeycode: Optional[HoneycodeMetadataModel] = Field(default=None, alias="Honeycode") 1128 s_ap_odata: Optional[Dict[str, Any]] = Field(default=None, alias="SAPOData") 1129 pardot: Optional[Dict[str, Any]] = Field(default=None, alias="Pardot")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1132class GoogleAnalyticsConnectorProfileCredentialsModel(BaseModel): 1133 client_id: str = Field(alias="clientId") 1134 client_secret: str = Field(alias="clientSecret") 1135 access_token: Optional[str] = Field(default=None, alias="accessToken") 1136 refresh_token: Optional[str] = Field(default=None, alias="refreshToken") 1137 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1138 default=None, alias="oAuthRequest" 1139 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1142class HoneycodeConnectorProfileCredentialsModel(BaseModel): 1143 access_token: Optional[str] = Field(default=None, alias="accessToken") 1144 refresh_token: Optional[str] = Field(default=None, alias="refreshToken") 1145 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1146 default=None, alias="oAuthRequest" 1147 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1150class MarketoConnectorProfileCredentialsModel(BaseModel): 1151 client_id: str = Field(alias="clientId") 1152 client_secret: str = Field(alias="clientSecret") 1153 access_token: Optional[str] = Field(default=None, alias="accessToken") 1154 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1155 default=None, alias="oAuthRequest" 1156 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1159class OAuth2CredentialsModel(BaseModel): 1160 client_id: Optional[str] = Field(default=None, alias="clientId") 1161 client_secret: Optional[str] = Field(default=None, alias="clientSecret") 1162 access_token: Optional[str] = Field(default=None, alias="accessToken") 1163 refresh_token: Optional[str] = Field(default=None, alias="refreshToken") 1164 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1165 default=None, alias="oAuthRequest" 1166 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1169class OAuthCredentialsModel(BaseModel): 1170 client_id: str = Field(alias="clientId") 1171 client_secret: str = Field(alias="clientSecret") 1172 access_token: Optional[str] = Field(default=None, alias="accessToken") 1173 refresh_token: Optional[str] = Field(default=None, alias="refreshToken") 1174 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1175 default=None, alias="oAuthRequest" 1176 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1179class PardotConnectorProfileCredentialsModel(BaseModel): 1180 access_token: Optional[str] = Field(default=None, alias="accessToken") 1181 refresh_token: Optional[str] = Field(default=None, alias="refreshToken") 1182 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1183 default=None, alias="oAuthRequest" 1184 ) 1185 client_credentials_arn: Optional[str] = Field( 1186 default=None, alias="clientCredentialsArn" 1187 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1190class SalesforceConnectorProfileCredentialsModel(BaseModel): 1191 access_token: Optional[str] = Field(default=None, alias="accessToken") 1192 refresh_token: Optional[str] = Field(default=None, alias="refreshToken") 1193 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1194 default=None, alias="oAuthRequest" 1195 ) 1196 client_credentials_arn: Optional[str] = Field( 1197 default=None, alias="clientCredentialsArn" 1198 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1201class SlackConnectorProfileCredentialsModel(BaseModel): 1202 client_id: str = Field(alias="clientId") 1203 client_secret: str = Field(alias="clientSecret") 1204 access_token: Optional[str] = Field(default=None, alias="accessToken") 1205 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1206 default=None, alias="oAuthRequest" 1207 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1210class ZendeskConnectorProfileCredentialsModel(BaseModel): 1211 client_id: str = Field(alias="clientId") 1212 client_secret: str = Field(alias="clientSecret") 1213 access_token: Optional[str] = Field(default=None, alias="accessToken") 1214 oauth_request: Optional[ConnectorOAuthRequestModel] = Field( 1215 default=None, alias="oAuthRequest" 1216 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1219class TaskModel(BaseModel): 1220 source_fields: Sequence[str] = Field(alias="sourceFields") 1221 task_type: Literal[ 1222 "Arithmetic", 1223 "Filter", 1224 "Map", 1225 "Map_all", 1226 "Mask", 1227 "Merge", 1228 "Partition", 1229 "Passthrough", 1230 "Truncate", 1231 "Validate", 1232 ] = Field(alias="taskType") 1233 connector_operator: Optional[ConnectorOperatorModel] = Field( 1234 default=None, alias="connectorOperator" 1235 ) 1236 destination_field: Optional[str] = Field(default=None, alias="destinationField") 1237 task_properties: Optional[ 1238 Mapping[ 1239 Literal[ 1240 "CONCAT_FORMAT", 1241 "DATA_TYPE", 1242 "DESTINATION_DATA_TYPE", 1243 "EXCLUDE_SOURCE_FIELDS_LIST", 1244 "INCLUDE_NEW_FIELDS", 1245 "LOWER_BOUND", 1246 "MASK_LENGTH", 1247 "MASK_VALUE", 1248 "MATH_OPERATION_FIELDS_ORDER", 1249 "ORDERED_PARTITION_KEYS_LIST", 1250 "SOURCE_DATA_TYPE", 1251 "SUBFIELD_CATEGORY_MAP", 1252 "TRUNCATE_LENGTH", 1253 "UPPER_BOUND", 1254 "VALIDATION_ACTION", 1255 "VALUE", 1256 "VALUES", 1257 ], 1258 str, 1259 ] 1260 ] = Field(default=None, alias="taskProperties")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1263class ConnectorProvisioningConfigModel(BaseModel): 1264 lambda_: Optional[LambdaConnectorProvisioningConfigModel] = Field( 1265 default=None, alias="lambda" 1266 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1269class CreateConnectorProfileResponseModel(BaseModel): 1270 connector_profile_arn: str = Field(alias="connectorProfileArn") 1271 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1274class CreateFlowResponseModel(BaseModel): 1275 flow_arn: str = Field(alias="flowArn") 1276 flow_status: Literal[ 1277 "Active", "Deleted", "Deprecated", "Draft", "Errored", "Suspended" 1278 ] = Field(alias="flowStatus") 1279 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1282class ListConnectorEntitiesResponseModel(BaseModel): 1283 connector_entity_map: Dict[str, List[ConnectorEntityModel]] = Field( 1284 alias="connectorEntityMap" 1285 ) 1286 next_token: str = Field(alias="nextToken") 1287 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1290class ListConnectorsResponseModel(BaseModel): 1291 connectors: List[ConnectorDetailModel] = Field(alias="connectors") 1292 next_token: str = Field(alias="nextToken") 1293 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1296class ListTagsForResourceResponseModel(BaseModel): 1297 tags: Dict[str, str] = Field(alias="tags") 1298 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1301class RegisterConnectorResponseModel(BaseModel): 1302 connector_arn: str = Field(alias="connectorArn") 1303 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1306class StartFlowResponseModel(BaseModel): 1307 flow_arn: str = Field(alias="flowArn") 1308 flow_status: Literal[ 1309 "Active", "Deleted", "Deprecated", "Draft", "Errored", "Suspended" 1310 ] = Field(alias="flowStatus") 1311 execution_id: str = Field(alias="executionId") 1312 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1315class StopFlowResponseModel(BaseModel): 1316 flow_arn: str = Field(alias="flowArn") 1317 flow_status: Literal[ 1318 "Active", "Deleted", "Deprecated", "Draft", "Errored", "Suspended" 1319 ] = Field(alias="flowStatus") 1320 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1323class UpdateConnectorProfileResponseModel(BaseModel): 1324 connector_profile_arn: str = Field(alias="connectorProfileArn") 1325 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1328class UpdateConnectorRegistrationResponseModel(BaseModel): 1329 connector_arn: str = Field(alias="connectorArn") 1330 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1333class UpdateFlowResponseModel(BaseModel): 1334 flow_status: Literal[ 1335 "Active", "Deleted", "Deprecated", "Draft", "Errored", "Suspended" 1336 ] = Field(alias="flowStatus") 1337 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1340class CustomConnectorDestinationPropertiesModel(BaseModel): 1341 entity_name: str = Field(alias="entityName") 1342 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1343 default=None, alias="errorHandlingConfig" 1344 ) 1345 write_operation_type: Optional[ 1346 Literal["DELETE", "INSERT", "UPDATE", "UPSERT"] 1347 ] = Field(default=None, alias="writeOperationType") 1348 id_field_names: Optional[Sequence[str]] = Field(default=None, alias="idFieldNames") 1349 custom_properties: Optional[Mapping[str, str]] = Field( 1350 default=None, alias="customProperties" 1351 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1354class EventBridgeDestinationPropertiesModel(BaseModel): 1355 object: str = Field(alias="object") 1356 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1357 default=None, alias="errorHandlingConfig" 1358 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1361class HoneycodeDestinationPropertiesModel(BaseModel): 1362 object: str = Field(alias="object") 1363 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1364 default=None, alias="errorHandlingConfig" 1365 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1368class MarketoDestinationPropertiesModel(BaseModel): 1369 object: str = Field(alias="object") 1370 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1371 default=None, alias="errorHandlingConfig" 1372 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1375class RedshiftDestinationPropertiesModel(BaseModel): 1376 object: str = Field(alias="object") 1377 intermediate_bucket_name: str = Field(alias="intermediateBucketName") 1378 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 1379 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1380 default=None, alias="errorHandlingConfig" 1381 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1384class SalesforceDestinationPropertiesModel(BaseModel): 1385 object: str = Field(alias="object") 1386 id_field_names: Optional[Sequence[str]] = Field(default=None, alias="idFieldNames") 1387 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1388 default=None, alias="errorHandlingConfig" 1389 ) 1390 write_operation_type: Optional[ 1391 Literal["DELETE", "INSERT", "UPDATE", "UPSERT"] 1392 ] = Field(default=None, alias="writeOperationType") 1393 data_transfer_api: Optional[Literal["AUTOMATIC", "BULKV2", "REST_SYNC"]] = Field( 1394 default=None, alias="dataTransferApi" 1395 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1398class SnowflakeDestinationPropertiesModel(BaseModel): 1399 object: str = Field(alias="object") 1400 intermediate_bucket_name: str = Field(alias="intermediateBucketName") 1401 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 1402 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1403 default=None, alias="errorHandlingConfig" 1404 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1407class ZendeskDestinationPropertiesModel(BaseModel): 1408 object: str = Field(alias="object") 1409 id_field_names: Optional[Sequence[str]] = Field(default=None, alias="idFieldNames") 1410 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1411 default=None, alias="errorHandlingConfig" 1412 ) 1413 write_operation_type: Optional[ 1414 Literal["DELETE", "INSERT", "UPDATE", "UPSERT"] 1415 ] = Field(default=None, alias="writeOperationType")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1418class CustomConnectorProfilePropertiesModel(BaseModel): 1419 profile_properties: Optional[Mapping[str, str]] = Field( 1420 default=None, alias="profileProperties" 1421 ) 1422 oauth2_properties: Optional[OAuth2PropertiesModel] = Field( 1423 default=None, alias="oAuth2Properties" 1424 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1427class FlowDefinitionModel(BaseModel): 1428 flow_arn: Optional[str] = Field(default=None, alias="flowArn") 1429 description: Optional[str] = Field(default=None, alias="description") 1430 flow_name: Optional[str] = Field(default=None, alias="flowName") 1431 flow_status: Optional[ 1432 Literal["Active", "Deleted", "Deprecated", "Draft", "Errored", "Suspended"] 1433 ] = Field(default=None, alias="flowStatus") 1434 source_connector_type: Optional[ 1435 Literal[ 1436 "Amplitude", 1437 "CustomConnector", 1438 "CustomerProfiles", 1439 "Datadog", 1440 "Dynatrace", 1441 "EventBridge", 1442 "Googleanalytics", 1443 "Honeycode", 1444 "Infornexus", 1445 "LookoutMetrics", 1446 "Marketo", 1447 "Pardot", 1448 "Redshift", 1449 "S3", 1450 "SAPOData", 1451 "Salesforce", 1452 "Servicenow", 1453 "Singular", 1454 "Slack", 1455 "Snowflake", 1456 "Trendmicro", 1457 "Upsolver", 1458 "Veeva", 1459 "Zendesk", 1460 ] 1461 ] = Field(default=None, alias="sourceConnectorType") 1462 source_connector_label: Optional[str] = Field( 1463 default=None, alias="sourceConnectorLabel" 1464 ) 1465 destination_connector_type: Optional[ 1466 Literal[ 1467 "Amplitude", 1468 "CustomConnector", 1469 "CustomerProfiles", 1470 "Datadog", 1471 "Dynatrace", 1472 "EventBridge", 1473 "Googleanalytics", 1474 "Honeycode", 1475 "Infornexus", 1476 "LookoutMetrics", 1477 "Marketo", 1478 "Pardot", 1479 "Redshift", 1480 "S3", 1481 "SAPOData", 1482 "Salesforce", 1483 "Servicenow", 1484 "Singular", 1485 "Slack", 1486 "Snowflake", 1487 "Trendmicro", 1488 "Upsolver", 1489 "Veeva", 1490 "Zendesk", 1491 ] 1492 ] = Field(default=None, alias="destinationConnectorType") 1493 destination_connector_label: Optional[str] = Field( 1494 default=None, alias="destinationConnectorLabel" 1495 ) 1496 trigger_type: Optional[Literal["Event", "OnDemand", "Scheduled"]] = Field( 1497 default=None, alias="triggerType" 1498 ) 1499 created_at: Optional[datetime] = Field(default=None, alias="createdAt") 1500 last_updated_at: Optional[datetime] = Field(default=None, alias="lastUpdatedAt") 1501 created_by: Optional[str] = Field(default=None, alias="createdBy") 1502 last_updated_by: Optional[str] = Field(default=None, alias="lastUpdatedBy") 1503 tags: Optional[Dict[str, str]] = Field(default=None, alias="tags") 1504 last_run_execution_details: Optional[ExecutionDetailsModel] = Field( 1505 default=None, alias="lastRunExecutionDetails" 1506 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1509class ExecutionResultModel(BaseModel): 1510 error_info: Optional[ErrorInfoModel] = Field(default=None, alias="errorInfo") 1511 bytes_processed: Optional[int] = Field(default=None, alias="bytesProcessed") 1512 bytes_written: Optional[int] = Field(default=None, alias="bytesWritten") 1513 records_processed: Optional[int] = Field(default=None, alias="recordsProcessed")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1516class FieldTypeDetailsModel(BaseModel): 1517 field_type: str = Field(alias="fieldType") 1518 filter_operators: List[ 1519 Literal[ 1520 "ADDITION", 1521 "BETWEEN", 1522 "CONTAINS", 1523 "DIVISION", 1524 "EQUAL_TO", 1525 "GREATER_THAN", 1526 "GREATER_THAN_OR_EQUAL_TO", 1527 "LESS_THAN", 1528 "LESS_THAN_OR_EQUAL_TO", 1529 "MASK_ALL", 1530 "MASK_FIRST_N", 1531 "MASK_LAST_N", 1532 "MULTIPLICATION", 1533 "NOT_EQUAL_TO", 1534 "NO_OP", 1535 "PROJECTION", 1536 "SUBTRACTION", 1537 "VALIDATE_NON_NEGATIVE", 1538 "VALIDATE_NON_NULL", 1539 "VALIDATE_NON_ZERO", 1540 "VALIDATE_NUMERIC", 1541 ] 1542 ] = Field(alias="filterOperators") 1543 supported_values: Optional[List[str]] = Field(default=None, alias="supportedValues") 1544 value_regex_pattern: Optional[str] = Field(default=None, alias="valueRegexPattern") 1545 supported_date_format: Optional[str] = Field( 1546 default=None, alias="supportedDateFormat" 1547 ) 1548 field_value_range: Optional[RangeModel] = Field( 1549 default=None, alias="fieldValueRange" 1550 ) 1551 field_length_range: Optional[RangeModel] = Field( 1552 default=None, alias="fieldLengthRange" 1553 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1556class MetadataCatalogConfigModel(BaseModel): 1557 glue_data_catalog: Optional[GlueDataCatalogConfigModel] = Field( 1558 default=None, alias="glueDataCatalog" 1559 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1562class MetadataCatalogDetailModel(BaseModel): 1563 catalog_type: Optional[Literal["GLUE"]] = Field(default=None, alias="catalogType") 1564 table_name: Optional[str] = Field(default=None, alias="tableName") 1565 table_registration_output: Optional[RegistrationOutputModel] = Field( 1566 default=None, alias="tableRegistrationOutput" 1567 ) 1568 partition_registration_output: Optional[RegistrationOutputModel] = Field( 1569 default=None, alias="partitionRegistrationOutput" 1570 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1573class OAuth2DefaultsModel(BaseModel): 1574 oauth_scopes: Optional[List[str]] = Field(default=None, alias="oauthScopes") 1575 token_urls: Optional[List[str]] = Field(default=None, alias="tokenUrls") 1576 auth_code_urls: Optional[List[str]] = Field(default=None, alias="authCodeUrls") 1577 oauth2_grant_types_supported: Optional[ 1578 List[Literal["AUTHORIZATION_CODE", "CLIENT_CREDENTIALS"]] 1579 ] = Field(default=None, alias="oauth2GrantTypesSupported") 1580 oauth2_custom_properties: Optional[List[OAuth2CustomParameterModel]] = Field( 1581 default=None, alias="oauth2CustomProperties" 1582 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1585class SAPODataConnectorProfilePropertiesModel(BaseModel): 1586 application_host_url: str = Field(alias="applicationHostUrl") 1587 application_service_path: str = Field(alias="applicationServicePath") 1588 port_number: int = Field(alias="portNumber") 1589 client_number: str = Field(alias="clientNumber") 1590 logon_language: Optional[str] = Field(default=None, alias="logonLanguage") 1591 private_link_service_name: Optional[str] = Field( 1592 default=None, alias="privateLinkServiceName" 1593 ) 1594 oauth_properties: Optional[OAuthPropertiesModel] = Field( 1595 default=None, alias="oAuthProperties" 1596 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1599class S3OutputFormatConfigModel(BaseModel): 1600 file_type: Optional[Literal["CSV", "JSON", "PARQUET"]] = Field( 1601 default=None, alias="fileType" 1602 ) 1603 prefix_config: Optional[PrefixConfigModel] = Field( 1604 default=None, alias="prefixConfig" 1605 ) 1606 aggregation_config: Optional[AggregationConfigModel] = Field( 1607 default=None, alias="aggregationConfig" 1608 ) 1609 preserve_source_data_typing: Optional[bool] = Field( 1610 default=None, alias="preserveSourceDataTyping" 1611 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1614class UpsolverS3OutputFormatConfigModel(BaseModel): 1615 prefix_config: PrefixConfigModel = Field(alias="prefixConfig") 1616 file_type: Optional[Literal["CSV", "JSON", "PARQUET"]] = Field( 1617 default=None, alias="fileType" 1618 ) 1619 aggregation_config: Optional[AggregationConfigModel] = Field( 1620 default=None, alias="aggregationConfig" 1621 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1624class S3SourcePropertiesModel(BaseModel): 1625 bucket_name: str = Field(alias="bucketName") 1626 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 1627 s3_input_format_config: Optional[S3InputFormatConfigModel] = Field( 1628 default=None, alias="s3InputFormatConfig" 1629 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1632class SAPODataDestinationPropertiesModel(BaseModel): 1633 object_path: str = Field(alias="objectPath") 1634 success_response_handling_config: Optional[ 1635 SuccessResponseHandlingConfigModel 1636 ] = Field(default=None, alias="successResponseHandlingConfig") 1637 id_field_names: Optional[Sequence[str]] = Field(default=None, alias="idFieldNames") 1638 error_handling_config: Optional[ErrorHandlingConfigModel] = Field( 1639 default=None, alias="errorHandlingConfig" 1640 ) 1641 write_operation_type: Optional[ 1642 Literal["DELETE", "INSERT", "UPDATE", "UPSERT"] 1643 ] = Field(default=None, alias="writeOperationType")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1646class TriggerPropertiesModel(BaseModel): 1647 scheduled: Optional[ScheduledTriggerPropertiesModel] = Field( 1648 default=None, alias="Scheduled" 1649 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1652class CustomConnectorProfileCredentialsModel(BaseModel): 1653 authentication_type: Literal["APIKEY", "BASIC", "CUSTOM", "OAUTH2"] = Field( 1654 alias="authenticationType" 1655 ) 1656 basic: Optional[BasicAuthCredentialsModel] = Field(default=None, alias="basic") 1657 oauth2: Optional[OAuth2CredentialsModel] = Field(default=None, alias="oauth2") 1658 api_key: Optional[ApiKeyCredentialsModel] = Field(default=None, alias="apiKey") 1659 custom: Optional[CustomAuthCredentialsModel] = Field(default=None, alias="custom")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1662class SAPODataConnectorProfileCredentialsModel(BaseModel): 1663 basic_auth_credentials: Optional[BasicAuthCredentialsModel] = Field( 1664 default=None, alias="basicAuthCredentials" 1665 ) 1666 oauth_credentials: Optional[OAuthCredentialsModel] = Field( 1667 default=None, alias="oAuthCredentials" 1668 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1671class RegisterConnectorRequestModel(BaseModel): 1672 connector_label: Optional[str] = Field(default=None, alias="connectorLabel") 1673 description: Optional[str] = Field(default=None, alias="description") 1674 connector_provisioning_type: Optional[Literal["LAMBDA"]] = Field( 1675 default=None, alias="connectorProvisioningType" 1676 ) 1677 connector_provisioning_config: Optional[ConnectorProvisioningConfigModel] = Field( 1678 default=None, alias="connectorProvisioningConfig" 1679 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1682class UpdateConnectorRegistrationRequestModel(BaseModel): 1683 connector_label: str = Field(alias="connectorLabel") 1684 description: Optional[str] = Field(default=None, alias="description") 1685 connector_provisioning_config: Optional[ConnectorProvisioningConfigModel] = Field( 1686 default=None, alias="connectorProvisioningConfig" 1687 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1690class ListFlowsResponseModel(BaseModel): 1691 flows: List[FlowDefinitionModel] = Field(alias="flows") 1692 next_token: str = Field(alias="nextToken") 1693 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1696class SupportedFieldTypeDetailsModel(BaseModel): 1697 v1: FieldTypeDetailsModel = Field(alias="v1")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1700class ExecutionRecordModel(BaseModel): 1701 execution_id: Optional[str] = Field(default=None, alias="executionId") 1702 execution_status: Optional[Literal["Error", "InProgress", "Successful"]] = Field( 1703 default=None, alias="executionStatus" 1704 ) 1705 execution_result: Optional[ExecutionResultModel] = Field( 1706 default=None, alias="executionResult" 1707 ) 1708 started_at: Optional[datetime] = Field(default=None, alias="startedAt") 1709 last_updated_at: Optional[datetime] = Field(default=None, alias="lastUpdatedAt") 1710 data_pull_start_time: Optional[datetime] = Field( 1711 default=None, alias="dataPullStartTime" 1712 ) 1713 data_pull_end_time: Optional[datetime] = Field( 1714 default=None, alias="dataPullEndTime" 1715 ) 1716 metadata_catalog_details: Optional[List[MetadataCatalogDetailModel]] = Field( 1717 default=None, alias="metadataCatalogDetails" 1718 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1721class AuthenticationConfigModel(BaseModel): 1722 is_basic_auth_supported: Optional[bool] = Field( 1723 default=None, alias="isBasicAuthSupported" 1724 ) 1725 is_api_key_auth_supported: Optional[bool] = Field( 1726 default=None, alias="isApiKeyAuthSupported" 1727 ) 1728 is_oauth2_supported: Optional[bool] = Field(default=None, alias="isOAuth2Supported") 1729 is_custom_auth_supported: Optional[bool] = Field( 1730 default=None, alias="isCustomAuthSupported" 1731 ) 1732 oauth2_defaults: Optional[OAuth2DefaultsModel] = Field( 1733 default=None, alias="oAuth2Defaults" 1734 ) 1735 custom_auth_configs: Optional[List[CustomAuthConfigModel]] = Field( 1736 default=None, alias="customAuthConfigs" 1737 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1740class ConnectorProfilePropertiesModel(BaseModel): 1741 amplitude: Optional[Mapping[str, Any]] = Field(default=None, alias="Amplitude") 1742 datadog: Optional[DatadogConnectorProfilePropertiesModel] = Field( 1743 default=None, alias="Datadog" 1744 ) 1745 dynatrace: Optional[DynatraceConnectorProfilePropertiesModel] = Field( 1746 default=None, alias="Dynatrace" 1747 ) 1748 google_analytics: Optional[Mapping[str, Any]] = Field( 1749 default=None, alias="GoogleAnalytics" 1750 ) 1751 honeycode: Optional[Mapping[str, Any]] = Field(default=None, alias="Honeycode") 1752 infor_nexus: Optional[InforNexusConnectorProfilePropertiesModel] = Field( 1753 default=None, alias="InforNexus" 1754 ) 1755 marketo: Optional[MarketoConnectorProfilePropertiesModel] = Field( 1756 default=None, alias="Marketo" 1757 ) 1758 redshift: Optional[RedshiftConnectorProfilePropertiesModel] = Field( 1759 default=None, alias="Redshift" 1760 ) 1761 salesforce: Optional[SalesforceConnectorProfilePropertiesModel] = Field( 1762 default=None, alias="Salesforce" 1763 ) 1764 service_now: Optional[ServiceNowConnectorProfilePropertiesModel] = Field( 1765 default=None, alias="ServiceNow" 1766 ) 1767 singular: Optional[Mapping[str, Any]] = Field(default=None, alias="Singular") 1768 slack: Optional[SlackConnectorProfilePropertiesModel] = Field( 1769 default=None, alias="Slack" 1770 ) 1771 snowflake: Optional[SnowflakeConnectorProfilePropertiesModel] = Field( 1772 default=None, alias="Snowflake" 1773 ) 1774 trendmicro: Optional[Mapping[str, Any]] = Field(default=None, alias="Trendmicro") 1775 veeva: Optional[VeevaConnectorProfilePropertiesModel] = Field( 1776 default=None, alias="Veeva" 1777 ) 1778 zendesk: Optional[ZendeskConnectorProfilePropertiesModel] = Field( 1779 default=None, alias="Zendesk" 1780 ) 1781 s_ap_odata: Optional[SAPODataConnectorProfilePropertiesModel] = Field( 1782 default=None, alias="SAPOData" 1783 ) 1784 custom_connector: Optional[CustomConnectorProfilePropertiesModel] = Field( 1785 default=None, alias="CustomConnector" 1786 ) 1787 pardot: Optional[PardotConnectorProfilePropertiesModel] = Field( 1788 default=None, alias="Pardot" 1789 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1792class S3DestinationPropertiesModel(BaseModel): 1793 bucket_name: str = Field(alias="bucketName") 1794 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix") 1795 s3_output_format_config: Optional[S3OutputFormatConfigModel] = Field( 1796 default=None, alias="s3OutputFormatConfig" 1797 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1800class UpsolverDestinationPropertiesModel(BaseModel): 1801 bucket_name: str = Field(alias="bucketName") 1802 s3_output_format_config: UpsolverS3OutputFormatConfigModel = Field( 1803 alias="s3OutputFormatConfig" 1804 ) 1805 bucket_prefix: Optional[str] = Field(default=None, alias="bucketPrefix")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1808class SourceConnectorPropertiesModel(BaseModel): 1809 amplitude: Optional[AmplitudeSourcePropertiesModel] = Field( 1810 default=None, alias="Amplitude" 1811 ) 1812 datadog: Optional[DatadogSourcePropertiesModel] = Field( 1813 default=None, alias="Datadog" 1814 ) 1815 dynatrace: Optional[DynatraceSourcePropertiesModel] = Field( 1816 default=None, alias="Dynatrace" 1817 ) 1818 google_analytics: Optional[GoogleAnalyticsSourcePropertiesModel] = Field( 1819 default=None, alias="GoogleAnalytics" 1820 ) 1821 infor_nexus: Optional[InforNexusSourcePropertiesModel] = Field( 1822 default=None, alias="InforNexus" 1823 ) 1824 marketo: Optional[MarketoSourcePropertiesModel] = Field( 1825 default=None, alias="Marketo" 1826 ) 1827 s3: Optional[S3SourcePropertiesModel] = Field(default=None, alias="S3") 1828 salesforce: Optional[SalesforceSourcePropertiesModel] = Field( 1829 default=None, alias="Salesforce" 1830 ) 1831 service_now: Optional[ServiceNowSourcePropertiesModel] = Field( 1832 default=None, alias="ServiceNow" 1833 ) 1834 singular: Optional[SingularSourcePropertiesModel] = Field( 1835 default=None, alias="Singular" 1836 ) 1837 slack: Optional[SlackSourcePropertiesModel] = Field(default=None, alias="Slack") 1838 trendmicro: Optional[TrendmicroSourcePropertiesModel] = Field( 1839 default=None, alias="Trendmicro" 1840 ) 1841 veeva: Optional[VeevaSourcePropertiesModel] = Field(default=None, alias="Veeva") 1842 zendesk: Optional[ZendeskSourcePropertiesModel] = Field( 1843 default=None, alias="Zendesk" 1844 ) 1845 s_ap_odata: Optional[SAPODataSourcePropertiesModel] = Field( 1846 default=None, alias="SAPOData" 1847 ) 1848 custom_connector: Optional[CustomConnectorSourcePropertiesModel] = Field( 1849 default=None, alias="CustomConnector" 1850 ) 1851 pardot: Optional[PardotSourcePropertiesModel] = Field(default=None, alias="Pardot")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1854class TriggerConfigModel(BaseModel): 1855 trigger_type: Literal["Event", "OnDemand", "Scheduled"] = Field(alias="triggerType") 1856 trigger_properties: Optional[TriggerPropertiesModel] = Field( 1857 default=None, alias="triggerProperties" 1858 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1861class ConnectorProfileCredentialsModel(BaseModel): 1862 amplitude: Optional[AmplitudeConnectorProfileCredentialsModel] = Field( 1863 default=None, alias="Amplitude" 1864 ) 1865 datadog: Optional[DatadogConnectorProfileCredentialsModel] = Field( 1866 default=None, alias="Datadog" 1867 ) 1868 dynatrace: Optional[DynatraceConnectorProfileCredentialsModel] = Field( 1869 default=None, alias="Dynatrace" 1870 ) 1871 google_analytics: Optional[GoogleAnalyticsConnectorProfileCredentialsModel] = Field( 1872 default=None, alias="GoogleAnalytics" 1873 ) 1874 honeycode: Optional[HoneycodeConnectorProfileCredentialsModel] = Field( 1875 default=None, alias="Honeycode" 1876 ) 1877 infor_nexus: Optional[InforNexusConnectorProfileCredentialsModel] = Field( 1878 default=None, alias="InforNexus" 1879 ) 1880 marketo: Optional[MarketoConnectorProfileCredentialsModel] = Field( 1881 default=None, alias="Marketo" 1882 ) 1883 redshift: Optional[RedshiftConnectorProfileCredentialsModel] = Field( 1884 default=None, alias="Redshift" 1885 ) 1886 salesforce: Optional[SalesforceConnectorProfileCredentialsModel] = Field( 1887 default=None, alias="Salesforce" 1888 ) 1889 service_now: Optional[ServiceNowConnectorProfileCredentialsModel] = Field( 1890 default=None, alias="ServiceNow" 1891 ) 1892 singular: Optional[SingularConnectorProfileCredentialsModel] = Field( 1893 default=None, alias="Singular" 1894 ) 1895 slack: Optional[SlackConnectorProfileCredentialsModel] = Field( 1896 default=None, alias="Slack" 1897 ) 1898 snowflake: Optional[SnowflakeConnectorProfileCredentialsModel] = Field( 1899 default=None, alias="Snowflake" 1900 ) 1901 trendmicro: Optional[TrendmicroConnectorProfileCredentialsModel] = Field( 1902 default=None, alias="Trendmicro" 1903 ) 1904 veeva: Optional[VeevaConnectorProfileCredentialsModel] = Field( 1905 default=None, alias="Veeva" 1906 ) 1907 zendesk: Optional[ZendeskConnectorProfileCredentialsModel] = Field( 1908 default=None, alias="Zendesk" 1909 ) 1910 s_ap_odata: Optional[SAPODataConnectorProfileCredentialsModel] = Field( 1911 default=None, alias="SAPOData" 1912 ) 1913 custom_connector: Optional[CustomConnectorProfileCredentialsModel] = Field( 1914 default=None, alias="CustomConnector" 1915 ) 1916 pardot: Optional[PardotConnectorProfileCredentialsModel] = Field( 1917 default=None, alias="Pardot" 1918 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1921class ConnectorEntityFieldModel(BaseModel): 1922 identifier: str = Field(alias="identifier") 1923 parent_identifier: Optional[str] = Field(default=None, alias="parentIdentifier") 1924 label: Optional[str] = Field(default=None, alias="label") 1925 is_primary_key: Optional[bool] = Field(default=None, alias="isPrimaryKey") 1926 default_value: Optional[str] = Field(default=None, alias="defaultValue") 1927 is_deprecated: Optional[bool] = Field(default=None, alias="isDeprecated") 1928 supported_field_type_details: Optional[SupportedFieldTypeDetailsModel] = Field( 1929 default=None, alias="supportedFieldTypeDetails" 1930 ) 1931 description: Optional[str] = Field(default=None, alias="description") 1932 source_properties: Optional[SourceFieldPropertiesModel] = Field( 1933 default=None, alias="sourceProperties" 1934 ) 1935 destination_properties: Optional[DestinationFieldPropertiesModel] = Field( 1936 default=None, alias="destinationProperties" 1937 ) 1938 custom_properties: Optional[Dict[str, str]] = Field( 1939 default=None, alias="customProperties" 1940 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1943class DescribeFlowExecutionRecordsResponseModel(BaseModel): 1944 flow_executions: List[ExecutionRecordModel] = Field(alias="flowExecutions") 1945 next_token: str = Field(alias="nextToken") 1946 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
1949class ConnectorConfigurationModel(BaseModel): 1950 can_use_as_source: Optional[bool] = Field(default=None, alias="canUseAsSource") 1951 can_use_as_destination: Optional[bool] = Field( 1952 default=None, alias="canUseAsDestination" 1953 ) 1954 supported_destination_connectors: Optional[ 1955 List[ 1956 Literal[ 1957 "Amplitude", 1958 "CustomConnector", 1959 "CustomerProfiles", 1960 "Datadog", 1961 "Dynatrace", 1962 "EventBridge", 1963 "Googleanalytics", 1964 "Honeycode", 1965 "Infornexus", 1966 "LookoutMetrics", 1967 "Marketo", 1968 "Pardot", 1969 "Redshift", 1970 "S3", 1971 "SAPOData", 1972 "Salesforce", 1973 "Servicenow", 1974 "Singular", 1975 "Slack", 1976 "Snowflake", 1977 "Trendmicro", 1978 "Upsolver", 1979 "Veeva", 1980 "Zendesk", 1981 ] 1982 ] 1983 ] = Field(default=None, alias="supportedDestinationConnectors") 1984 supported_scheduling_frequencies: Optional[ 1985 List[Literal["BYMINUTE", "DAILY", "HOURLY", "MONTHLY", "ONCE", "WEEKLY"]] 1986 ] = Field(default=None, alias="supportedSchedulingFrequencies") 1987 is_private_link_enabled: Optional[bool] = Field( 1988 default=None, alias="isPrivateLinkEnabled" 1989 ) 1990 is_private_link_endpoint_url_required: Optional[bool] = Field( 1991 default=None, alias="isPrivateLinkEndpointUrlRequired" 1992 ) 1993 supported_trigger_types: Optional[ 1994 List[Literal["Event", "OnDemand", "Scheduled"]] 1995 ] = Field(default=None, alias="supportedTriggerTypes") 1996 connector_metadata: Optional[ConnectorMetadataModel] = Field( 1997 default=None, alias="connectorMetadata" 1998 ) 1999 connector_type: Optional[ 2000 Literal[ 2001 "Amplitude", 2002 "CustomConnector", 2003 "CustomerProfiles", 2004 "Datadog", 2005 "Dynatrace", 2006 "EventBridge", 2007 "Googleanalytics", 2008 "Honeycode", 2009 "Infornexus", 2010 "LookoutMetrics", 2011 "Marketo", 2012 "Pardot", 2013 "Redshift", 2014 "S3", 2015 "SAPOData", 2016 "Salesforce", 2017 "Servicenow", 2018 "Singular", 2019 "Slack", 2020 "Snowflake", 2021 "Trendmicro", 2022 "Upsolver", 2023 "Veeva", 2024 "Zendesk", 2025 ] 2026 ] = Field(default=None, alias="connectorType") 2027 connector_label: Optional[str] = Field(default=None, alias="connectorLabel") 2028 connector_description: Optional[str] = Field( 2029 default=None, alias="connectorDescription" 2030 ) 2031 connector_owner: Optional[str] = Field(default=None, alias="connectorOwner") 2032 connector_name: Optional[str] = Field(default=None, alias="connectorName") 2033 connector_version: Optional[str] = Field(default=None, alias="connectorVersion") 2034 connector_arn: Optional[str] = Field(default=None, alias="connectorArn") 2035 connector_modes: Optional[List[str]] = Field(default=None, alias="connectorModes") 2036 authentication_config: Optional[AuthenticationConfigModel] = Field( 2037 default=None, alias="authenticationConfig" 2038 ) 2039 connector_runtime_settings: Optional[List[ConnectorRuntimeSettingModel]] = Field( 2040 default=None, alias="connectorRuntimeSettings" 2041 ) 2042 supported_api_versions: Optional[List[str]] = Field( 2043 default=None, alias="supportedApiVersions" 2044 ) 2045 supported_operators: Optional[ 2046 List[ 2047 Literal[ 2048 "ADDITION", 2049 "BETWEEN", 2050 "CONTAINS", 2051 "DIVISION", 2052 "EQUAL_TO", 2053 "GREATER_THAN", 2054 "GREATER_THAN_OR_EQUAL_TO", 2055 "LESS_THAN", 2056 "LESS_THAN_OR_EQUAL_TO", 2057 "MASK_ALL", 2058 "MASK_FIRST_N", 2059 "MASK_LAST_N", 2060 "MULTIPLICATION", 2061 "NOT_EQUAL_TO", 2062 "NO_OP", 2063 "PROJECTION", 2064 "SUBTRACTION", 2065 "VALIDATE_NON_NEGATIVE", 2066 "VALIDATE_NON_NULL", 2067 "VALIDATE_NON_ZERO", 2068 "VALIDATE_NUMERIC", 2069 ] 2070 ] 2071 ] = Field(default=None, alias="supportedOperators") 2072 supported_write_operations: Optional[ 2073 List[Literal["DELETE", "INSERT", "UPDATE", "UPSERT"]] 2074 ] = Field(default=None, alias="supportedWriteOperations") 2075 connector_provisioning_type: Optional[Literal["LAMBDA"]] = Field( 2076 default=None, alias="connectorProvisioningType" 2077 ) 2078 connector_provisioning_config: Optional[ConnectorProvisioningConfigModel] = Field( 2079 default=None, alias="connectorProvisioningConfig" 2080 ) 2081 logo_url: Optional[str] = Field(default=None, alias="logoURL") 2082 registered_at: Optional[datetime] = Field(default=None, alias="registeredAt") 2083 registered_by: Optional[str] = Field(default=None, alias="registeredBy")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
2086class ConnectorProfileModel(BaseModel): 2087 connector_profile_arn: Optional[str] = Field( 2088 default=None, alias="connectorProfileArn" 2089 ) 2090 connector_profile_name: Optional[str] = Field( 2091 default=None, alias="connectorProfileName" 2092 ) 2093 connector_type: Optional[ 2094 Literal[ 2095 "Amplitude", 2096 "CustomConnector", 2097 "CustomerProfiles", 2098 "Datadog", 2099 "Dynatrace", 2100 "EventBridge", 2101 "Googleanalytics", 2102 "Honeycode", 2103 "Infornexus", 2104 "LookoutMetrics", 2105 "Marketo", 2106 "Pardot", 2107 "Redshift", 2108 "S3", 2109 "SAPOData", 2110 "Salesforce", 2111 "Servicenow", 2112 "Singular", 2113 "Slack", 2114 "Snowflake", 2115 "Trendmicro", 2116 "Upsolver", 2117 "Veeva", 2118 "Zendesk", 2119 ] 2120 ] = Field(default=None, alias="connectorType") 2121 connector_label: Optional[str] = Field(default=None, alias="connectorLabel") 2122 connection_mode: Optional[Literal["Private", "Public"]] = Field( 2123 default=None, alias="connectionMode" 2124 ) 2125 credentials_arn: Optional[str] = Field(default=None, alias="credentialsArn") 2126 connector_profile_properties: Optional[ConnectorProfilePropertiesModel] = Field( 2127 default=None, alias="connectorProfileProperties" 2128 ) 2129 created_at: Optional[datetime] = Field(default=None, alias="createdAt") 2130 last_updated_at: Optional[datetime] = Field(default=None, alias="lastUpdatedAt") 2131 private_connection_provisioning_state: Optional[ 2132 PrivateConnectionProvisioningStateModel 2133 ] = Field(default=None, alias="privateConnectionProvisioningState")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
2136class DestinationConnectorPropertiesModel(BaseModel): 2137 redshift: Optional[RedshiftDestinationPropertiesModel] = Field( 2138 default=None, alias="Redshift" 2139 ) 2140 s3: Optional[S3DestinationPropertiesModel] = Field(default=None, alias="S3") 2141 salesforce: Optional[SalesforceDestinationPropertiesModel] = Field( 2142 default=None, alias="Salesforce" 2143 ) 2144 snowflake: Optional[SnowflakeDestinationPropertiesModel] = Field( 2145 default=None, alias="Snowflake" 2146 ) 2147 event_bridge: Optional[EventBridgeDestinationPropertiesModel] = Field( 2148 default=None, alias="EventBridge" 2149 ) 2150 lookout_metrics: Optional[Mapping[str, Any]] = Field( 2151 default=None, alias="LookoutMetrics" 2152 ) 2153 upsolver: Optional[UpsolverDestinationPropertiesModel] = Field( 2154 default=None, alias="Upsolver" 2155 ) 2156 honeycode: Optional[HoneycodeDestinationPropertiesModel] = Field( 2157 default=None, alias="Honeycode" 2158 ) 2159 customer_profiles: Optional[CustomerProfilesDestinationPropertiesModel] = Field( 2160 default=None, alias="CustomerProfiles" 2161 ) 2162 zendesk: Optional[ZendeskDestinationPropertiesModel] = Field( 2163 default=None, alias="Zendesk" 2164 ) 2165 marketo: Optional[MarketoDestinationPropertiesModel] = Field( 2166 default=None, alias="Marketo" 2167 ) 2168 custom_connector: Optional[CustomConnectorDestinationPropertiesModel] = Field( 2169 default=None, alias="CustomConnector" 2170 ) 2171 s_ap_odata: Optional[SAPODataDestinationPropertiesModel] = Field( 2172 default=None, alias="SAPOData" 2173 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
2176class SourceFlowConfigModel(BaseModel): 2177 connector_type: Literal[ 2178 "Amplitude", 2179 "CustomConnector", 2180 "CustomerProfiles", 2181 "Datadog", 2182 "Dynatrace", 2183 "EventBridge", 2184 "Googleanalytics", 2185 "Honeycode", 2186 "Infornexus", 2187 "LookoutMetrics", 2188 "Marketo", 2189 "Pardot", 2190 "Redshift", 2191 "S3", 2192 "SAPOData", 2193 "Salesforce", 2194 "Servicenow", 2195 "Singular", 2196 "Slack", 2197 "Snowflake", 2198 "Trendmicro", 2199 "Upsolver", 2200 "Veeva", 2201 "Zendesk", 2202 ] = Field(alias="connectorType") 2203 source_connector_properties: SourceConnectorPropertiesModel = Field( 2204 alias="sourceConnectorProperties" 2205 ) 2206 api_version: Optional[str] = Field(default=None, alias="apiVersion") 2207 connector_profile_name: Optional[str] = Field( 2208 default=None, alias="connectorProfileName" 2209 ) 2210 incremental_pull_config: Optional[IncrementalPullConfigModel] = Field( 2211 default=None, alias="incrementalPullConfig" 2212 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
2215class ConnectorProfileConfigModel(BaseModel): 2216 connector_profile_properties: ConnectorProfilePropertiesModel = Field( 2217 alias="connectorProfileProperties" 2218 ) 2219 connector_profile_credentials: Optional[ConnectorProfileCredentialsModel] = Field( 2220 default=None, alias="connectorProfileCredentials" 2221 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
2224class DescribeConnectorEntityResponseModel(BaseModel): 2225 connector_entity_fields: List[ConnectorEntityFieldModel] = Field( 2226 alias="connectorEntityFields" 2227 ) 2228 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
2231class DescribeConnectorResponseModel(BaseModel): 2232 connector_configuration: ConnectorConfigurationModel = Field( 2233 alias="connectorConfiguration" 2234 ) 2235 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
2238class DescribeConnectorsResponseModel(BaseModel): 2239 connector_configurations: Dict[ 2240 Literal[ 2241 "Amplitude", 2242 "CustomConnector", 2243 "CustomerProfiles", 2244 "Datadog", 2245 "Dynatrace", 2246 "EventBridge", 2247 "Googleanalytics", 2248 "Honeycode", 2249 "Infornexus", 2250 "LookoutMetrics", 2251 "Marketo", 2252 "Pardot", 2253 "Redshift", 2254 "S3", 2255 "SAPOData", 2256 "Salesforce", 2257 "Servicenow", 2258 "Singular", 2259 "Slack", 2260 "Snowflake", 2261 "Trendmicro", 2262 "Upsolver", 2263 "Veeva", 2264 "Zendesk", 2265 ], 2266 ConnectorConfigurationModel, 2267 ] = Field(alias="connectorConfigurations") 2268 connectors: List[ConnectorDetailModel] = Field(alias="connectors") 2269 next_token: str = Field(alias="nextToken") 2270 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
2273class DescribeConnectorProfilesResponseModel(BaseModel): 2274 connector_profile_details: List[ConnectorProfileModel] = Field( 2275 alias="connectorProfileDetails" 2276 ) 2277 next_token: str = Field(alias="nextToken") 2278 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
2281class DestinationFlowConfigModel(BaseModel): 2282 connector_type: Literal[ 2283 "Amplitude", 2284 "CustomConnector", 2285 "CustomerProfiles", 2286 "Datadog", 2287 "Dynatrace", 2288 "EventBridge", 2289 "Googleanalytics", 2290 "Honeycode", 2291 "Infornexus", 2292 "LookoutMetrics", 2293 "Marketo", 2294 "Pardot", 2295 "Redshift", 2296 "S3", 2297 "SAPOData", 2298 "Salesforce", 2299 "Servicenow", 2300 "Singular", 2301 "Slack", 2302 "Snowflake", 2303 "Trendmicro", 2304 "Upsolver", 2305 "Veeva", 2306 "Zendesk", 2307 ] = Field(alias="connectorType") 2308 destination_connector_properties: DestinationConnectorPropertiesModel = Field( 2309 alias="destinationConnectorProperties" 2310 ) 2311 api_version: Optional[str] = Field(default=None, alias="apiVersion") 2312 connector_profile_name: Optional[str] = Field( 2313 default=None, alias="connectorProfileName" 2314 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
2317class CreateConnectorProfileRequestModel(BaseModel): 2318 connector_profile_name: str = Field(alias="connectorProfileName") 2319 connector_type: Literal[ 2320 "Amplitude", 2321 "CustomConnector", 2322 "CustomerProfiles", 2323 "Datadog", 2324 "Dynatrace", 2325 "EventBridge", 2326 "Googleanalytics", 2327 "Honeycode", 2328 "Infornexus", 2329 "LookoutMetrics", 2330 "Marketo", 2331 "Pardot", 2332 "Redshift", 2333 "S3", 2334 "SAPOData", 2335 "Salesforce", 2336 "Servicenow", 2337 "Singular", 2338 "Slack", 2339 "Snowflake", 2340 "Trendmicro", 2341 "Upsolver", 2342 "Veeva", 2343 "Zendesk", 2344 ] = Field(alias="connectorType") 2345 connection_mode: Literal["Private", "Public"] = Field(alias="connectionMode") 2346 connector_profile_config: ConnectorProfileConfigModel = Field( 2347 alias="connectorProfileConfig" 2348 ) 2349 kms_arn: Optional[str] = Field(default=None, alias="kmsArn") 2350 connector_label: Optional[str] = Field(default=None, alias="connectorLabel")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
2353class UpdateConnectorProfileRequestModel(BaseModel): 2354 connector_profile_name: str = Field(alias="connectorProfileName") 2355 connection_mode: Literal["Private", "Public"] = Field(alias="connectionMode") 2356 connector_profile_config: ConnectorProfileConfigModel = Field( 2357 alias="connectorProfileConfig" 2358 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
2361class CreateFlowRequestModel(BaseModel): 2362 flow_name: str = Field(alias="flowName") 2363 trigger_config: TriggerConfigModel = Field(alias="triggerConfig") 2364 source_flow_config: SourceFlowConfigModel = Field(alias="sourceFlowConfig") 2365 destination_flow_config_list: Sequence[DestinationFlowConfigModel] = Field( 2366 alias="destinationFlowConfigList" 2367 ) 2368 tasks: Sequence[TaskModel] = Field(alias="tasks") 2369 description: Optional[str] = Field(default=None, alias="description") 2370 kms_arn: Optional[str] = Field(default=None, alias="kmsArn") 2371 tags: Optional[Mapping[str, str]] = Field(default=None, alias="tags") 2372 metadata_catalog_config: Optional[MetadataCatalogConfigModel] = Field( 2373 default=None, alias="metadataCatalogConfig" 2374 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
2377class DescribeFlowResponseModel(BaseModel): 2378 flow_arn: str = Field(alias="flowArn") 2379 description: str = Field(alias="description") 2380 flow_name: str = Field(alias="flowName") 2381 kms_arn: str = Field(alias="kmsArn") 2382 flow_status: Literal[ 2383 "Active", "Deleted", "Deprecated", "Draft", "Errored", "Suspended" 2384 ] = Field(alias="flowStatus") 2385 flow_status_message: str = Field(alias="flowStatusMessage") 2386 source_flow_config: SourceFlowConfigModel = Field(alias="sourceFlowConfig") 2387 destination_flow_config_list: List[DestinationFlowConfigModel] = Field( 2388 alias="destinationFlowConfigList" 2389 ) 2390 last_run_execution_details: ExecutionDetailsModel = Field( 2391 alias="lastRunExecutionDetails" 2392 ) 2393 trigger_config: TriggerConfigModel = Field(alias="triggerConfig") 2394 tasks: List[TaskModel] = Field(alias="tasks") 2395 created_at: datetime = Field(alias="createdAt") 2396 last_updated_at: datetime = Field(alias="lastUpdatedAt") 2397 created_by: str = Field(alias="createdBy") 2398 last_updated_by: str = Field(alias="lastUpdatedBy") 2399 tags: Dict[str, str] = Field(alias="tags") 2400 metadata_catalog_config: MetadataCatalogConfigModel = Field( 2401 alias="metadataCatalogConfig" 2402 ) 2403 last_run_metadata_catalog_details: List[MetadataCatalogDetailModel] = Field( 2404 alias="lastRunMetadataCatalogDetails" 2405 ) 2406 schema_version: int = Field(alias="schemaVersion") 2407 response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs
2410class UpdateFlowRequestModel(BaseModel): 2411 flow_name: str = Field(alias="flowName") 2412 trigger_config: TriggerConfigModel = Field(alias="triggerConfig") 2413 source_flow_config: SourceFlowConfigModel = Field(alias="sourceFlowConfig") 2414 destination_flow_config_list: Sequence[DestinationFlowConfigModel] = Field( 2415 alias="destinationFlowConfigList" 2416 ) 2417 tasks: Sequence[TaskModel] = Field(alias="tasks") 2418 description: Optional[str] = Field(default=None, alias="description") 2419 metadata_catalog_config: Optional[MetadataCatalogConfigModel] = Field( 2420 default=None, alias="metadataCatalogConfig" 2421 )
Inherited Members
- pydantic.main.BaseModel
- dict
- json
- parse_obj
- parse_raw
- parse_file
- from_orm
- construct
- copy
- schema
- schema_json
- validate
- update_forward_refs