Class DataSourcesAsyncClient

java.lang.Object
com.azure.analytics.purview.scanning.DataSourcesAsyncClient

public final class DataSourcesAsyncClient extends Object
Initializes a new instance of the asynchronous PurviewScanningClient type.
  • Method Details

    • createOrUpdateWithResponse

      public Mono<Response<BinaryData>> createOrUpdateWithResponse(String dataSourceName, RequestOptions requestOptions)
      Creates or Updates a data source.

      Query Parameters

      Query Parameters
      NameTypeRequiredDescription
      apiVersionStringYesApi Version

      Request Body Schema

      
       {
           id: String
           name: String
           scans: [
               {
                   id: String
                   name: String
                   scanResults: [
                       {
                           parentId: String
                           id: String
                           resourceId: String
                           status: String
                           assetsDiscovered: Long
                           assetsClassified: Long
                           diagnostics: {
                               notifications: [
                                   {
                                       message: String
                                       code: Integer
                                   }
                               ]
                               exceptionCountMap: {
                                   String: int
                               }
                           }
                           startTime: String
                           queuedTime: String
                           pipelineStartTime: String
                           endTime: String
                           scanRulesetVersion: Integer
                           scanRulesetType: String(Custom/System)
                           scanLevelType: String(Full/Incremental)
                           errorMessage: String
                           error: {
                               code: String
                               message: String
                               target: String
                               details: [
                                   {
                                       code: String
                                       message: String
                                       target: String
                                       details: [
                                           (recursive schema, see above)
                                       ]
                                   }
                               ]
                           }
                           runType: String
                           dataSourceType: String(None/AzureSubscription/AzureResourceGroup/AzureSynapseWorkspace/AzureSynapse/AdlsGen1/AdlsGen2/AmazonAccount/AmazonS3/AmazonSql/AzureCosmosDb/AzureDataExplorer/AzureFileService/AzureSqlDatabase/AmazonPostgreSql/AzurePostgreSql/SqlServerDatabase/AzureSqlDatabaseManagedInstance/AzureSqlDataWarehouse/AzureMySql/AzureStorage/Teradata/Oracle/SapS4Hana/SapEcc/PowerBI)
                       }
                   ]
               }
           ]
       }
       

      Response Body Schema

      
       {
           id: String
           name: String
           scans: [
               {
                   id: String
                   name: String
                   scanResults: [
                       {
                           parentId: String
                           id: String
                           resourceId: String
                           status: String
                           assetsDiscovered: Long
                           assetsClassified: Long
                           diagnostics: {
                               notifications: [
                                   {
                                       message: String
                                       code: Integer
                                   }
                               ]
                               exceptionCountMap: {
                                   String: int
                               }
                           }
                           startTime: String
                           queuedTime: String
                           pipelineStartTime: String
                           endTime: String
                           scanRulesetVersion: Integer
                           scanRulesetType: String(Custom/System)
                           scanLevelType: String(Full/Incremental)
                           errorMessage: String
                           error: {
                               code: String
                               message: String
                               target: String
                               details: [
                                   {
                                       code: String
                                       message: String
                                       target: String
                                       details: [
                                           (recursive schema, see above)
                                       ]
                                   }
                               ]
                           }
                           runType: String
                           dataSourceType: String(None/AzureSubscription/AzureResourceGroup/AzureSynapseWorkspace/AzureSynapse/AdlsGen1/AdlsGen2/AmazonAccount/AmazonS3/AmazonSql/AzureCosmosDb/AzureDataExplorer/AzureFileService/AzureSqlDatabase/AmazonPostgreSql/AzurePostgreSql/SqlServerDatabase/AzureSqlDatabaseManagedInstance/AzureSqlDataWarehouse/AzureMySql/AzureStorage/Teradata/Oracle/SapS4Hana/SapEcc/PowerBI)
                       }
                   ]
               }
           ]
       }
       
      Parameters:
      dataSourceName - The dataSourceName parameter.
      requestOptions - The options to configure the HTTP request before HTTP client sends it.
      Returns:
      the response body along with Response on successful completion of Mono.
      Throws:
      HttpResponseException - thrown if the request is rejected by server.
    • getWithResponse

      public Mono<Response<BinaryData>> getWithResponse(String dataSourceName, RequestOptions requestOptions)
      Get a data source.

      Query Parameters

      Query Parameters
      NameTypeRequiredDescription
      apiVersionStringYesApi Version

      Response Body Schema

      
       {
           id: String
           name: String
           scans: [
               {
                   id: String
                   name: String
                   scanResults: [
                       {
                           parentId: String
                           id: String
                           resourceId: String
                           status: String
                           assetsDiscovered: Long
                           assetsClassified: Long
                           diagnostics: {
                               notifications: [
                                   {
                                       message: String
                                       code: Integer
                                   }
                               ]
                               exceptionCountMap: {
                                   String: int
                               }
                           }
                           startTime: String
                           queuedTime: String
                           pipelineStartTime: String
                           endTime: String
                           scanRulesetVersion: Integer
                           scanRulesetType: String(Custom/System)
                           scanLevelType: String(Full/Incremental)
                           errorMessage: String
                           error: {
                               code: String
                               message: String
                               target: String
                               details: [
                                   {
                                       code: String
                                       message: String
                                       target: String
                                       details: [
                                           (recursive schema, see above)
                                       ]
                                   }
                               ]
                           }
                           runType: String
                           dataSourceType: String(None/AzureSubscription/AzureResourceGroup/AzureSynapseWorkspace/AzureSynapse/AdlsGen1/AdlsGen2/AmazonAccount/AmazonS3/AmazonSql/AzureCosmosDb/AzureDataExplorer/AzureFileService/AzureSqlDatabase/AmazonPostgreSql/AzurePostgreSql/SqlServerDatabase/AzureSqlDatabaseManagedInstance/AzureSqlDataWarehouse/AzureMySql/AzureStorage/Teradata/Oracle/SapS4Hana/SapEcc/PowerBI)
                       }
                   ]
               }
           ]
       }
       
      Parameters:
      dataSourceName - The dataSourceName parameter.
      requestOptions - The options to configure the HTTP request before HTTP client sends it.
      Returns:
      a data source along with Response on successful completion of Mono.
      Throws:
      HttpResponseException - thrown if the request is rejected by server.
    • deleteWithResponse

      public Mono<Response<BinaryData>> deleteWithResponse(String dataSourceName, RequestOptions requestOptions)
      Deletes a data source.

      Query Parameters

      Query Parameters
      NameTypeRequiredDescription
      apiVersionStringYesApi Version

      Response Body Schema

      
       {
           id: String
           name: String
           scans: [
               {
                   id: String
                   name: String
                   scanResults: [
                       {
                           parentId: String
                           id: String
                           resourceId: String
                           status: String
                           assetsDiscovered: Long
                           assetsClassified: Long
                           diagnostics: {
                               notifications: [
                                   {
                                       message: String
                                       code: Integer
                                   }
                               ]
                               exceptionCountMap: {
                                   String: int
                               }
                           }
                           startTime: String
                           queuedTime: String
                           pipelineStartTime: String
                           endTime: String
                           scanRulesetVersion: Integer
                           scanRulesetType: String(Custom/System)
                           scanLevelType: String(Full/Incremental)
                           errorMessage: String
                           error: {
                               code: String
                               message: String
                               target: String
                               details: [
                                   {
                                       code: String
                                       message: String
                                       target: String
                                       details: [
                                           (recursive schema, see above)
                                       ]
                                   }
                               ]
                           }
                           runType: String
                           dataSourceType: String(None/AzureSubscription/AzureResourceGroup/AzureSynapseWorkspace/AzureSynapse/AdlsGen1/AdlsGen2/AmazonAccount/AmazonS3/AmazonSql/AzureCosmosDb/AzureDataExplorer/AzureFileService/AzureSqlDatabase/AmazonPostgreSql/AzurePostgreSql/SqlServerDatabase/AzureSqlDatabaseManagedInstance/AzureSqlDataWarehouse/AzureMySql/AzureStorage/Teradata/Oracle/SapS4Hana/SapEcc/PowerBI)
                       }
                   ]
               }
           ]
       }
       
      Parameters:
      dataSourceName - The dataSourceName parameter.
      requestOptions - The options to configure the HTTP request before HTTP client sends it.
      Returns:
      the response body along with Response on successful completion of Mono.
      Throws:
      HttpResponseException - thrown if the request is rejected by server.
    • listAll

      public PagedFlux<BinaryData> listAll(RequestOptions requestOptions)
      List data sources in Data catalog.

      Query Parameters

      Query Parameters
      NameTypeRequiredDescription
      apiVersionStringYesApi Version

      Response Body Schema

      
       {
           value: [
               {
                   id: String
                   name: String
                   scans: [
                       {
                           id: String
                           name: String
                           scanResults: [
                               {
                                   parentId: String
                                   id: String
                                   resourceId: String
                                   status: String
                                   assetsDiscovered: Long
                                   assetsClassified: Long
                                   diagnostics: {
                                       notifications: [
                                           {
                                               message: String
                                               code: Integer
                                           }
                                       ]
                                       exceptionCountMap: {
                                           String: int
                                       }
                                   }
                                   startTime: String
                                   queuedTime: String
                                   pipelineStartTime: String
                                   endTime: String
                                   scanRulesetVersion: Integer
                                   scanRulesetType: String(Custom/System)
                                   scanLevelType: String(Full/Incremental)
                                   errorMessage: String
                                   error: {
                                       code: String
                                       message: String
                                       target: String
                                       details: [
                                           {
                                               code: String
                                               message: String
                                               target: String
                                               details: [
                                                   (recursive schema, see above)
                                               ]
                                           }
                                       ]
                                   }
                                   runType: String
                                   dataSourceType: String(None/AzureSubscription/AzureResourceGroup/AzureSynapseWorkspace/AzureSynapse/AdlsGen1/AdlsGen2/AmazonAccount/AmazonS3/AmazonSql/AzureCosmosDb/AzureDataExplorer/AzureFileService/AzureSqlDatabase/AmazonPostgreSql/AzurePostgreSql/SqlServerDatabase/AzureSqlDatabaseManagedInstance/AzureSqlDataWarehouse/AzureMySql/AzureStorage/Teradata/Oracle/SapS4Hana/SapEcc/PowerBI)
                               }
                           ]
                       }
                   ]
               }
           ]
           nextLink: String
           count: Long
       }
       
      Parameters:
      requestOptions - The options to configure the HTTP request before HTTP client sends it.
      Returns:
      the response.
      Throws:
      HttpResponseException - thrown if the request is rejected by server.