6
6
# Changes may cause incorrect behavior and will be lost if the code is regenerated.
7
7
# --------------------------------------------------------------------------
8
8
9
- from typing import TYPE_CHECKING
9
+ from copy import deepcopy
10
+ from typing import Any , Optional , TYPE_CHECKING
10
11
12
+ from azure .core .rest import HttpRequest , HttpResponse
11
13
from azure .mgmt .core import ARMPipelineClient
12
14
from msrest import Deserializer , Serializer
13
15
16
+ from . import models
17
+ from ._configuration import DataMigrationManagementClientConfiguration
18
+ from .operations import DatabaseMigrationsSqlDbOperations , DatabaseMigrationsSqlMiOperations , DatabaseMigrationsSqlVmOperations , FilesOperations , Operations , ProjectsOperations , ResourceSkusOperations , ServiceTasksOperations , ServicesOperations , SqlMigrationServicesOperations , TasksOperations , UsagesOperations
19
+
14
20
if TYPE_CHECKING :
15
21
# pylint: disable=unused-import,ungrouped-imports
16
- from typing import Any , Optional
17
-
18
22
from azure .core .credentials import TokenCredential
19
- from azure .core .pipeline .transport import HttpRequest , HttpResponse
20
-
21
- from ._configuration import DataMigrationManagementClientConfiguration
22
- from .operations import ResourceSkusOperations
23
- from .operations import ServicesOperations
24
- from .operations import TasksOperations
25
- from .operations import ServiceTasksOperations
26
- from .operations import ProjectsOperations
27
- from .operations import UsagesOperations
28
- from .operations import Operations
29
- from .operations import FilesOperations
30
- from . import models
31
-
32
23
33
- class DataMigrationManagementClient ( object ) :
24
+ class DataMigrationManagementClient :
34
25
"""Data Migration Client.
35
26
27
+ :ivar database_migrations_sql_db: DatabaseMigrationsSqlDbOperations operations
28
+ :vartype database_migrations_sql_db:
29
+ azure.mgmt.datamigration.operations.DatabaseMigrationsSqlDbOperations
30
+ :ivar database_migrations_sql_mi: DatabaseMigrationsSqlMiOperations operations
31
+ :vartype database_migrations_sql_mi:
32
+ azure.mgmt.datamigration.operations.DatabaseMigrationsSqlMiOperations
33
+ :ivar database_migrations_sql_vm: DatabaseMigrationsSqlVmOperations operations
34
+ :vartype database_migrations_sql_vm:
35
+ azure.mgmt.datamigration.operations.DatabaseMigrationsSqlVmOperations
36
+ :ivar operations: Operations operations
37
+ :vartype operations: azure.mgmt.datamigration.operations.Operations
38
+ :ivar sql_migration_services: SqlMigrationServicesOperations operations
39
+ :vartype sql_migration_services:
40
+ azure.mgmt.datamigration.operations.SqlMigrationServicesOperations
36
41
:ivar resource_skus: ResourceSkusOperations operations
37
42
:vartype resource_skus: azure.mgmt.datamigration.operations.ResourceSkusOperations
38
43
:ivar services: ServicesOperations operations
@@ -45,70 +50,71 @@ class DataMigrationManagementClient(object):
45
50
:vartype projects: azure.mgmt.datamigration.operations.ProjectsOperations
46
51
:ivar usages: UsagesOperations operations
47
52
:vartype usages: azure.mgmt.datamigration.operations.UsagesOperations
48
- :ivar operations: Operations operations
49
- :vartype operations: azure.mgmt.datamigration.operations.Operations
50
53
:ivar files: FilesOperations operations
51
54
:vartype files: azure.mgmt.datamigration.operations.FilesOperations
52
55
:param credential: Credential needed for the client to connect to Azure.
53
56
:type credential: ~azure.core.credentials.TokenCredential
54
- :param subscription_id: Identifier of the subscription.
57
+ :param subscription_id: Subscription ID that identifies an Azure subscription.
55
58
:type subscription_id: str
56
- :param str base_url: Service URL
57
- :keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
59
+ :param base_url: Service URL. Default value is 'https://management.azure.com'.
60
+ :type base_url: str
61
+ :keyword int polling_interval: Default waiting time between two polls for LRO operations if no
62
+ Retry-After header is present.
58
63
"""
59
64
60
65
def __init__ (
61
66
self ,
62
- credential , # type: "TokenCredential"
63
- subscription_id , # type: str
64
- base_url = None , # type: Optional[str]
65
- ** kwargs # type: Any
66
- ):
67
- # type: (...) -> None
68
- if not base_url :
69
- base_url = 'https://management.azure.com'
70
- self ._config = DataMigrationManagementClientConfiguration (credential , subscription_id , ** kwargs )
67
+ credential : "TokenCredential" ,
68
+ subscription_id : str ,
69
+ base_url : str = "https://management.azure.com" ,
70
+ ** kwargs : Any
71
+ ) -> None :
72
+ self ._config = DataMigrationManagementClientConfiguration (credential = credential , subscription_id = subscription_id , ** kwargs )
71
73
self ._client = ARMPipelineClient (base_url = base_url , config = self ._config , ** kwargs )
72
74
73
75
client_models = {k : v for k , v in models .__dict__ .items () if isinstance (v , type )}
74
76
self ._serialize = Serializer (client_models )
75
- self ._serialize .client_side_validation = False
76
77
self ._deserialize = Deserializer (client_models )
77
-
78
- self .resource_skus = ResourceSkusOperations (
79
- self ._client , self ._config , self ._serialize , self ._deserialize )
80
- self .services = ServicesOperations (
81
- self ._client , self ._config , self ._serialize , self ._deserialize )
82
- self .tasks = TasksOperations (
83
- self ._client , self ._config , self ._serialize , self ._deserialize )
84
- self .service_tasks = ServiceTasksOperations (
85
- self ._client , self ._config , self ._serialize , self ._deserialize )
86
- self .projects = ProjectsOperations (
87
- self ._client , self ._config , self ._serialize , self ._deserialize )
88
- self .usages = UsagesOperations (
89
- self ._client , self ._config , self ._serialize , self ._deserialize )
90
- self . operations = Operations (
91
- self . _client , self . _config , self . _serialize , self . _deserialize )
92
- self . files = FilesOperations (
93
- self . _client , self . _config , self . _serialize , self . _deserialize )
94
-
95
- def _send_request ( self , http_request , ** kwargs ):
96
- # type: (HttpRequest, Any ) -> HttpResponse
78
+ self . _serialize . client_side_validation = False
79
+ self .database_migrations_sql_db = DatabaseMigrationsSqlDbOperations ( self . _client , self . _config , self . _serialize , self . _deserialize )
80
+ self . database_migrations_sql_mi = DatabaseMigrationsSqlMiOperations ( self ._client , self ._config , self ._serialize , self ._deserialize )
81
+ self .database_migrations_sql_vm = DatabaseMigrationsSqlVmOperations ( self . _client , self . _config , self . _serialize , self . _deserialize )
82
+ self . operations = Operations ( self ._client , self ._config , self ._serialize , self ._deserialize )
83
+ self .sql_migration_services = SqlMigrationServicesOperations ( self . _client , self . _config , self . _serialize , self . _deserialize )
84
+ self . resource_skus = ResourceSkusOperations ( self ._client , self ._config , self ._serialize , self ._deserialize )
85
+ self .services = ServicesOperations ( self . _client , self . _config , self . _serialize , self . _deserialize )
86
+ self . tasks = TasksOperations ( self ._client , self ._config , self ._serialize , self ._deserialize )
87
+ self .service_tasks = ServiceTasksOperations ( self . _client , self . _config , self . _serialize , self . _deserialize )
88
+ self . projects = ProjectsOperations ( self ._client , self ._config , self ._serialize , self ._deserialize )
89
+ self .usages = UsagesOperations (self . _client , self . _config , self . _serialize , self . _deserialize )
90
+ self . files = FilesOperations ( self ._client , self ._config , self ._serialize , self ._deserialize )
91
+
92
+
93
+ def _send_request (
94
+ self ,
95
+ request , # type: HttpRequest
96
+ ** kwargs : Any
97
+ ) -> HttpResponse :
97
98
"""Runs the network request through the client's chained policies.
98
99
99
- :param http_request: The network request you want to make. Required.
100
- :type http_request: ~azure.core.pipeline.transport.HttpRequest
101
- :keyword bool stream: Whether the response payload will be streamed. Defaults to True.
100
+ >>> from azure.core.rest import HttpRequest
101
+ >>> request = HttpRequest("GET", "https://www.example.org/")
102
+ <HttpRequest [GET], url: 'https://www.example.org/'>
103
+ >>> response = client._send_request(request)
104
+ <HttpResponse: 200 OK>
105
+
106
+ For more information on this code flow, see https://aka.ms/azsdk/python/protocol/quickstart
107
+
108
+ :param request: The network request you want to make. Required.
109
+ :type request: ~azure.core.rest.HttpRequest
110
+ :keyword bool stream: Whether the response payload will be streamed. Defaults to False.
102
111
:return: The response of your network call. Does not do error handling on your response.
103
- :rtype: ~azure.core.pipeline.transport .HttpResponse
112
+ :rtype: ~azure.core.rest .HttpResponse
104
113
"""
105
- path_format_arguments = {
106
- 'subscriptionId' : self ._serialize .url ("self._config.subscription_id" , self ._config .subscription_id , 'str' ),
107
- }
108
- http_request .url = self ._client .format_url (http_request .url , ** path_format_arguments )
109
- stream = kwargs .pop ("stream" , True )
110
- pipeline_response = self ._client ._pipeline .run (http_request , stream = stream , ** kwargs )
111
- return pipeline_response .http_response
114
+
115
+ request_copy = deepcopy (request )
116
+ request_copy .url = self ._client .format_url (request_copy .url )
117
+ return self ._client .send_request (request_copy , ** kwargs )
112
118
113
119
def close (self ):
114
120
# type: () -> None
0 commit comments