New module: azure_rm_eventhub

plugins/module_utils/azure_rm_common.py

@@ -108,7 +108,8 @@ def default_api_version(self):
         'MySQLManagementClient': '2017-12-01',
         'MariaDBManagementClient': '2019-03-01',
         'ManagementLockClient': '2016-09-01',
-        'DataLakeStoreAccountManagementClient': '2016-11-01'
+        'DataLakeStoreAccountManagementClient': '2016-11-01',
+        'EventHubManagementClient': '2018-05-04'
     },
     '2019-03-01-hybrid': {
         'StorageManagementClient': '2017-10-01',
@@ -122,6 +123,7 @@ def default_api_version(self):
         'ManagementLockClient': '2016-09-01',
         'PolicyClient': '2016-12-01',
         'ResourceManagementClient': '2018-05-01',
+        'EventHubManagementClient': '2018-05-04',
         'SubscriptionClient': '2016-06-01',
         'DnsManagementClient': '2016-04-01',
         'KeyVaultManagementClient': '2016-10-01',
@@ -277,6 +279,7 @@ def default_api_version(self):
     from azure.mgmt.search import SearchManagementClient
     from azure.mgmt.datalake.store import DataLakeStoreAccountManagementClient
     import azure.mgmt.datalake.store.models as DataLakeStoreAccountModel
+    from azure.mgmt.eventhub import EventHubManagementClient
 
 except ImportError as exc:
     Authentication = object
@@ -364,6 +367,10 @@ def normalize_location_name(name):
         'package_name': 'trafficmanager',
         'expected_version': '0.50.0'
     },
+    'EventHubManagementClient': {
+        'package_name': 'azure-mgmt-eventhub',
+        'expected_version': '2.0.0'
+    },
 } if HAS_AZURE else {}
 
 
@@ -441,6 +448,7 @@ def __init__(self, derived_arg_spec, bypass_checks=False, no_log=False,
         self._recovery_services_backup_client = None
         self._search_client = None
         self._datalake_store_client = None
+        self._event_hub_client = None
 
         self.check_mode = self.module.check_mode
         self.api_profile = self.module.params.get('api_profile')
@@ -1327,6 +1335,16 @@ def datalake_store_client(self):
     def datalake_store_models(self):
         return DataLakeStoreAccountModel
 
+    @property
+    def event_hub_client(self):
+        self.log('Getting event hub client')
+        if not self._event_hub_client:
+            self._event_hub_client = self.get_mgmt_svc_client(
+                EventHubManagementClient,
+                base_url=self._cloud_environment.endpoints.resource_manager,
+                api_version='2018-05-04')
+        return self._event_hub_client
+
 
 class AzureSASAuthentication(Authentication):
     """Simple SAS Authentication.