src/storage-preview/azext_storage_preview/

# -------------------------------------------------------------------------------------------- # Copyright (c) Microsoft Corporation. All rights reserved. # Licensed under the MIT License. See License.txt in the project root for license information. # -------------------------------------------------------------------------------------------- from azure.cli.core.commands.parameters import (get_enum_type, get_three_state_flag, get_location_type, tags_type, edge_zone_type, file_type) from azure.cli.core.commands.validators import get_default_location_from_resource_group from azure.cli.core.local_context import LocalContextAttribute, LocalContextAction, ALL from ._validators import (get_datetime_type, validate_metadata, validate_bypass, validate_subnet, validate_azcopy_upload_destination_url, validate_azcopy_download_source_url, validate_azcopy_target_url, validate_included_datasets, validate_custom_domain, validate_blob_directory_download_source_url, validate_blob_directory_upload_destination_url, validate_storage_data_plane_list, validate_immutability_arguments, process_resource_group, validate_encryption_source, get_permission_help_string, get_permission_validator, add_progress_callback, validate_share_close_handle, PermissionScopeAddAction, SshPublicKeyAddAction) from .profiles import CUSTOM_MGMT_STORAGE, CUSTOM_DATA_STORAGE_FILESHARE def load_arguments(self, _): # pylint: disable=too-many-locals, too-many-statements from knack.arguments import CLIArgumentType from azure.cli.core.commands.parameters import get_resource_name_completion_list from .sdkutil import get_table_data_type from .completers import get_storage_name_completion_list, get_container_name_completions t_base_blob_service = self.get_sdk('blob.baseblobservice#BaseBlobService') t_file_service = self.get_sdk('file#FileService') t_table_service = get_table_data_type(self.cli_ctx, 'table', 'TableService') acct_name_type = CLIArgumentType(options_list=['--account-name', '-n'], help='The storage account name.', id_part='name', completer=get_resource_name_completion_list('Microsoft.Storage/storageAccounts'), local_context_attribute=LocalContextAttribute( name='storage_account_name', actions=[LocalContextAction.GET])) blob_name_type = CLIArgumentType(options_list=['--blob-name', '-b'], help='The blob name.', completer=get_storage_name_completion_list(t_base_blob_service, 'list_blobs', parent='container_name')) container_name_type = CLIArgumentType(options_list=['--container-name', '-c'], help='The container name.', completer=get_container_name_completions) directory_path_type = CLIArgumentType(options_list=['--directory-path', '-d'], help='The directory path name.', parent='container_name') share_name_type = CLIArgumentType(options_list=['--share-name', '-s'], help='The file share name.', completer=get_storage_name_completion_list(t_file_service, 'list_shares')) table_name_type = CLIArgumentType(options_list=['--table-name', '-t'], completer=get_storage_name_completion_list(t_table_service, 'list_tables')) large_file_share_type = CLIArgumentType( action='store_true', min_api='2019-04-01', help='Enable the capability to support large file shares with more than 5 TiB capacity for storage account.' 'Once the property is enabled, the feature cannot be disabled. Currently only supported for LRS and ' 'ZRS replication types, hence account conversions to geo-redundant accounts would not be possible. ' 'For more information, please refer to https://go.microsoft.com/fwlink/?linkid=2086047.') adds_type = CLIArgumentType(arg_type=get_three_state_flag(), min_api='2019-04-01', arg_group='Azure Files Identity Based Authentication', help='Enable Azure Files Active Directory Domain Service Authentication for ' 'storage account. When --enable-files-adds is set to true, Azure Active ' 'Directory Properties arguments must be provided.') aadkerb_type = CLIArgumentType(arg_type=get_three_state_flag(), min_api='2022-05-01', arg_group='Azure Files Identity Based Authentication', help='Enable Azure Files Active Directory Domain Service Kerberos Authentication ' 'for the storage account') aadds_type = CLIArgumentType(arg_type=get_three_state_flag(), min_api='2018-11-01', arg_group='Azure Files Identity Based Authentication', help='Enable Azure Active Directory Domain Services authentication for Azure Files') domain_name_type = CLIArgumentType(min_api='2019-04-01', arg_group="Azure Active Directory Properties", help="Specify the primary domain that the AD DNS server is authoritative for. " "Required when --enable-files-adds is set to True") net_bios_domain_name_type = CLIArgumentType(min_api='2019-04-01', arg_group="Azure Active Directory Properties", help="Specify the NetBIOS domain name. " "Required when --enable-files-adds is set to True") forest_name_type = CLIArgumentType(min_api='2019-04-01', arg_group="Azure Active Directory Properties", help="Specify the Active Directory forest to get. " "Required when --enable-files-adds is set to True") domain_guid_type = CLIArgumentType(min_api='2019-04-01', arg_group="Azure Active Directory Properties", help="Specify the domain GUID. Required when --enable-files-adds is set to True") domain_sid_type = CLIArgumentType(min_api='2019-04-01', arg_group="Azure Active Directory Properties", help="Specify the security identifier (SID). Required when --enable-files-adds " "is set to True") azure_storage_sid_type = CLIArgumentType(min_api='2019-04-01', arg_group="Azure Active Directory Properties", help="Specify the security identifier (SID) for Azure Storage. " "Required when --enable-files-adds is set to True") sam_account_name_type = CLIArgumentType(min_api='2021-08-01', arg_group="Azure Active Directory Properties", help="Specify the Active Directory SAMAccountName for Azure Storage.") t_account_type = self.get_models('ActiveDirectoryPropertiesAccountType', resource_type=CUSTOM_MGMT_STORAGE) account_type_type = CLIArgumentType(min_api='2021-08-01', arg_group="Azure Active Directory Properties", arg_type=get_enum_type(t_account_type), help="Specify the Active Directory account type for Azure Storage.") t_routing_choice = self.get_models('RoutingChoice', resource_type=CUSTOM_MGMT_STORAGE) routing_choice_type = CLIArgumentType( arg_group='Routing Preference', arg_type=get_enum_type(t_routing_choice), help='Routing Choice defines the kind of network routing opted by the user.', min_api='2019-06-01') publish_microsoft_endpoints_type = CLIArgumentType( arg_group='Routing Preference', arg_type=get_three_state_flag(), min_api='2019-06-01', help='A boolean flag which indicates whether microsoft routing storage endpoints are to be published.') publish_internet_endpoints_type = CLIArgumentType( arg_group='Routing Preference', arg_type=get_three_state_flag(), min_api='2019-06-01', help='A boolean flag which indicates whether internet routing storage endpoints are to be published.') allow_shared_key_access_type = CLIArgumentType( arg_type=get_three_state_flag(), options_list=['--allow-shared-key-access', '-k'], min_api='2019-04-01', help='Indicate whether the storage account permits requests to be authorized with the account access key via ' 'Shared Key. If false, then all requests, including shared access signatures, must be authorized with ' 'Azure Active Directory (Azure AD). The default value is null, which is equivalent to true.') sas_expiration_period_type = CLIArgumentType( options_list=['--sas-expiration-period', '--sas-exp'], min_api='2021-02-01', help='Expiration period of the SAS Policy assigned to the storage account, DD.HH:MM:SS.' ) key_expiration_period_in_days_type = CLIArgumentType( options_list=['--key-expiration-period-in-days', '--key-exp-days'], min_api='2021-02-01', type=int, help='Expiration period in days of the Key Policy assigned to the storage account' ) allow_cross_tenant_replication_type = CLIArgumentType( arg_type=get_three_state_flag(), options_list=['--allow-cross-tenant-replication', '-r'], min_api='2021-04-01', help='Allow or disallow cross AAD tenant object replication. The default interpretation is true for this ' 'property.') t_share_permission = self.get_models('DefaultSharePermission', resource_type=CUSTOM_MGMT_STORAGE) default_share_permission_type = CLIArgumentType( options_list=['--default-share-permission', '-d'], arg_type=get_enum_type(t_share_permission), min_api='2020-08-01-preview', arg_group='Azure Files Identity Based Authentication', help='Default share permission for users using Kerberos authentication if RBAC role is not assigned.') action_type = CLIArgumentType( help='The action of virtual network rule. Possible value is Allow.' ) immutability_period_since_creation_in_days_type = CLIArgumentType( options_list=['--immutability-period-in-days', '--immutability-period'], min_api='2021-06-01', help='The immutability period for the blobs in the container since the policy creation, in days.' ) account_immutability_policy_state_enum = self.get_sdk( 'models._storage_management_client_enums#AccountImmutabilityPolicyState', resource_type=CUSTOM_MGMT_STORAGE) immutability_policy_state_type = CLIArgumentType( arg_type=get_enum_type(account_immutability_policy_state_enum), options_list='--immutability-state', min_api='2021-06-01', help='Defines the mode of the policy. Disabled state disables the policy, ' 'Unlocked state allows increase and decrease of immutability retention time ' 'and also allows toggling allow-protected-append-write property, ' 'Locked state only allows the increase of the immutability retention time. ' 'A policy can only be created in a Disabled or Unlocked state and can be toggled between the ' 'two states. Only a policy in an Unlocked state can transition to a Locked state which cannot ' 'be reverted.') allowed_copy_scope_enum = self.get_sdk( 'models._storage_management_client_enums#AllowedCopyScope', resource_type=CUSTOM_MGMT_STORAGE ) allowed_copy_scope_type = CLIArgumentType( arg_type=get_enum_type(allowed_copy_scope_enum), options_list=['--allowed-copy-scope', '-s'], min_api='2021-08-01', help='Restrict copy to and from Storage Accounts within an AAD tenant or with Private Links to the same VNet' ) dns_endpoint_type_enum = self.get_sdk( 'models._storage_management_client_enums#DnsEndpointType', resource_type=CUSTOM_MGMT_STORAGE ) dns_endpoint_type_type = CLIArgumentType( arg_type=get_enum_type(dns_endpoint_type_enum), options_list=['--dns-endpoint-type', '--endpoint'], min_api='2021-09-01', help='Allow you to specify the type of endpoint. Set this to AzureDNSZone to create a large number of ' 'accounts in a single subscription, which creates accounts in an Azure DNS Zone and the endpoint URL ' 'will have an alphanumeric DNS Zone identifier.' ) public_network_access_enum = self.get_sdk('models._storage_management_client_enums#PublicNetworkAccess', resource_type=CUSTOM_MGMT_STORAGE) num_results_type = CLIArgumentType( default=5000, help='Specifies the maximum number of results to return. Provide "*" to return all.', validator=validate_storage_data_plane_list) acl_type = CLIArgumentType(options_list=['--acl-spec', '-a'], help='The ACL specification to set on the path in the format ' '"[default:]user|group|other|mask:[entity id or UPN]:r|-w|-x|-,' '[default:]user|group|other|mask:[entity id or UPN]:r|-w|-x|-,...". ' 'e.g."user::rwx,user:john.doe@contoso:rwx,group::r--,other::---,mask::rwx".') directory_type = CLIArgumentType(options_list=['--directory-name', '-d'], help='The directory name.', completer=get_storage_name_completion_list(t_file_service, 'list_directories_and_files', parent='share_name')) file_name_type = CLIArgumentType(options_list=['--file-name', '-f'], completer=get_storage_name_completion_list(t_file_service, 'list_directories_and_files', parent='share_name')) with self.argument_context('storage') as c: c.argument('container_name', container_name_type) c.argument('directory_name', directory_type) c.argument('share_name', share_name_type) c.argument('table_name', table_name_type) c.argument('retry_wait', options_list=('--retry-interval',)) c.ignore('progress_callback') c.argument('metadata', nargs='+', help='Metadata in space-separated key=value pairs. This overwrites any existing metadata.', validator=validate_metadata) c.argument('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) with self.argument_context('storage', arg_group='Precondition') as c: c.argument('if_modified_since', help='Alter only if modified since supplied UTC datetime (Y-m-d\'T\'H:M\'Z\')', type=get_datetime_type(False)) c.argument('if_unmodified_since', help='Alter only if unmodified since supplied UTC datetime (Y-m-d\'T\'H:M\'Z\')', type=get_datetime_type(False)) c.argument('if_match') c.argument('if_none_match') with self.argument_context('storage account create', resource_type=CUSTOM_MGMT_STORAGE) as c: t_account_type, t_sku_name, t_kind, t_tls_version = \ self.get_models('AccountType', 'SkuName', 'Kind', 'MinimumTlsVersion', resource_type=CUSTOM_MGMT_STORAGE) t_identity_type = self.get_models('IdentityType', resource_type=CUSTOM_MGMT_STORAGE) c.register_common_storage_account_options() c.argument('location', get_location_type(self.cli_ctx), validator=get_default_location_from_resource_group) c.argument('account_type', help='The storage account type', arg_type=get_enum_type(t_account_type)) c.argument('account_name', acct_name_type, options_list=['--name', '-n'], completer=None, local_context_attribute=LocalContextAttribute( name='storage_account_name', actions=[LocalContextAction.SET], scopes=[ALL])) c.argument('kind', help='Indicate the type of storage account.', arg_type=get_enum_type(t_kind), default='StorageV2' if self.cli_ctx.cloud.profile == 'latest' else 'Storage') c.argument('https_only', arg_type=get_three_state_flag(), min_api='2019-04-01', help='Allow https traffic only to storage service if set to true. The default value is true.') c.argument('https_only', arg_type=get_three_state_flag(), max_api='2018-11-01', help='Allow https traffic only to storage service if set to true. The default value is false.') c.argument('tags', tags_type) c.argument('custom_domain', help='User domain assigned to the storage account. Name is the CNAME source.') c.argument('sku', help='The storage account SKU.', arg_type=get_enum_type(t_sku_name, default='standard_ragrs')) c.argument('enable_sftp', arg_type=get_three_state_flag(), min_api='2021-08-01', help='Enable Secure File Transfer Protocol.') c.argument('enable_local_user', arg_type=get_three_state_flag(), min_api='2021-08-01', help='Enable local user features.') c.argument('enable_files_aadds', aadds_type) c.argument('enable_files_adds', adds_type) c.argument('enable_files_aadkerb', aadkerb_type) c.argument('enable_large_file_share', arg_type=large_file_share_type) c.argument('domain_name', domain_name_type) c.argument('net_bios_domain_name', net_bios_domain_name_type) c.argument('forest_name', forest_name_type) c.argument('domain_guid', domain_guid_type) c.argument('domain_sid', domain_sid_type) c.argument('azure_storage_sid', azure_storage_sid_type) c.argument('sam_account_name', sam_account_name_type) c.argument('account_type', account_type_type) c.argument('enable_hierarchical_namespace', arg_type=get_three_state_flag(), options_list=['--enable-hierarchical-namespace', '--hns', c.deprecate(target='--hierarchical-namespace', redirect='--hns', hide=True)], help=" Allow the blob service to exhibit filesystem semantics. This property can be enabled only " "when storage account kind is StorageV2.", min_api='2018-02-01') c.argument('encryption_key_type_for_table', arg_type=get_enum_type(['Account', 'Service']), help='Set the encryption key type for Table service. "Account": Table will be encrypted ' 'with account-scoped encryption key. "Service": Table will always be encrypted with ' 'service-scoped keys. Currently the default encryption key type is "Service".', min_api='2019-06-01', options_list=['--encryption-key-type-for-table', '-t']) c.argument('encryption_key_type_for_queue', arg_type=get_enum_type(['Account', 'Service']), help='Set the encryption key type for Queue service. "Account": Queue will be encrypted ' 'with account-scoped encryption key. "Service": Queue will always be encrypted with ' 'service-scoped keys. Currently the default encryption key type is "Service".', min_api='2019-06-01', options_list=['--encryption-key-type-for-queue', '-q']) c.argument('routing_choice', routing_choice_type) c.argument('publish_microsoft_endpoints', publish_microsoft_endpoints_type) c.argument('publish_internet_endpoints', publish_internet_endpoints_type) c.argument('require_infrastructure_encryption', options_list=['--require-infrastructure-encryption', '-i'], arg_type=get_three_state_flag(), help='A boolean indicating whether or not the service applies a secondary layer of encryption with ' 'platform managed keys for data at rest.') c.argument('allow_blob_public_access', arg_type=get_three_state_flag(), min_api='2019-04-01', help='Allow or disallow public access to all blobs or containers in the storage account. ' 'The default value for this property is null, which is equivalent to true. When true, containers ' 'in the account may be configured for public access. Note that setting this property to true does ' 'not enable anonymous access to any data in the account. The additional step of configuring the ' 'public access setting for a container is required to enable anonymous access.') c.argument('min_tls_version', arg_type=get_enum_type(t_tls_version), help='The minimum TLS version to be permitted on requests to storage. ' 'The default interpretation is TLS 1.0 for this property') c.argument('allow_shared_key_access', allow_shared_key_access_type) c.argument('edge_zone', edge_zone_type, min_api='2020-08-01-preview') c.argument('identity_type', arg_type=get_enum_type(t_identity_type), arg_group='Identity', help='The identity type.') c.argument('user_identity_id', arg_group='Identity', help='The key is the ARM resource identifier of the identity. Only 1 User Assigned identity is ' 'permitted here.') c.argument('key_expiration_period_in_days', key_expiration_period_in_days_type, is_preview=True) c.argument('sas_expiration_period', sas_expiration_period_type, is_preview=True) c.argument('allow_cross_tenant_replication', allow_cross_tenant_replication_type) c.argument('default_share_permission', default_share_permission_type) c.argument('enable_nfs_v3', arg_type=get_three_state_flag(), min_api='2021-01-01', help='NFS 3.0 protocol support enabled if sets to true.') c.argument('enable_alw', arg_type=get_three_state_flag(), min_api='2021-06-01', help='The account level immutability property. The property is immutable and can only be set to true' ' at the account creation time. When set to true, it enables object level immutability for all ' 'the containers in the account by default.', arg_group='Account Level Immutability', validator=validate_immutability_arguments) c.argument('immutability_period_since_creation_in_days', arg_type=immutability_period_since_creation_in_days_type, arg_group='Account Level Immutability', validator=validate_immutability_arguments) c.argument('immutability_policy_state', arg_type=immutability_policy_state_type, arg_group='Account Level Immutability', validator=validate_immutability_arguments) c.argument('allow_protected_append_writes', arg_type=get_three_state_flag(), options_list=['--allow-protected-append-writes', '--allow-append', '-w'], min_api='2021-06-01', help='This property can only be changed for disabled and unlocked time-based retention policies. ' 'When enabled, new blocks can be written to an append blob while maintaining immutability ' 'protection and compliance. Only new blocks can be added and any existing blocks cannot be ' 'modified or deleted.', arg_group='Account Level Immutability', validator=validate_immutability_arguments) c.argument('allowed_copy_scope', arg_type=allowed_copy_scope_type) c.argument('dns_endpoint_type', arg_type=dns_endpoint_type_type) c.argument('public_network_access', arg_type=get_enum_type(public_network_access_enum), min_api='2021-06-01', help='Enable or disable public network access to the storage account. ' 'Possible values include: `Enabled` or `Disabled`.') c.argument('enable_extended_groups', arg_type=get_three_state_flag(), is_preview=True, help='Enable extended group support with local users feature, if set to true.') with self.argument_context('storage account update', resource_type=CUSTOM_MGMT_STORAGE) as c: t_tls_version = self.get_models('MinimumTlsVersion', resource_type=CUSTOM_MGMT_STORAGE) t_identity_type = self.get_models('IdentityType', resource_type=CUSTOM_MGMT_STORAGE) c.register_common_storage_account_options() c.argument('sku', arg_type=get_enum_type(t_sku_name), help='Note that the SKU name cannot be updated to Standard_ZRS, Premium_LRS or Premium_ZRS, ' 'nor can accounts of those SKU names be updated to any other value') c.argument('custom_domain', help='User domain assigned to the storage account. Name is the CNAME source. Use "" to clear ' 'existing value.', validator=validate_custom_domain) c.argument('use_subdomain', help='Specify whether to use indirect CNAME validation.', arg_type=get_enum_type(['true', 'false'])) c.argument('tags', tags_type, default=None) c.argument('enable_sftp', arg_type=get_three_state_flag(), min_api='2021-08-01', help='Enable Secure File Transfer Protocol.') c.argument('enable_local_user', arg_type=get_three_state_flag(), min_api='2021-08-01', help='Enable local user features.') c.argument('enable_files_aadds', aadds_type) c.argument('enable_files_adds', adds_type) c.argument('enable_files_aadkerb', aadkerb_type) c.argument('enable_large_file_share', arg_type=large_file_share_type) c.argument('domain_name', domain_name_type) c.argument('net_bios_domain_name', net_bios_domain_name_type) c.argument('forest_name', forest_name_type) c.argument('domain_guid', domain_guid_type) c.argument('domain_sid', domain_sid_type) c.argument('azure_storage_sid', azure_storage_sid_type) c.argument('sam_account_name', sam_account_name_type) c.argument('account_type', account_type_type) c.argument('routing_choice', routing_choice_type) c.argument('publish_microsoft_endpoints', publish_microsoft_endpoints_type) c.argument('publish_internet_endpoints', publish_internet_endpoints_type) c.argument('allow_blob_public_access', arg_type=get_three_state_flag(), min_api='2019-04-01', help='Allow or disallow public access to all blobs or containers in the storage account. ' 'The default value for this property is null, which is equivalent to true. When true, containers ' 'in the account may be configured for public access. Note that setting this property to true does ' 'not enable anonymous access to any data in the account. The additional step of configuring the ' 'public access setting for a container is required to enable anonymous access.') c.argument('min_tls_version', arg_type=get_enum_type(t_tls_version), help='The minimum TLS version to be permitted on requests to storage. ' 'The default interpretation is TLS 1.0 for this property') c.argument('allow_shared_key_access', allow_shared_key_access_type) c.argument('identity_type', arg_type=get_enum_type(t_identity_type), arg_group='Identity', help='The identity type.') c.argument('user_identity_id', arg_group='Identity', help='The key is the ARM resource identifier of the identity. Only 1 User Assigned identity is ' 'permitted here.') c.argument('key_expiration_period_in_days', key_expiration_period_in_days_type, is_preview=True) c.argument('sas_expiration_period', sas_expiration_period_type, is_preview=True) c.argument('allow_cross_tenant_replication', allow_cross_tenant_replication_type) c.argument('default_share_permission', default_share_permission_type) c.argument('immutability_period_since_creation_in_days', arg_type=immutability_period_since_creation_in_days_type, arg_group='Account Level Immutability') c.argument('immutability_policy_state', arg_type=immutability_policy_state_type, arg_group='Account Level Immutability') c.argument('allow_protected_append_writes', arg_type=get_three_state_flag(), options_list=['--allow-protected-append-writes', '--allow-append', '-w'], min_api='2021-06-01', help='This property can only be changed for disabled and unlocked time-based retention policies. ' 'When enabled, new blocks can be written to an append blob while maintaining immutability ' 'protection and compliance. Only new blocks can be added and any existing blocks cannot be ' 'modified or deleted.', arg_group='Account Level Immutability') c.argument('allowed_copy_scope', arg_type=allowed_copy_scope_type) c.argument('public_network_access', arg_type=get_enum_type(public_network_access_enum), min_api='2021-06-01', help='Enable or disable public network access to the storage account. ' 'Possible values include: `Enabled` or `Disabled`.') c.argument('account_name', acct_name_type, options_list=['--name', '-n']) c.argument('resource_group_name', required=False, validator=process_resource_group) c.argument('enable_extended_groups', arg_type=get_three_state_flag(), help='Enable extended group support with local users feature, if set to true.') for scope in ['storage account create', 'storage account update']: with self.argument_context(scope, arg_group='Customer managed key', min_api='2017-06-01', resource_type=CUSTOM_MGMT_STORAGE) as c: t_key_source = self.get_models('KeySource', resource_type=CUSTOM_MGMT_STORAGE) c.argument('encryption_key_name', help='The name of the KeyVault key.', ) c.argument('encryption_key_vault', help='The Uri of the KeyVault.') c.argument('encryption_key_version', help='The version of the KeyVault key to use, which will opt out of implicit key rotation. ' 'Please use "" to opt in key auto-rotation again.') c.argument('encryption_key_source', arg_type=get_enum_type(t_key_source), help='The default encryption key source', validator=validate_encryption_source) c.argument('key_vault_user_identity_id', options_list=['--key-vault-user-identity-id', '-u'], min_api='2021-01-01', help='Resource identifier of the UserAssigned identity to be associated with server-side ' 'encryption on the storage account.') c.argument('federated_identity_client_id', options_list=['--key-vault-federated-client-id', '-f'], min_api='2021-08-01', help='ClientId of the multi-tenant application to be used ' 'in conjunction with the user-assigned identity for ' 'cross-tenant customer-managed-keys server-side encryption on the storage account.') for scope in ['storage account create', 'storage account update']: with self.argument_context(scope, resource_type=CUSTOM_MGMT_STORAGE, min_api='2017-06-01', arg_group='Network Rule') as c: t_bypass, t_default_action = self.get_models('Bypass', 'DefaultAction', resource_type=CUSTOM_MGMT_STORAGE) c.argument('bypass', nargs='+', validator=validate_bypass, arg_type=get_enum_type(t_bypass), help='Bypass traffic for space-separated uses.') c.argument('default_action', arg_type=get_enum_type(t_default_action), help='Default action to apply when no rule matches.') c.argument('subnet', help='Name or ID of subnet. If name is supplied, `--vnet-name` must be supplied.') c.argument('vnet_name', help='Name of a virtual network.', validator=validate_subnet) c.argument('action', action_type) with self.argument_context('storage blob service-properties update') as c: c.argument('delete_retention', arg_type=get_three_state_flag(), arg_group='Soft Delete', help='Enable soft-delete.') c.argument('days_retained', type=int, arg_group='Soft Delete', help='Number of days that soft-deleted blob will be retained. Must be in range [1,365].') c.argument('static_website', arg_group='Static Website', arg_type=get_three_state_flag(), help='Enable static-website.') c.argument('index_document', help='Represents the name of the index document. This is commonly "index.html".', arg_group='Static Website') c.argument('error_document_404_path', options_list=['--404-document'], arg_group='Static Website', help='Represent the path to the error document that should be shown when an error 404 is issued,' ' in other words, when a browser requests a page that does not exist.') with self.argument_context('storage azcopy blob upload') as c: c.extra('destination_container', options_list=['--container', '-c'], required=True, help='The upload destination container.') c.extra('destination_path', options_list=['--destination', '-d'], validator=validate_azcopy_upload_destination_url, help='The upload destination path.') c.argument('source', options_list=['--source', '-s'], help='The source file path to upload from.') c.argument('recursive', options_list=['--recursive', '-r'], action='store_true', help='Recursively upload blobs.') c.ignore('destination') with self.argument_context('storage azcopy blob download') as c: c.extra('source_container', options_list=['--container', '-c'], required=True, help='The download source container.') c.extra('source_path', options_list=['--source', '-s'], validator=validate_azcopy_download_source_url, help='The download source path.') c.argument('destination', options_list=['--destination', '-d'], help='The destination file path to download to.') c.argument('recursive', options_list=['--recursive', '-r'], action='store_true', help='Recursively download blobs.') c.ignore('source') with self.argument_context('storage azcopy blob delete') as c: c.extra('target_container', options_list=['--container', '-c'], required=True, help='The delete target container.') c.extra('target_path', options_list=['--target', '-t'], validator=validate_azcopy_target_url, help='The delete target path.') c.argument('recursive', options_list=['--recursive', '-r'], action='store_true', help='Recursively delete blobs.') c.ignore('target') with self.argument_context('storage azcopy blob sync') as c: c.extra('destination_container', options_list=['--container', '-c'], required=True, help='The sync destination container.') c.extra('destination_path', options_list=['--destination', '-d'], validator=validate_azcopy_upload_destination_url, help='The sync destination path.') c.argument('source', options_list=['--source', '-s'], help='The source file path to sync from.') c.ignore('destination') with self.argument_context('storage azcopy run-command') as c: c.positional('command_args', help='Command to run using azcopy. Please start commands with "azcopy ".') with self.argument_context('storage blob access') as c: c.argument('path', blob_name_type) with self.argument_context('storage blob access set') as c: c.argument('acl', acl_type, required=True,) c.ignore('owner', 'group', 'permissions') with self.argument_context('storage blob access update') as c: c.argument('acl', acl_type) c.argument('owner', help='The owning user for the directory.') c.argument('group', help='The owning group for the directory.') c.argument('permissions', help='The POSIX access permissions for the file owner,' 'the file owning group, and others. Both symbolic (rwxrw-rw-) and 4-digit ' 'octal notation (e.g. 0766) are supported.') with self.argument_context('storage blob move') as c: from ._validators import validate_move_file c.argument('source_path', options_list=['--source-blob', '-s'], validator=validate_move_file, help="The source blob name. It should be an absolute path under the container. e.g." "'topdir1/dirsubfoo'.") c.argument('new_path', options_list=['--destination-blob', '-d'], help="The destination blob name. It should be an absolute path under the container. e.g." "'topdir1/dirbar'.") c.argument('container_name', container_name_type) c.ignore('mode') c.ignore('marker') with self.argument_context('storage blob directory') as c: c.argument('directory_path', directory_path_type) c.argument('container_name', container_name_type) with self.argument_context('storage blob directory access') as c: c.argument('path', directory_path_type) with self.argument_context('storage blob directory access set') as c: c.argument('acl', acl_type, required=True) c.ignore('owner', 'group', 'permissions') with self.argument_context('storage blob directory access update') as c: c.argument('acl', acl_type) c.argument('owner', help='The owning user for the directory.') c.argument('group', help='The owning group for the directory.') c.argument('permissions', help='The POSIX access permissions for the file owner,' 'the file owning group, and others. Both symbolic (rwxrw-rw-) and 4-digit ' 'octal notation (e.g. 0766) are supported.') with self.argument_context('storage blob directory create') as c: from ._validators import validate_directory_name c.argument('posix_permissions', options_list=['--permissions']) c.argument('posix_umask', options_list=['--umask'], default='0027', help='Optional and only valid if Hierarchical Namespace is enabled for the account. ' 'The umask restricts permission settings for file and directory, and will only be applied when ' 'default Acl does not exist in parent directory. If the umask bit has set, it means that the ' 'corresponding permission will be disabled. In this way, the resulting permission is given by ' 'p & ^u, where p is the permission and u is the umask. Only 4-digit octal notation (e.g. 0022) ' 'is supported here.') c.argument('directory_path', directory_path_type, validator=validate_directory_name) with self.argument_context('storage blob directory download') as c: c.extra('source_container', options_list=['--container', '-c'], required=True, help='The download source container.') c.extra('source_path', options_list=['--source-path', '-s'], required=True, validator=validate_blob_directory_download_source_url, help='The download source directory path. It should be an absolute path to container.') c.argument('destination', options_list=['--destination-path', '-d'], help='The destination local directory path to download.') c.argument('recursive', options_list=['--recursive', '-r'], action='store_true', help='Recursively download blobs. If enabled, all the blobs including the blobs in subdirectories ' 'will be downloaded.') c.ignore('source') with self.argument_context('storage blob directory exists') as c: c.argument('blob_name', directory_path_type, required=True) with self.argument_context('storage blob directory list') as c: c.argument('include', validator=validate_included_datasets, default='mc') c.argument('num_results', arg_type=num_results_type) with self.argument_context('storage blob directory metadata') as c: c.argument('blob_name', directory_path_type) with self.argument_context('storage blob directory move') as c: from ._validators import validate_move_directory c.argument('new_path', options_list=['--destination-path', '-d'], help='The destination blob directory path. It can be a directory or subdirectory name, e.g. dir, ' 'dir/subdir. If the destination path exists and is empty, the source will be moved into the ' 'destination path. If the destination path does not exist, the destination path will be created' ' and overwritten by the source. To control the move operation for nonempty path, you can use ' '--move-mode to determine its behavior.') c.argument('source_path', options_list=['--source-path', '-s'], help='The source blob directory path.', validator=validate_move_directory) c.argument('lease_id', options_list=['--lease-id'], help='A lease ID for destination directory_path. The destination directory_path must have an active ' 'lease and the lease ID must match.') c.argument('mode', options_list=['--move-mode'], arg_type=get_enum_type(["legacy", "posix"]), default="posix", help="Valid only when namespace is enabled. This parameter determines the behavior " "of the move operation. If the destination directory is empty, for both two mode, " "the destination directory will be overwritten. But if the destination directory is not empty, " "in legacy mode the move operation will fail and in posix mode, the source directory will be " "moved into the destination directory. ") with self.argument_context('storage blob directory show') as c: c.argument('directory_name', directory_path_type) c.argument('container_name', container_name_type) # c.argument('snapshot', help='The snapshot parameter is an opaque DateTime value that, ' # 'when present, specifies the directory snapshot to retrieve.') c.ignore('snapshot') c.argument('lease_id', help='Required if the blob has an active lease.') c.argument('if_match', help="An ETag value, or the wildcard character (*). Specify this header to perform the" "operation only if the resource's ETag matches the value specified") c.argument('if_none_match', help="An ETag value, or the wildcard character (*). Specify this header to perform" "the operation only if the resource's ETag does not match the value specified. Specify the wildcard" "character (*) to perform the operation only if the resource does not exist, and fail the operation" "if it does exist.") with self.argument_context('storage blob directory upload') as c: c.extra('destination_container', options_list=['--container', '-c'], required=True, help='The upload destination container.') c.extra('destination_path', options_list=['--destination-path', '-d'], required=True, validator=validate_blob_directory_upload_destination_url, help='The upload destination directory path. It should be an absolute path to container. If the ' 'specified destination path does not exist, a new directory path will be created.') c.argument('source', options_list=['--source', '-s'], help='The source file path to upload from.') c.argument('recursive', options_list=['--recursive', '-r'], action='store_true', help='Recursively upload blobs. If enabled, all the blobs including the blobs in subdirectories will' ' be uploaded.') c.ignore('destination') from argcomplete.completers import FilesCompleter from knack.arguments import ignore_type with self.argument_context('storage share') as c: c.argument('share_name', share_name_type, options_list=('--name', '-n')) with self.argument_context('storage share list-handle') as c: c.register_path_argument(default_file_param="", fileshare=True) c.extra('share_name', share_name_type, options_list=('--name', '-n'), required=True) c.extra('marker', help='An opaque continuation token. This value can be retrieved from the ' 'next_marker field of a previous generator object if max_results was ' 'specified and that generator has finished enumerating results. If ' 'specified, this generator will begin returning results from the point ' 'where the previous generator stopped.') c.extra('num_results', options_list='--max-results', type=int, help='Specifies the maximum number of handles taken on files and/or directories ' 'to return. If the request does not specify max_results or specifies a ' 'value greater than 5,000, the server will return up to 5,000 items. ' 'Setting max_results to a value less than or equal to zero results in ' 'error response code 400 (Bad Request).') c.extra('recursive', arg_type=get_three_state_flag(), help='Boolean that specifies if operation should apply to the directory specified in the URI, ' 'its files, with its subdirectories and their files.') c.extra('snapshot', help="A string that represents the snapshot version, if applicable.") c.extra('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) with self.argument_context('storage share close-handle') as c: c.register_path_argument(default_file_param="", fileshare=True) c.extra('share_name', share_name_type, options_list=('--name', '-n'), required=True) c.extra('recursive', arg_type=get_three_state_flag(), help="Boolean that specifies if operation should apply to the directory specified in the URI, its " "files, with its subdirectories and their files.") c.extra('close_all', arg_type=get_three_state_flag(), validator=validate_share_close_handle, help="Whether or not to close all the file handles. Specify close-all or a specific handle-id.") c.extra('handle', options_list='--handle-id', help="Specifies handle ID opened on the file or directory to be closed. " "Astrix (‘*’) is a wildcard that specifies all handles.") c.extra('snapshot', help="A string that represents the snapshot version, if applicable.") c.extra('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) for scope in ['create', 'delete', 'show', 'exists', 'metadata show', 'metadata update']: with self.argument_context(f'storage directory {scope}') as c: c.extra('share_name', share_name_type, required=True) c.extra('snapshot', help="A string that represents the snapshot version, if applicable.") c.extra('directory_path', directory_type, options_list=('--name', '-n'), required=True) c.extra('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) with self.argument_context('storage directory list') as c: c.extra('share_name', share_name_type, required=True) c.extra('directory_path', directory_type, options_list=('--name', '-n')) c.argument('exclude_extended_info', help='Specify to exclude "timestamps", "Etag", "Attributes", "PermissionKey" info from response') c.extra('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) with self.argument_context('storage directory create') as c: c.argument('fail_on_exist', help='Throw an exception if the directory already exists.') with self.argument_context('storage directory delete') as c: c.argument('fail_not_exist', help='Throw an exception if the directory does not exist.') with self.argument_context('storage directory metadata update') as c: c.argument('metadata', required=False) with self.argument_context('storage file') as c: c.argument('file_name', file_name_type, options_list=('--name', '-n')) c.argument('directory_name', directory_type, required=False) with self.argument_context('storage file copy') as c: c.argument('share_name', share_name_type, options_list=('--destination-share', '-s'), help='Name of the destination share. The share must exist.') with self.argument_context('storage file copy start') as c: from .completers import dir_path_completer from ._validators import validate_source_uri c.register_path_argument(options_list=('--destination-path', '-p')) c.register_source_uri_arguments(validator=validate_source_uri) c.extra('share_name', share_name_type, options_list=('--destination-share', '-s'), required=True, help='Name of the destination share. The share must exist.') c.extra('file_snapshot', default=None, arg_group='Copy Source', help='The file snapshot for the source storage account.') c.extra('metadata', nargs='+', help='Metadata in space-separated key=value pairs. This overwrites any existing metadata.', validator=validate_metadata) c.extra('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) with self.argument_context('storage file copy cancel') as c: c.register_path_argument(options_list=('--destination-path', '-p')) c.extra('share_name', share_name_type, options_list=('--destination-share', '-s'), required=True, help='Name of the destination share. The share must exist.') c.extra('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) with self.argument_context('storage file copy start-batch') as c: c.argument('share_name', share_name_type, options_list=('--destination-share'), help='Name of the destination share. The share must exist.') with self.argument_context('storage file copy start-batch', arg_group='Copy Source') as c: from ._validators import get_source_file_or_blob_service_client_track2 c.argument('source_client', ignore_type, validator=get_source_file_or_blob_service_client_track2) c.extra('source_account_name') c.extra('source_account_key') c.extra('source_uri') c.argument('source_sas') c.argument('source_container') c.argument('source_share') with self.argument_context('storage file delete') as c: c.register_path_argument() c.extra('share_name', share_name_type, required=True) c.extra('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) progress_type = CLIArgumentType(help='Include this flag to disable progress reporting for the command.', action='store_true', validator=add_progress_callback) with self.argument_context('storage file download') as c: c.register_path_argument() c.extra('share_name', share_name_type, required=True) c.extra('destination_path', options_list=('--dest',), type=file_type, required=False, help='Path of the file to write to. The source filename will be used if not specified.', completer=FilesCompleter()) c.extra('no_progress', progress_type, validator=add_progress_callback) c.argument('max_connections', type=int, help='Maximum number of parallel connections to use.') c.extra('start_range', type=int, help='Start of byte range to use for downloading a section of the file. ' 'If no --end-range is given, all bytes after the --start-range will be ' 'downloaded. The --start-range and --end-range params are inclusive. Ex: ' '--start-range=0, --end-range=511 will download first 512 bytes of file.') c.extra('end_range', type=int, help='End of byte range to use for downloading a section of the file. If ' '--end-range is given, --start-range must be provided. The --start-range ' 'and --end-range params are inclusive. Ex: --start-range=0, ' '--end-range=511 will download first 512 bytes of file.') c.argument('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) c.extra('snapshot', help="A string that represents the snapshot version, if applicable.") c.argument('open_mode', help="Mode to use when opening the file. Note that specifying append only " "open_mode prevents parallel download. So, --max-connections must be " "set to 1 if this --open-mode is used.") c.extra('validate_content', help="If set to true, validates an MD5 hash for each retrieved portion of the file." " This is primarily valuable for detecting bitflips on the wire if using " "http instead of https as https (the default) will already validate. " "As computing the MD5 takes processing time and more requests will " "need to be done due to the reduced chunk size there may be some increase " "in latency.") with self.argument_context('storage file exists') as c: c.register_path_argument() c.extra('share_name', share_name_type, required=True) c.extra('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) c.extra('snapshot', help="A string that represents the snapshot version, if applicable.") sas_help = 'The permissions the SAS grants. Allowed values: {}. Do not use if a stored access policy is ' \ 'referenced with --id that specifies this value. Can be combined.' with self.argument_context('storage file generate-sas') as c: from .completers import get_storage_acl_name_completion_list c.register_path_argument() c.register_sas_arguments() c.extra('share_name', share_name_type, required=True) t_file_svc = self.get_sdk('file.fileservice#FileService') t_file_permissions = self.get_sdk('_models#FileSasPermissions', resource_type=CUSTOM_DATA_STORAGE_FILESHARE) c.argument('id', options_list='--policy-name', help='The name of a stored access policy within the container\'s ACL.', completer=get_storage_acl_name_completion_list(t_file_svc, 'container_name', 'get_container_acl')) c.argument('permission', options_list='--permissions', help=sas_help.format(get_permission_help_string(t_file_permissions)), validator=get_permission_validator(t_file_permissions)) c.extra('cache_control', help='Response header value for Cache-Control when resource is accessed ' 'using this shared access signature.') c.extra('content_disposition', help='Response header value for Content-Disposition when resource is accessed ' 'using this shared access signature.') c.extra('content_encoding', help='Response header value for Content-Encoding when resource is accessed ' 'using this shared access signature.') c.extra('content_language', help='Response header value for Content-Language when resource is accessed ' 'using this shared access signature.') c.extra('content_type', help='Response header value for Content-Type when resource is accessed ' 'using this shared access signature.') c.ignore('sas_token') marker_type = CLIArgumentType( help='A string value that identifies the portion of the list of containers to be ' 'returned with the next listing operation. The operation returns the NextMarker value within ' 'the response body if the listing operation did not return all containers remaining to be listed ' 'with the current page. If specified, this generator will begin returning results from the point ' 'where the previous generator stopped.') with self.argument_context('storage file list') as c: c.extra('share_name', share_name_type, required=True) c.extra('snapshot', help="A string that represents the snapshot version, if applicable.") c.argument('directory_name', options_list=('--path', '-p'), help='The directory path within the file share.', completer=dir_path_completer) c.argument('num_results', arg_type=num_results_type) c.argument('marker', arg_type=marker_type) c.argument('exclude_extended_info', help='Specify to exclude "timestamps", "Etag", "Attributes", "PermissionKey" info from response') with self.argument_context('storage file metadata show') as c: c.register_path_argument() c.extra('share_name', share_name_type, required=True) c.extra('snapshot', help="A string that represents the snapshot version, if applicable.") c.extra('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) with self.argument_context('storage file metadata update') as c: c.register_path_argument() c.extra('share_name', share_name_type, required=True) c.extra('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) with self.argument_context('storage file resize') as c: c.register_path_argument() c.extra('share_name', share_name_type, required=True) c.extra('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) c.argument('content_length', options_list='--size', type=int) with self.argument_context('storage file show') as c: c.register_path_argument() c.extra('share_name', share_name_type, required=True) c.extra('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) c.extra('snapshot', help='A string that represents the snapshot version, if applicable.') with self.argument_context('storage file update') as c: t_file_content_settings = self.get_sdk('_models#ContentSettings', resource_type=CUSTOM_DATA_STORAGE_FILESHARE) c.extra('share_name', share_name_type, required=True) c.register_path_argument() c.register_content_settings_argument(t_file_content_settings, update=True, process_md5=True) c.extra('timeout', help='Request timeout in seconds. Applies to each call to the service.', type=int) with self.argument_context('storage file upload') as c: t_file_content_settings = self.get_sdk('_models#ContentSettings', resource_type=CUSTOM_DATA_STORAGE_FILESHARE) c.register_path_argument(default_file_param='local_file_path') c.register_content_settings_argument(t_file_content_settings, update=False, guess_from_file='local_file_path', process_md5=True) c.argument('local_file_path', options_list='--source', type=file_type, completer=FilesCompleter(), help='Path of the local file to upload as the file content.') c.extra('no_progress', progress_type, validator=add_progress_callback) c.argument('max_connections', type=int, help='Maximum number of parallel connections to use.') c.extra('share_name', share_name_type, required=True) c.argument('validate_content', action='store_true', min_api='2016-05-31', help='If true, calculates an MD5 hash for each range of the file. The storage service checks the ' 'hash of the content that has arrived with the hash that was sent. This is primarily valuable ' 'for detecting bitflips on the wire if using http instead of https as https (the default) will ' 'already validate. Note that this MD5 hash is not stored with the file.') with self.argument_context('storage file url') as c: c.register_path_argument(fileshare=True) c.extra('share_name', share_name_type, required=True) c.argument('protocol', arg_type=get_enum_type(['http', 'https'], 'https'), help='Protocol to use.') with self.argument_context('storage file upload-batch') as c: t_file_content_settings = self.get_sdk('_models#ContentSettings', resource_type=CUSTOM_DATA_STORAGE_FILESHARE) from ._validators import process_file_upload_batch_parameters c.argument('source', options_list=('--source', '-s'), validator=process_file_upload_batch_parameters) c.argument('destination', options_list=('--destination', '-d')) c.argument('max_connections', arg_group='Download Control', type=int) c.argument('validate_content', action='store_true', min_api='2016-05-31') c.register_content_settings_argument(t_file_content_settings, update=False, arg_group='Content Settings') c.extra('no_progress', progress_type, validator=add_progress_callback) with self.argument_context('storage file download-batch') as c: from ._validators import process_file_download_batch_parameters c.argument('source', options_list=('--source', '-s'), validator=process_file_download_batch_parameters) c.argument('destination', options_list=('--destination', '-d')) c.argument('max_connections', arg_group='Download Control', type=int) c.argument('validate_content', action='store_true', min_api='2016-05-31') c.extra('no_progress', progress_type, validator=add_progress_callback) c.extra('snapshot', help='The snapshot parameter is an opaque DateTime value that, when present, ' 'specifies the snapshot.') with self.argument_context('storage file delete-batch') as c: from ._validators import process_file_batch_source_parameters c.argument('source', options_list=('--source', '-s'), validator=process_file_batch_source_parameters) for cmd in ['list-handle', 'close-handle']: with self.argument_context('storage share ' + cmd) as c: c.extra('disallow_trailing_dot', arg_type=get_three_state_flag(), default=False, help="If true, the trailing dot will be trimmed from the target URI. Default to False") for cmd in ['create', 'delete', 'show', 'exists', 'metadata show', 'metadata update', 'list']: with self.argument_context('storage directory ' + cmd) as c: c.extra('disallow_trailing_dot', arg_type=get_three_state_flag(), default=False, help="If true, the trailing dot will be trimmed from the target URI. Default to False") for cmd in ['list', 'delete', 'delete-batch', 'resize', 'url', 'generate-sas', 'show', 'update', 'exists', 'metadata show', 'metadata update', 'copy start', 'copy cancel', 'copy start-batch', 'upload', 'upload-batch', 'download', 'download-batch']: with self.argument_context('storage file ' + cmd) as c: c.extra('disallow_trailing_dot', arg_type=get_three_state_flag(), default=False, help="If true, the trailing dot will be trimmed from the target URI. Default to False") for cmd in ['start', 'start-batch']: with self.argument_context('storage file copy ' + cmd) as c: c.extra('disallow_source_trailing_dot', arg_type=get_three_state_flag(), default=False, options_list=["--disallow-source-trailing-dot", "--disallow-src-trailing"], help="If true, the trailing dot will be trimmed from the source URI. Default to False") with self.argument_context('storage account local-user') as c: c.argument('account_name', acct_name_type, options_list='--account-name', id_part=None) c.argument('username', options_list=['--user-name', '--name', '-n'], help='The name of local user. The username must contain lowercase letters and numbers ' 'only. It must be unique only within the storage account.') for item in ['create', 'update']: with self.argument_context(f'storage account local-user {item}') as c: c.argument('permission_scope', nargs='+', action=PermissionScopeAddAction, help='The permission scope argument list which includes the permissions, service, ' 'and resource_name.' 'The permissions can be a combination of the below possible values: ' 'Read(r), Write (w), Delete (d), List (l), and Create (c). ' 'The service has possible values: blob, file. ' 'The resource-name is the container name or the file share name. ' 'Example: --permission-scope permissions=r service=blob resource-name=container1' 'Can specify multiple permission scopes: ' '--permission-scope permissions=rw service=blob resource-name=container1' '--permission-scope permissions=rwd service=file resource-name=share2') c.argument('home_directory', help='The home directory.') c.argument('ssh_authorized_key', nargs='+', action=SshPublicKeyAddAction, help='SSH authorized keys for SFTP. Includes an optional description and key. ' 'The key is the base64 encoded SSH public key , with format: ' '`<keyType> <keyData>` e.g. ssh-rsa AAAABBBB.' 'Example: --ssh_authorized_key description=description key="ssh-rsa AAAABBBB"' 'or --ssh_authorized_key key="ssh-rsa AAAABBBB"') c.argument('has_shared_key', arg_type=get_three_state_flag(), help='Indicates whether shared key exists. Set it to false to remove existing shared key.') c.argument('has_ssh_key', arg_type=get_three_state_flag(), help='Indicates whether ssh key exists. Set it to false to remove existing SSH key.') c.argument('has_ssh_password', arg_type=get_three_state_flag(), help='Indicates whether ssh password exists. Set it to false to remove existing SSH password.') c.argument('group_id', is_preview=True, help='An identifier for associating a group of users.') c.argument('allow_acl_authorization', options_list=['--allow-acl-authorization', '--allow-acl-auth'], arg_type=get_three_state_flag(), is_preview=True, help='Indicate whether ACL authorization is allowed for this user. ' 'Set it to false to disallow using ACL authorization.') c.argument('extended_groups', nargs='+', is_preview=True, help='Supplementary group membership. Only applicable for local users enabled for NFSv3 access.') with self.argument_context('storage account local-user create') as c: c.argument('is_nfsv3_enabled', arg_type=get_three_state_flag(), is_preview=True, help='Indicate if the local user is enabled for access with NFSv3 protocol.')

src/storage-preview/azext_storage_preview/_params.py (873 lines of code) (raw):