Create Connection

datazone_create_connection

R Documentation

Creates a new connection

Description

Creates a new connection. In Amazon DataZone, a connection enables you to connect your resources (domains, projects, and environments) to external resources and services.

Usage

datazone_create_connection(awsLocation, clientToken, configurations,
  description, domainIdentifier, environmentIdentifier, name, props,
  enableTrustedIdentityPropagation, scope)

Arguments

awsLocation	The location where the connection is created.
clientToken	A unique, case-sensitive identifier that is provided to ensure the idempotency of the request.
configurations	The configurations of the connection.
description	A connection description.
domainIdentifier	[required] The ID of the domain where the connection is created.
environmentIdentifier	The ID of the environment where the connection is created.
name	[required] The connection name.
props	The connection props.
enableTrustedIdentityPropagation	Specifies whether the trusted identity propagation is enabled.
scope	The scope of the connection.

Value

A list with the following syntax:

list(
  connectionId = "string",
  configurations = list(
    list(
      classification = "string",
      properties = list(
        "string"
      )
    )
  ),
  description = "string",
  domainId = "string",
  domainUnitId = "string",
  environmentId = "string",
  name = "string",
  physicalEndpoints = list(
    list(
      awsLocation = list(
        accessRole = "string",
        awsAccountId = "string",
        awsRegion = "string",
        iamConnectionId = "string"
      ),
      glueConnectionName = "string",
      glueConnectionNames = list(
        "string"
      ),
      glueConnection = list(
        name = "string",
        description = "string",
        connectionType = "ATHENA"|"BIGQUERY"|"DATABRICKS"|"DOCUMENTDB"|"DYNAMODB"|"HYPERPOD"|"IAM"|"MYSQL"|"OPENSEARCH"|"ORACLE"|"POSTGRESQL"|"REDSHIFT"|"S3"|"SAPHANA"|"SNOWFLAKE"|"SPARK"|"SQLSERVER"|"TERADATA"|"VERTICA"|"WORKFLOWS_MWAA"|"AMAZON_Q"|"MLFLOW"|"VPC",
        matchCriteria = list(
          "string"
        ),
        connectionProperties = list(
          "string"
        ),
        sparkProperties = list(
          "string"
        ),
        athenaProperties = list(
          "string"
        ),
        pythonProperties = list(
          "string"
        ),
        physicalConnectionRequirements = list(
          subnetId = "string",
          subnetIdList = list(
            "string"
          ),
          securityGroupIdList = list(
            "string"
          ),
          availabilityZone = "string"
        ),
        creationTime = as.POSIXct(
          "2015-01-01"
        ),
        lastUpdatedTime = as.POSIXct(
          "2015-01-01"
        ),
        lastUpdatedBy = "string",
        status = "CREATING"|"CREATE_FAILED"|"DELETING"|"DELETE_FAILED"|"READY"|"UPDATING"|"UPDATE_FAILED"|"DELETED",
        statusReason = "string",
        lastConnectionValidationTime = as.POSIXct(
          "2015-01-01"
        ),
        authenticationConfiguration = list(
          authenticationType = "BASIC"|"OAUTH2"|"CUSTOM",
          secretArn = "string",
          oAuth2Properties = list(
            oAuth2GrantType = "AUTHORIZATION_CODE"|"CLIENT_CREDENTIALS"|"JWT_BEARER",
            oAuth2ClientApplication = list(
              userManagedClientApplicationClientId = "string",
              aWSManagedClientApplicationReference = "string"
            ),
            tokenUrl = "string",
            tokenUrlParametersMap = list(
              "string"
            ),
            authorizationCodeProperties = list(
              authorizationCode = "string",
              redirectUri = "string"
            ),
            oAuth2Credentials = list(
              userManagedClientApplicationClientSecret = "string",
              accessToken = "string",
              refreshToken = "string",
              jwtToken = "string"
            )
          )
        ),
        connectionSchemaVersion = 123,
        compatibleComputeEnvironments = list(
          "SPARK"|"ATHENA"|"PYTHON"
        )
      ),
      enableTrustedIdentityPropagation = TRUE|FALSE,
      host = "string",
      port = 123,
      protocol = "ATHENA"|"GLUE_INTERACTIVE_SESSION"|"HTTPS"|"JDBC"|"LIVY"|"ODBC"|"PRISM",
      stage = "string"
    )
  ),
  projectId = "string",
  props = list(
    athenaProperties = list(
      workgroupName = "string"
    ),
    glueProperties = list(
      status = "CREATING"|"CREATE_FAILED"|"DELETING"|"DELETE_FAILED"|"READY"|"UPDATING"|"UPDATE_FAILED"|"DELETED",
      errorMessage = "string"
    ),
    hyperPodProperties = list(
      clusterName = "string",
      clusterArn = "string",
      orchestrator = "EKS"|"SLURM"
    ),
    iamProperties = list(
      environmentId = "string",
      glueLineageSyncEnabled = TRUE|FALSE
    ),
    redshiftProperties = list(
      storage = list(
        clusterName = "string",
        workgroupName = "string"
      ),
      credentials = list(
        secretArn = "string",
        usernamePassword = list(
          password = "string",
          username = "string"
        )
      ),
      isProvisionedSecret = TRUE|FALSE,
      jdbcIamUrl = "string",
      jdbcUrl = "string",
      redshiftTempDir = "string",
      lineageSync = list(
        lineageJobId = "string",
        enabled = TRUE|FALSE,
        schedule = list(
          schedule = "string"
        )
      ),
      status = "CREATING"|"CREATE_FAILED"|"DELETING"|"DELETE_FAILED"|"READY"|"UPDATING"|"UPDATE_FAILED"|"DELETED",
      databaseName = "string"
    ),
    sparkEmrProperties = list(
      computeArn = "string",
      credentials = list(
        password = "string",
        username = "string"
      ),
      credentialsExpiration = as.POSIXct(
        "2015-01-01"
      ),
      governanceType = "AWS_MANAGED"|"USER_MANAGED",
      instanceProfileArn = "string",
      javaVirtualEnv = "string",
      livyEndpoint = "string",
      logUri = "string",
      pythonVirtualEnv = "string",
      runtimeRole = "string",
      trustedCertificatesS3Uri = "string",
      certificateData = "string",
      managedEndpointArn = "string",
      managedEndpointCredentials = list(
        id = "string",
        token = "string"
      )
    ),
    sparkGlueProperties = list(
      additionalArgs = list(
        connection = "string"
      ),
      glueConnectionName = "string",
      glueConnectionNames = list(
        "string"
      ),
      glueVersion = "string",
      idleTimeout = 123,
      javaVirtualEnv = "string",
      numberOfWorkers = 123,
      pythonVirtualEnv = "string",
      workerType = "string"
    ),
    s3Properties = list(
      s3Uri = "string",
      s3AccessGrantLocationId = "string",
      registerS3AccessGrantLocation = TRUE|FALSE,
      status = "CREATING"|"CREATE_FAILED"|"DELETING"|"DELETE_FAILED"|"READY"|"UPDATING"|"UPDATE_FAILED"|"DELETED",
      errorMessage = "string"
    ),
    amazonQProperties = list(
      isEnabled = TRUE|FALSE,
      profileArn = "string",
      authMode = "string"
    ),
    mlflowProperties = list(
      trackingServerArn = "string"
    ),
    workflowsMwaaProperties = list(
      mwaaEnvironmentName = "string"
    ),
    workflowsServerlessProperties = list(),
    lakehouseProperties = list(
      glueLineageSyncEnabled = TRUE|FALSE
    ),
    vpcProperties = list(
      vpcId = "string",
      subnetIds = list(
        "string"
      ),
      status = "CREATING"|"CREATE_FAILED"|"DELETING"|"DELETE_FAILED"|"READY"|"UPDATING"|"UPDATE_FAILED"|"DELETED",
      securityGroupId = "string",
      glueConnectionNames = list(
        "string"
      )
    )
  ),
  type = "ATHENA"|"BIGQUERY"|"DATABRICKS"|"DOCUMENTDB"|"DYNAMODB"|"HYPERPOD"|"IAM"|"MYSQL"|"OPENSEARCH"|"ORACLE"|"POSTGRESQL"|"REDSHIFT"|"S3"|"SAPHANA"|"SNOWFLAKE"|"SPARK"|"SQLSERVER"|"TERADATA"|"VERTICA"|"WORKFLOWS_MWAA"|"AMAZON_Q"|"MLFLOW"|"VPC",
  scope = "DOMAIN"|"PROJECT"
)

