Add new module azure_rm_datalakestore

plugins/module_utils/azure_rm_common.py

@@ -104,7 +104,8 @@ def default_api_version(self):
         'PostgreSQLManagementClient': '2017-12-01',
         'MySQLManagementClient': '2017-12-01',
         'MariaDBManagementClient': '2019-03-01',
-        'ManagementLockClient': '2016-09-01'
+        'ManagementLockClient': '2016-09-01',
+        'DataLakeStoreAccountManagementClient': '2016-11-01'
     },
     '2019-03-01-hybrid': {
         'StorageManagementClient': '2017-10-01',
@@ -270,6 +271,8 @@ def default_api_version(self):
     from azure.mgmt.resource.locks import ManagementLockClient
     from azure.mgmt.recoveryservicesbackup import RecoveryServicesBackupClient
     import azure.mgmt.recoveryservicesbackup.models as RecoveryServicesBackupModels
+    from azure.mgmt.datalake.store import DataLakeStoreAccountManagementClient
+    import azure.mgmt.datalake.store.models as DataLakeStoreAccountModel
 
 except ImportError as exc:
     Authentication = object
@@ -432,6 +435,7 @@ def __init__(self, derived_arg_spec, bypass_checks=False, no_log=False,
         self._IoThub_client = None
         self._lock_client = None
         self._recovery_services_backup_client = None
+        self._datalake_store_client = None
 
         self.check_mode = self.module.check_mode
         self.api_profile = self.module.params.get('api_profile')
@@ -1296,6 +1300,19 @@ def recovery_services_backup_client(self):
     def recovery_services_backup_models(self):
         return RecoveryServicesBackupModels
 
+    @property
+    def datalake_store_client(self):
+        self.log('Getting datalake store client...')
+        if not self._datalake_store_client:
+            self._datalake_store_client = self.get_mgmt_svc_client(DataLakeStoreAccountManagementClient,
+                                                                   base_url=self._cloud_environment.endpoints.resource_manager,
+                                                                   api_version='2016-11-01')
+        return self._datalake_store_client
+
+    @property
+    def datalake_store_models(self):
+        return DataLakeStoreAccountModel
+
 
 class AzureSASAuthentication(Authentication):
     """Simple SAS Authentication.