2424from azext_datafactory .action import (
2525 AddFactoryVstsConfiguration ,
2626 AddFactoryGitHubConfiguration ,
27+ AddIdentity ,
28+ AddGitHubClientSecret ,
29+ AddManagedVirtualNetwork ,
2730 AddFolder ,
2831 AddFilters ,
29- AddOrderBy
32+ AddOrderBy ,
33+ AddPrivateLinkServiceConnectionState
3034)
3135
3236
@@ -57,12 +61,33 @@ def load_arguments(self, _):
5761 'GitHub repo information.' , arg_group = 'RepoConfiguration' )
5862 c .argument ('global_parameters' , type = validate_file_or_dict , help = 'List of parameters for factory. Expected '
5963 'value: json-string/@json-file.' )
64+ c .argument ('public_network_access' , arg_type = get_enum_type (['Enabled' , 'Disabled' ]), help = 'Whether or not '
65+ 'public network access is allowed for the data factory.' )
66+ c .argument ('key_name' , type = str , help = 'The name of the key in Azure Key Vault to use as Customer Managed Key.' ,
67+ arg_group = 'Encryption' )
68+ c .argument ('vault_base_url' , type = str , help = 'The url of the Azure Key Vault used for CMK.' ,
69+ arg_group = 'Encryption' )
70+ c .argument ('key_version' , type = str , help = 'The version of the key used for CMK. If not provided, latest version '
71+ 'will be used.' , arg_group = 'Encryption' )
72+ c .argument ('identity' , action = AddIdentity , nargs = '+' , help = 'User assigned identity to use to authenticate to '
73+ 'customer\' s key vault. If not provided Managed Service Identity will be used.' ,
74+ arg_group = 'Encryption' )
75+ c .argument ('type_' , options_list = ['--type' ], arg_type = get_enum_type (['SystemAssigned' , 'UserAssigned' ,
76+ 'SystemAssigned,UserAssigned' ]),
77+ help = 'The identity type.' , arg_group = 'Identity' )
78+ c .argument ('user_assigned_identities' , type = validate_file_or_dict , help = 'List of user assigned identities for '
79+ 'the factory. Expected value: json-string/@json-file.' , arg_group = 'Identity' )
6080
6181 with self .argument_context ('datafactory update' ) as c :
6282 c .argument ('resource_group_name' , resource_group_name_type )
6383 c .argument ('factory_name' , options_list = ['--name' , '-n' , '--factory-name' ], type = str , help = 'The factory name.' ,
6484 id_part = 'name' )
6585 c .argument ('tags' , tags_type )
86+ c .argument ('type_' , options_list = ['--type' ], arg_type = get_enum_type (['SystemAssigned' , 'UserAssigned' ,
87+ 'SystemAssigned,UserAssigned' ]),
88+ help = 'The identity type.' , arg_group = 'Identity' )
89+ c .argument ('user_assigned_identities' , type = validate_file_or_dict , help = 'List of user assigned identities for '
90+ 'the factory. Expected value: json-string/@json-file.' , arg_group = 'Identity' )
6691
6792 with self .argument_context ('datafactory delete' ) as c :
6893 c .argument ('resource_group_name' , resource_group_name_type )
@@ -98,6 +123,8 @@ def load_arguments(self, _):
98123 id_part = 'name' )
99124 c .argument ('git_hub_access_code' , type = str , help = 'GitHub access code.' )
100125 c .argument ('git_hub_client_id' , type = str , help = 'GitHub application client ID.' )
126+ c .argument ('git_hub_client_secret' , action = AddGitHubClientSecret , nargs = '+' , help = 'GitHub bring your own app '
127+ 'client secret information.' )
101128 c .argument ('git_hub_access_token_base_url' , type = str , help = 'GitHub access token base URL.' )
102129
103130 with self .argument_context ('datafactory integration-runtime list' ) as c :
@@ -133,6 +160,8 @@ def load_arguments(self, _):
133160 c .argument ('if_match' , type = str , help = 'ETag of the integration runtime entity. Should only be specified for '
134161 'update, for which it should match existing entity or can be * for unconditional update.' )
135162 c .argument ('description' , type = str , help = 'Integration runtime description.' )
163+ c .argument ('managed_virtual_network' , action = AddManagedVirtualNetwork , nargs = '+' , help = 'Managed Virtual '
164+ 'Network reference.' )
136165 c .argument ('compute_properties' , type = validate_file_or_dict , help = 'The compute resource for managed '
137166 'integration runtime. Expected value: json-string/@json-file.' , arg_group = 'Type Properties' )
138167 c .argument ('ssis_properties' , type = validate_file_or_dict , help = 'SSIS properties for managed integration '
@@ -386,8 +415,7 @@ def load_arguments(self, _):
386415 with self .argument_context ('datafactory pipeline update' ) as c :
387416 c .argument ('resource_group_name' , resource_group_name_type )
388417 c .argument ('factory_name' , type = str , help = 'The factory name.' , id_part = 'name' )
389- c .argument ('pipeline_name' , options_list = ['--name' , '-n' , '--pipeline-name' ], type = str , help = 'The pipeline '
390- 'name.' , id_part = 'child_name_1' )
418+ c .argument ('pipeline_name' , type = str , help = 'The pipeline name.' , id_part = 'child_name_1' )
391419 c .argument ('if_match' , type = str , help = 'ETag of the pipeline entity. Should only be specified for update, for '
392420 'which it should match existing entity or can be * for unconditional update.' )
393421 c .argument ('description' , type = str , help = 'The description of the pipeline.' )
@@ -404,8 +432,7 @@ def load_arguments(self, _):
404432 'json-string/@json-file.' )
405433 c .argument ('duration' , type = validate_file_or_dict , help = 'TimeSpan value, after which an Azure Monitoring '
406434 'Metric is fired. Expected value: json-string/@json-file.' , arg_group = 'Policy Elapsed Time Metric' )
407- c .argument ('folder_name' , type = str , help = 'The name of the folder that this Pipeline is in.' ,
408- arg_group = 'Folder' )
435+ c .argument ('name' , type = str , help = 'The name of the folder that this Pipeline is in.' , arg_group = 'Folder' )
409436 c .ignore ('pipeline' )
410437
411438 with self .argument_context ('datafactory pipeline delete' ) as c :
@@ -578,3 +605,52 @@ def load_arguments(self, _):
578605 c .argument ('factory_name' , type = str , help = 'The factory name.' , id_part = 'name' )
579606 c .argument ('trigger_name' , type = str , help = 'The trigger name.' , id_part = 'child_name_1' )
580607 c .argument ('run_id' , type = str , help = 'The pipeline run identifier.' , id_part = 'child_name_2' )
608+
609+ with self .argument_context ('datafactory private-end-point-connection list' ) as c :
610+ c .argument ('resource_group_name' , resource_group_name_type )
611+ c .argument ('factory_name' , type = str , help = 'The factory name.' )
612+
613+ with self .argument_context ('datafactory private-endpoint-connection show' ) as c :
614+ c .argument ('resource_group_name' , resource_group_name_type )
615+ c .argument ('factory_name' , type = str , help = 'The factory name.' , id_part = 'name' )
616+ c .argument ('private_endpoint_connection_name' , options_list = ['--name' , '-n' , '--private-endpoint-connection-nam'
617+ 'e' ], type = str , help = 'The private endpoint '
618+ 'connection name.' , id_part = 'child_name_1' )
619+ c .argument ('if_none_match' , type = str , help = 'ETag of the private endpoint connection entity. Should only be '
620+ 'specified for get. If the ETag matches the existing entity tag, or if * was provided, then no '
621+ 'content will be returned.' )
622+
623+ with self .argument_context ('datafactory private-endpoint-connection create' ) as c :
624+ c .argument ('resource_group_name' , resource_group_name_type )
625+ c .argument ('factory_name' , type = str , help = 'The factory name.' )
626+ c .argument ('private_endpoint_connection_name' , options_list = ['--name' , '-n' , '--private-endpoint-connection-nam'
627+ 'e' ], type = str , help = 'The private endpoint '
628+ 'connection name.' )
629+ c .argument ('if_match' , type = str , help = 'ETag of the private endpoint connection entity. Should only be '
630+ 'specified for update, for which it should match existing entity or can be * for unconditional '
631+ 'update.' )
632+ c .argument ('private_link_service_connection_state' , action = AddPrivateLinkServiceConnectionState , nargs = '+' ,
633+ help = 'The state of a private link connection' )
634+
635+ with self .argument_context ('datafactory private-endpoint-connection update' ) as c :
636+ c .argument ('resource_group_name' , resource_group_name_type )
637+ c .argument ('factory_name' , type = str , help = 'The factory name.' , id_part = 'name' )
638+ c .argument ('private_endpoint_connection_name' , options_list = ['--name' , '-n' , '--private-endpoint-connection-nam'
639+ 'e' ], type = str , help = 'The private endpoint '
640+ 'connection name.' , id_part = 'child_name_1' )
641+ c .argument ('if_match' , type = str , help = 'ETag of the private endpoint connection entity. Should only be '
642+ 'specified for update, for which it should match existing entity or can be * for unconditional '
643+ 'update.' )
644+ c .argument ('private_link_service_connection_state' , action = AddPrivateLinkServiceConnectionState , nargs = '+' ,
645+ help = 'The state of a private link connection' )
646+
647+ with self .argument_context ('datafactory private-endpoint-connection delete' ) as c :
648+ c .argument ('resource_group_name' , resource_group_name_type )
649+ c .argument ('factory_name' , type = str , help = 'The factory name.' , id_part = 'name' )
650+ c .argument ('private_endpoint_connection_name' , options_list = ['--name' , '-n' , '--private-endpoint-connection-nam'
651+ 'e' ], type = str , help = 'The private endpoint '
652+ 'connection name.' , id_part = 'child_name_1' )
653+
654+ with self .argument_context ('datafactory private-link-resource show' ) as c :
655+ c .argument ('resource_group_name' , resource_group_name_type )
656+ c .argument ('factory_name' , type = str , help = 'The factory name.' , id_part = 'name' )
0 commit comments