12 def process_autoscale_create_namespace(cmd, namespace):  argument
15     validate_tags(namespace)
16 …source_validator('resource', required=True, preserve_resource_group_parameter=True)(cmd, namespace)
17     if not namespace.resource_group_name:
18 …  namespace.resource_group_name = parse_resource_id(namespace.resource).get('resource_group', None)
19     get_default_location_from_resource_group(cmd, namespace)
22 def validate_autoscale_recurrence(namespace):  argument
25     def _validate_weekly_recurrence(namespace):  argument
29         for partial in namespace.recurrence[1:]:
43                 time_zone=namespace.timezone,
57     if namespace.recurrence:
58         raw_values = namespace.recurrence
63                 namespace.recurrence = valid_recurrence[delimiter]['validator'](namespace)
70 def validate_autoscale_timegrain(namespace):  argument
75     values = namespace.timegrain
101     namespace.timegrain = timegrain
105     def _validator(cmd, namespace):  argument
107         name_or_id = getattr(namespace, dest)
108         rg = namespace.resource_group_name
109         res_ns = namespace.namespace
110         parent = namespace.parent
111         res_type = namespace.resource_type
129                 setattr(namespace, dest,
134         del namespace.namespace
135         del namespace.parent
136         del namespace.resource_type
138             del namespace.resource_group_name
143 def validate_metrics_alert_dimension(namespace):  argument
146         if namespace.operator == value:
147             namespace.operator = keyword
150 def validate_metrics_alert_condition(namespace):  argument
154         if namespace.aggregation == value:
155             namespace.aggregation = keyword
158         if namespace.operator == value:
159             namespace.operator = keyword
162     if namespace.condition_type == 'static':
163         if namespace.threshold is None:
165         if namespace.operator not in ('=', '!=', '>', '>=', '<', '<='):
167                 op_conversion[namespace.operator]
169     elif namespace.condition_type == 'dynamic':
170         if namespace.operator not in ('>', '<', '><'):
172                 op_conversion[namespace.operator]
174         if namespace.alert_sensitivity is None:
177             if namespace.alert_sensitivity == value:
178                 namespace.alert_sensitivity = keyword
181         if namespace.number_of_evaluation_periods is None:
182             setattr(namespace, 'number_of_evaluation_periods', 4)
184         if namespace.number_of_evaluation_periods < 1 or namespace.number_of_evaluation_periods > 6:
186                 namespace.number_of_evaluation_periods
189         if namespace.min_failing_periods_to_alert is None:
190 … setattr(namespace, 'min_failing_periods_to_alert', min(4, namespace.number_of_evaluation_periods))
192         if namespace.min_failing_periods_to_alert < 1 or namespace.min_failing_periods_to_alert > 6:
194                 namespace.min_failing_periods_to_alert
197         if namespace.min_failing_periods_to_alert > namespace.number_of_evaluation_periods:
200                     namespace.min_failing_periods_to_alert, namespace.number_of_evaluation_periods))
205 def validate_diagnostic_settings(cmd, namespace):  argument
209 …ce_validator('resource_uri', required=True, preserve_resource_group_parameter=True)(cmd, namespace)
210     if not namespace.resource_group_name:
211         namespace.resource_group_name = parse_resource_id(namespace.resource_uri)['resource_group']
213     if namespace.storage_account and not is_valid_resource_id(namespace.storage_account):
214         namespace.storage_account = resource_id(subscription=get_subscription_id(cmd.cli_ctx),
215                                                 resource_group=namespace.resource_group_name,
216                                                 namespace='microsoft.Storage',
218                                                 name=namespace.storage_account)
220     if namespace.workspace and not is_valid_resource_id(namespace.workspace):
221         namespace.workspace = resource_id(subscription=get_subscription_id(cmd.cli_ctx),
222                                           resource_group=namespace.resource_group_name,
223                                           namespace='microsoft.OperationalInsights',
225                                           name=namespace.workspace)
227     if namespace.event_hub and is_valid_resource_id(namespace.event_hub):
228         namespace.event_hub = parse_resource_id(namespace.event_hub)['name']
230     if namespace.event_hub_rule:
231         if not is_valid_resource_id(namespace.event_hub_rule):
232             if not namespace.event_hub:
235             namespace.event_hub_rule = resource_id(
237                 resource_group=namespace.resource_group_name,
238                 namespace='Microsoft.EventHub',
240                 name=namespace.event_hub,
242                 child_name_1=namespace.event_hub_rule)
243         elif not namespace.event_hub:
245             namespace.event_hub = parse_resource_id(namespace.event_hub_rule)['name']
247     if not any([namespace.storage_account, namespace.workspace, namespace.event_hub]):
253         del namespace.resource_group_name
258 def _validate_tags(namespace):  argument
260     if isinstance(namespace.tags, list):
262         for item in namespace.tags:
264         namespace.tags = tags_dict
276 def process_action_group_detail_for_creation(namespace):  argument
281     _validate_tags(namespace)
283     ns = vars(namespace)
301     if hasattr(namespace, 'tags'):
302         del namespace.tags
307 def validate_metric_dimension(namespace):  argument
309     if not namespace.dimension:
312     if namespace.filters:
315     namespace.filters = ' and '.join("{} eq '*'".format(d) for d in namespace.dimension)
318 def process_webhook_prop(namespace):  argument
319     if not isinstance(namespace.webhook_properties, list):
323     for each in namespace.webhook_properties:
331     namespace.webhook_properties = result
335     def validate_action_groups(cmd, namespace):  argument
336         action_groups = getattr(namespace, dest, None)
345         resource_group = namespace.resource_group_name
351                     namespace='microsoft.insights',
359     def validate_action_group_ids(cmd, namespace):  argument
360         action_groups = getattr(namespace, dest, None)
370         resource_group = namespace.resource_group_name
376                     namespace='microsoft.insights',
381         setattr(namespace, dest, action_group_ids)
385 def validate_private_endpoint_connection_id(namespace):  argument
386     if namespace.connection_id:
388         result = parse_proxy_resource_id(namespace.connection_id)
389         namespace.resource_group_name = result['resource_group']
390         namespace.scope_name = result['name']
391         namespace.private_endpoint_connection_name = result['child_name_1']
393 …if not all([namespace.scope_name, namespace.resource_group_name, namespace.private_endpoint_connec…
396     del namespace.connection_id
399 def validate_storage_accounts_name_or_id(cmd, namespace):  argument
400     if namespace.storage_account_ids:
403         for index, storage_account_id in enumerate(namespace.storage_account_ids):
405                 namespace.storage_account_ids[index] = resource_id(
407                     resource_group=namespace.resource_group_name,
408                     namespace='Microsoft.Storage',
414 def process_subscription_id(cmd, namespace):  argument
416     namespace.subscription_id = get_subscription_id(cmd.cli_ctx)
419 def process_workspace_data_export_destination(namespace):  argument
420     if namespace.destination:
422         if not is_valid_resource_id(namespace.destination):
425         result = parse_resource_id(namespace.destination)
427             namespace.data_export_type = 'StorageAccount'
429             namespace.data_export_type = 'EventHub'
430             namespace.destination = resource_id(
433                 namespace=result['namespace'],
438                 namespace.event_hub_name = result['child_name_1']