Request syntax

svc$create_connection(
  awsLocation = list(
    accessRole = "string",
    awsAccountId = "string",
    awsRegion = "string",
    iamConnectionId = "string"
  ),
  clientToken = "string",
  configurations = list(
    list(
      classification = "string",
      properties = list(
        "string"
      )
    )
  ),
  description = "string",
  domainIdentifier = "string",
  environmentIdentifier = "string",
  name = "string",
  props = list(
    athenaProperties = list(
      workgroupName = "string"
    ),
    glueProperties = list(
      glueConnectionInput = list(
        connectionProperties = list(
          "string"
        ),
        physicalConnectionRequirements = list(
          subnetId = "string",
          subnetIdList = list(
            "string"
          ),
          securityGroupIdList = list(
            "string"
          ),
          availabilityZone = "string"
        ),
        name = "string",
        description = "string",
        connectionType = "SNOWFLAKE"|"BIGQUERY"|"DOCUMENTDB"|"DYNAMODB"|"MYSQL"|"OPENSEARCH"|"ORACLE"|"POSTGRESQL"|"REDSHIFT"|"SAPHANA"|"SQLSERVER"|"TERADATA"|"VERTICA",
        matchCriteria = "string",
        validateCredentials = TRUE|FALSE,
        validateForComputeEnvironments = list(
          "SPARK"|"ATHENA"|"PYTHON"
        ),
        sparkProperties = list(
          "string"
        ),
        athenaProperties = list(
          "string"
        ),
        pythonProperties = list(
          "string"
        ),
        authenticationConfiguration = list(
          authenticationType = "BASIC"|"OAUTH2"|"CUSTOM",
          oAuth2Properties = list(
            oAuth2GrantType = "AUTHORIZATION_CODE"|"CLIENT_CREDENTIALS"|"JWT_BEARER",
            oAuth2ClientApplication = list(
              userManagedClientApplicationClientId = "string",
              aWSManagedClientApplicationReference = "string"
            ),
            tokenUrl = "string",
            tokenUrlParametersMap = list(
              "string"
            ),
            authorizationCodeProperties = list(
              authorizationCode = "string",
              redirectUri = "string"
            ),
            oAuth2Credentials = list(
              userManagedClientApplicationClientSecret = "string",
              accessToken = "string",
              refreshToken = "string",
              jwtToken = "string"
            )
          ),
          secretArn = "string",
          kmsKeyArn = "string",
          basicAuthenticationCredentials = list(
            userName = "string",
            password = "string"
          ),
          customAuthenticationCredentials = list(
            "string"
          )
        )
      )
    ),
    hyperPodProperties = list(
      clusterName = "string"
    ),
    iamProperties = list(
      glueLineageSyncEnabled = TRUE|FALSE
    ),
    redshiftProperties = list(
      storage = list(
        clusterName = "string",
        workgroupName = "string"
      ),
      databaseName = "string",
      host = "string",
      port = 123,
      credentials = list(
        secretArn = "string",
        usernamePassword = list(
          password = "string",
          username = "string"
        )
      ),
      lineageSync = list(
        enabled = TRUE|FALSE,
        schedule = list(
          schedule = "string"
        )
      )
    ),
    sparkEmrProperties = list(
      computeArn = "string",
      instanceProfileArn = "string",
      javaVirtualEnv = "string",
      logUri = "string",
      pythonVirtualEnv = "string",
      runtimeRole = "string",
      trustedCertificatesS3Uri = "string",
      managedEndpointArn = "string"
    ),
    sparkGlueProperties = list(
      additionalArgs = list(
        connection = "string"
      ),
      glueConnectionName = "string",
      glueConnectionNames = list(
        "string"
      ),
      glueVersion = "string",
      idleTimeout = 123,
      javaVirtualEnv = "string",
      numberOfWorkers = 123,
      pythonVirtualEnv = "string",
      workerType = "string"
    ),
    s3Properties = list(
      s3Uri = "string",
      s3AccessGrantLocationId = "string",
      registerS3AccessGrantLocation = TRUE|FALSE
    ),
    amazonQProperties = list(
      isEnabled = TRUE|FALSE,
      profileArn = "string",
      authMode = "string"
    ),
    mlflowProperties = list(
      trackingServerArn = "string"
    ),
    workflowsMwaaProperties = list(
      mwaaEnvironmentName = "string"
    ),
    workflowsServerlessProperties = list(),
    lakehouseProperties = list(
      glueLineageSyncEnabled = TRUE|FALSE
    ),
    vpcProperties = list(
      vpcId = "string",
      subnetIds = list(
        "string"
      ),
      securityGroupId = "string"
    )
  ),
  enableTrustedIdentityPropagation = TRUE|FALSE,
  scope = "DOMAIN"|"PROJECT"
)