Skip to content

Commit

Permalink
Add new module azure_rm_datafacotry (#840)
Browse files Browse the repository at this point in the history
* add new module azure_rm_datafacotry

* Fixed a sanity test failure

* update azure_rm_common.py

* fix dev sanity error

* Update azure_rm_datafactory_info.py

Update return key!

* Update azure_rm_datafactory_info.py

update azure_rm_datafactory_info return key!

* Update azure_rm_datafactory.py

Update azure_rm_datafactory.py return key!
  • Loading branch information
Fred-sun committed May 13, 2022
1 parent 82e252e commit 70feb11
Show file tree
Hide file tree
Showing 9 changed files with 831 additions and 3 deletions.
16 changes: 16 additions & 0 deletions plugins/module_utils/azure_rm_common.py
Original file line number Diff line number Diff line change
Expand Up @@ -275,6 +275,8 @@ def default_api_version(self):
import azure.mgmt.datalake.store.models as DataLakeStoreAccountModel
from azure.mgmt.notificationhubs import NotificationHubsManagementClient
from azure.mgmt.eventhub import EventHubManagementClient
from azure.mgmt.datafactory import DataFactoryManagementClient
import azure.mgmt.datafactory.models as DataFactoryModel
from azure.identity._credentials import client_secret, user_password

except ImportError as exc:
Expand Down Expand Up @@ -446,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._datafactory_client = None
self._notification_hub_client = None
self._event_hub_client = None

Expand Down Expand Up @@ -1381,6 +1384,19 @@ def event_hub_client(self):
api_version='2018-05-04')
return self._event_hub_client

@property
def datafactory_client(self):
self.log('Getting datafactory client...')
if not self._datafactory_client:
self._datafactory_client = self.get_mgmt_svc_client(DataFactoryManagementClient,
is_track2=True,
base_url=self._cloud_environment.endpoints.resource_manager)
return self._datafactory_client

@property
def datafactory_model(self):
return DataFactoryModel


class AzureSASAuthentication(Authentication):
"""Simple SAS Authentication.
Expand Down
Loading

0 comments on commit 70feb11

Please sign in to comment.