diff --git a/src/azure-cli/azure/cli/command_modules/eventhubs/_params.py b/src/azure-cli/azure/cli/command_modules/eventhubs/_params.py index 7dacfb540e5..602ed4e5e7e 100644 --- a/src/azure-cli/azure/cli/command_modules/eventhubs/_params.py +++ b/src/azure-cli/azure/cli/command_modules/eventhubs/_params.py @@ -12,8 +12,7 @@ def load_arguments_eh(self, _): from azure.cli.core.commands.parameters import tags_type, get_enum_type, resource_group_name_type, name_type, \ get_location_type, get_three_state_flag, get_resource_name_completion_list from azure.cli.core.commands.validators import get_default_location_from_resource_group - from azure.cli.command_modules.eventhubs._completers import get_consumergroup_command_completion_list, \ - get_eventhubs_command_completion_list + from azure.cli.command_modules.eventhubs._completers import get_eventhubs_command_completion_list from azure.cli.command_modules.eventhubs._validator import validate_storageaccount, validate_partner_namespace, validate_rights from knack.arguments import CLIArgumentType from azure.cli.core.profiles import ResourceType @@ -143,21 +142,6 @@ def load_arguments_eh(self, _): c.argument('event_hub_name', id_part=None, arg_type=event_hub_name_arg_type) c.argument('authorization_rule_name', arg_type=name_type, id_part=None, help='Name of EventHub AuthorizationRule') - -# - ConsumerGroup Region - with self.argument_context('eventhubs eventhub consumer-group') as c: - c.argument('event_hub_name', arg_type=event_hub_name_arg_type, help='Name of EventHub') - c.argument('consumer_group_name', arg_type=name_type, id_part='child_name_2', completer=get_consumergroup_command_completion_list, help='Name of ConsumerGroup') - - for scope in ['eventhubs eventhub consumer-group create', 'eventhubs eventhub consumer-group update']: - with self.argument_context(scope) as c: - c.argument('name', arg_type=name_type, help='Name of ConsumerGroup') - c.argument('user_metadata', help='Usermetadata is a placeholder to store user-defined string data with maximum length 1024. e.g. it can be used to store descriptive data, such as list of teams and their contact information also user-defined configuration settings can be stored.') - - with self.argument_context('eventhubs eventhub consumer-group list') as c: - c.argument('event_hub_name', arg_type=event_hub_name_arg_type, id_part=None, help='Name of EventHub') - c.argument('namespace_name', options_list=['--namespace-name'], id_part=None, help='Name of Namespace') - # : Region Geo DR Configuration with self.argument_context('eventhubs georecovery-alias') as c: c.argument('alias', options_list=['--alias', '-a'], id_part='child_name_1', help='Name of Geo-Disaster Recovery Configuration Alias') diff --git a/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/__cmd_group.py b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/__cmd_group.py new file mode 100644 index 00000000000..83ecbd45c40 --- /dev/null +++ b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/__cmd_group.py @@ -0,0 +1,23 @@ +# -------------------------------------------------------------------------------------------- +# Copyright (c) Microsoft Corporation. All rights reserved. +# Licensed under the MIT License. See License.txt in the project root for license information. +# +# Code generated by aaz-dev-tools +# -------------------------------------------------------------------------------------------- + +# pylint: skip-file +# flake8: noqa + +from azure.cli.core.aaz import * + + +@register_command_group( + "eventhubs eventhub", +) +class __CMDGroup(AAZCommandGroup): + """Manage Azure EventHubs eventhub + """ + pass + + +__all__ = ["__CMDGroup"] diff --git a/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/__init__.py b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/__init__.py new file mode 100644 index 00000000000..5a9d61963d6 --- /dev/null +++ b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/__init__.py @@ -0,0 +1,11 @@ +# -------------------------------------------------------------------------------------------- +# Copyright (c) Microsoft Corporation. All rights reserved. +# Licensed under the MIT License. See License.txt in the project root for license information. +# +# Code generated by aaz-dev-tools +# -------------------------------------------------------------------------------------------- + +# pylint: skip-file +# flake8: noqa + +from .__cmd_group import * diff --git a/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/__cmd_group.py b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/__cmd_group.py new file mode 100644 index 00000000000..66e34decf6e --- /dev/null +++ b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/__cmd_group.py @@ -0,0 +1,23 @@ +# -------------------------------------------------------------------------------------------- +# Copyright (c) Microsoft Corporation. All rights reserved. +# Licensed under the MIT License. See License.txt in the project root for license information. +# +# Code generated by aaz-dev-tools +# -------------------------------------------------------------------------------------------- + +# pylint: skip-file +# flake8: noqa + +from azure.cli.core.aaz import * + + +@register_command_group( + "eventhubs eventhub consumer-group", +) +class __CMDGroup(AAZCommandGroup): + """Manage Azure Event Hubs consumergroup. + """ + pass + + +__all__ = ["__CMDGroup"] diff --git a/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/__init__.py b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/__init__.py new file mode 100644 index 00000000000..c401f439385 --- /dev/null +++ b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/__init__.py @@ -0,0 +1,16 @@ +# -------------------------------------------------------------------------------------------- +# Copyright (c) Microsoft Corporation. All rights reserved. +# Licensed under the MIT License. See License.txt in the project root for license information. +# +# Code generated by aaz-dev-tools +# -------------------------------------------------------------------------------------------- + +# pylint: skip-file +# flake8: noqa + +from .__cmd_group import * +from ._create import * +from ._delete import * +from ._list import * +from ._show import * +from ._update import * diff --git a/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_create.py b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_create.py new file mode 100644 index 00000000000..75cbb0240b9 --- /dev/null +++ b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_create.py @@ -0,0 +1,269 @@ +# -------------------------------------------------------------------------------------------- +# Copyright (c) Microsoft Corporation. All rights reserved. +# Licensed under the MIT License. See License.txt in the project root for license information. +# +# Code generated by aaz-dev-tools +# -------------------------------------------------------------------------------------------- + +# pylint: skip-file +# flake8: noqa + +from azure.cli.core.aaz import * + + +@register_command( + "eventhubs eventhub consumer-group create", +) +class Create(AAZCommand): + """Create an Event Hubs consumer group as a nested resource within a Namespace. + """ + + _aaz_info = { + "version": "2022-01-01-preview", + "resources": [ + ["mgmt-plane", "/subscriptions/{}/resourcegroups/{}/providers/microsoft.eventhub/namespaces/{}/eventhubs/{}/consumergroups/{}", "2022-01-01-preview"], + ] + } + + def _handler(self, command_args): + super()._handler(command_args) + self._execute_operations() + return self._output() + + _args_schema = None + + @classmethod + def _build_arguments_schema(cls, *args, **kwargs): + if cls._args_schema is not None: + return cls._args_schema + cls._args_schema = super()._build_arguments_schema(*args, **kwargs) + + # define Arg Group "" + + _args_schema = cls._args_schema + _args_schema.consumer_group_name = AAZStrArg( + options=["-n", "--name", "--consumer-group-name"], + help="The consumer group name", + required=True, + fmt=AAZStrArgFormat( + max_length=50, + min_length=1, + ), + ) + _args_schema.eventhub_name = AAZStrArg( + options=["--eventhub-name"], + help="The Event Hub name", + required=True, + fmt=AAZStrArgFormat( + max_length=256, + min_length=1, + ), + ) + _args_schema.namespace_name = AAZStrArg( + options=["--namespace-name"], + help="The Namespace name", + required=True, + fmt=AAZStrArgFormat( + max_length=50, + min_length=6, + ), + ) + _args_schema.resource_group = AAZResourceGroupNameArg( + required=True, + ) + + # define Arg Group "Properties" + + _args_schema = cls._args_schema + _args_schema.user_metadata = AAZStrArg( + options=["--user-metadata"], + arg_group="Properties", + help="User Metadata is a placeholder to store user-defined string data with maximum length 1024. e.g. it can be used to store descriptive data, such as list of teams and their contact information also user-defined configuration settings can be stored.", + ) + return cls._args_schema + + def _execute_operations(self): + self.pre_operations() + self.ConsumerGroupsCreateOrUpdate(ctx=self.ctx)() + self.post_operations() + + @register_callback + def pre_operations(self): + pass + + @register_callback + def post_operations(self): + pass + + def _output(self, *args, **kwargs): + result = self.deserialize_output(self.ctx.vars.instance, client_flatten=True) + return result + + class ConsumerGroupsCreateOrUpdate(AAZHttpOperation): + CLIENT_TYPE = "MgmtClient" + + def __call__(self, *args, **kwargs): + request = self.make_request() + session = self.client.send_request(request=request, stream=False, **kwargs) + if session.http_response.status_code in [200]: + return self.on_200(session) + + return self.on_error(session.http_response) + + @property + def url(self): + return self.client.format_url( + "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventhubs/{eventHubName}/consumergroups/{consumerGroupName}", + **self.url_parameters + ) + + @property + def method(self): + return "PUT" + + @property + def error_format(self): + return "MgmtErrorFormat" + + @property + def url_parameters(self): + parameters = { + **self.serialize_url_param( + "consumerGroupName", self.ctx.args.consumer_group_name, + required=True, + ), + **self.serialize_url_param( + "eventHubName", self.ctx.args.eventhub_name, + required=True, + ), + **self.serialize_url_param( + "namespaceName", self.ctx.args.namespace_name, + required=True, + ), + **self.serialize_url_param( + "resourceGroupName", self.ctx.args.resource_group, + required=True, + ), + **self.serialize_url_param( + "subscriptionId", self.ctx.subscription_id, + required=True, + ), + } + return parameters + + @property + def query_parameters(self): + parameters = { + **self.serialize_query_param( + "api-version", "2022-01-01-preview", + required=True, + ), + } + return parameters + + @property + def header_parameters(self): + parameters = { + **self.serialize_header_param( + "Content-Type", "application/json", + ), + **self.serialize_header_param( + "Accept", "application/json", + ), + } + return parameters + + @property + def content(self): + _content_value, _builder = self.new_content_builder( + self.ctx.args, + typ=AAZObjectType, + typ_kwargs={"flags": {"required": True, "client_flatten": True}} + ) + _builder.set_prop("properties", AAZObjectType, typ_kwargs={"flags": {"client_flatten": True}}) + + properties = _builder.get(".properties") + if properties is not None: + properties.set_prop("userMetadata", AAZStrType, ".user_metadata") + + return self.serialize_content(_content_value) + + def on_200(self, session): + data = self.deserialize_http_content(session) + self.ctx.set_var( + "instance", + data, + schema_builder=self._build_schema_on_200 + ) + + _schema_on_200 = None + + @classmethod + def _build_schema_on_200(cls): + if cls._schema_on_200 is not None: + return cls._schema_on_200 + + cls._schema_on_200 = AAZObjectType() + + _schema_on_200 = cls._schema_on_200 + _schema_on_200.id = AAZStrType( + flags={"read_only": True}, + ) + _schema_on_200.location = AAZStrType( + flags={"read_only": True}, + ) + _schema_on_200.name = AAZStrType( + flags={"read_only": True}, + ) + _schema_on_200.properties = AAZObjectType( + flags={"client_flatten": True}, + ) + _schema_on_200.system_data = AAZObjectType( + serialized_name="systemData", + flags={"read_only": True}, + ) + _schema_on_200.type = AAZStrType( + flags={"read_only": True}, + ) + + properties = cls._schema_on_200.properties + properties.created_at = AAZStrType( + serialized_name="createdAt", + flags={"read_only": True}, + ) + properties.updated_at = AAZStrType( + serialized_name="updatedAt", + flags={"read_only": True}, + ) + properties.user_metadata = AAZStrType( + serialized_name="userMetadata", + ) + + system_data = cls._schema_on_200.system_data + system_data.created_at = AAZStrType( + serialized_name="createdAt", + ) + system_data.created_by = AAZStrType( + serialized_name="createdBy", + ) + system_data.created_by_type = AAZStrType( + serialized_name="createdByType", + ) + system_data.last_modified_at = AAZStrType( + serialized_name="lastModifiedAt", + ) + system_data.last_modified_by = AAZStrType( + serialized_name="lastModifiedBy", + ) + system_data.last_modified_by_type = AAZStrType( + serialized_name="lastModifiedByType", + ) + + return cls._schema_on_200 + + +class _CreateHelper: + """Helper class for Create""" + + +__all__ = ["Create"] diff --git a/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_delete.py b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_delete.py new file mode 100644 index 00000000000..82aca63ce35 --- /dev/null +++ b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_delete.py @@ -0,0 +1,167 @@ +# -------------------------------------------------------------------------------------------- +# Copyright (c) Microsoft Corporation. All rights reserved. +# Licensed under the MIT License. See License.txt in the project root for license information. +# +# Code generated by aaz-dev-tools +# -------------------------------------------------------------------------------------------- + +# pylint: skip-file +# flake8: noqa + +from azure.cli.core.aaz import * + + +@register_command( + "eventhubs eventhub consumer-group delete", +) +class Delete(AAZCommand): + """Delete a consumer group from the specified Event Hub and resource group. + """ + + _aaz_info = { + "version": "2022-01-01-preview", + "resources": [ + ["mgmt-plane", "/subscriptions/{}/resourcegroups/{}/providers/microsoft.eventhub/namespaces/{}/eventhubs/{}/consumergroups/{}", "2022-01-01-preview"], + ] + } + + def _handler(self, command_args): + super()._handler(command_args) + self._execute_operations() + return None + + _args_schema = None + + @classmethod + def _build_arguments_schema(cls, *args, **kwargs): + if cls._args_schema is not None: + return cls._args_schema + cls._args_schema = super()._build_arguments_schema(*args, **kwargs) + + # define Arg Group "" + + _args_schema = cls._args_schema + _args_schema.consumer_group_name = AAZStrArg( + options=["-n", "--name", "--consumer-group-name"], + help="The consumer group name", + required=True, + id_part="child_name_2", + fmt=AAZStrArgFormat( + max_length=50, + min_length=1, + ), + ) + _args_schema.eventhub_name = AAZStrArg( + options=["--eventhub-name"], + help="The Event Hub name", + required=True, + id_part="child_name_1", + fmt=AAZStrArgFormat( + max_length=256, + min_length=1, + ), + ) + _args_schema.namespace_name = AAZStrArg( + options=["--namespace-name"], + help="The Namespace name", + required=True, + id_part="name", + fmt=AAZStrArgFormat( + max_length=50, + min_length=6, + ), + ) + _args_schema.resource_group = AAZResourceGroupNameArg( + required=True, + ) + return cls._args_schema + + def _execute_operations(self): + self.pre_operations() + self.ConsumerGroupsDelete(ctx=self.ctx)() + self.post_operations() + + @register_callback + def pre_operations(self): + pass + + @register_callback + def post_operations(self): + pass + + class ConsumerGroupsDelete(AAZHttpOperation): + CLIENT_TYPE = "MgmtClient" + + def __call__(self, *args, **kwargs): + request = self.make_request() + session = self.client.send_request(request=request, stream=False, **kwargs) + if session.http_response.status_code in [200]: + return self.on_200(session) + if session.http_response.status_code in [204]: + return self.on_204(session) + + return self.on_error(session.http_response) + + @property + def url(self): + return self.client.format_url( + "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventhubs/{eventHubName}/consumergroups/{consumerGroupName}", + **self.url_parameters + ) + + @property + def method(self): + return "DELETE" + + @property + def error_format(self): + return "MgmtErrorFormat" + + @property + def url_parameters(self): + parameters = { + **self.serialize_url_param( + "consumerGroupName", self.ctx.args.consumer_group_name, + required=True, + ), + **self.serialize_url_param( + "eventHubName", self.ctx.args.eventhub_name, + required=True, + ), + **self.serialize_url_param( + "namespaceName", self.ctx.args.namespace_name, + required=True, + ), + **self.serialize_url_param( + "resourceGroupName", self.ctx.args.resource_group, + required=True, + ), + **self.serialize_url_param( + "subscriptionId", self.ctx.subscription_id, + required=True, + ), + } + return parameters + + @property + def query_parameters(self): + parameters = { + **self.serialize_query_param( + "api-version", "2022-01-01-preview", + required=True, + ), + } + return parameters + + def on_200(self, session): + pass + + def on_204(self, session): + pass + + +class _DeleteHelper: + """Helper class for Delete""" + + +__all__ = ["Delete"] diff --git a/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_list.py b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_list.py new file mode 100644 index 00000000000..14b14d446b7 --- /dev/null +++ b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_list.py @@ -0,0 +1,260 @@ +# -------------------------------------------------------------------------------------------- +# Copyright (c) Microsoft Corporation. All rights reserved. +# Licensed under the MIT License. See License.txt in the project root for license information. +# +# Code generated by aaz-dev-tools +# -------------------------------------------------------------------------------------------- + +# pylint: skip-file +# flake8: noqa + +from azure.cli.core.aaz import * + + +@register_command( + "eventhubs eventhub consumer-group list", +) +class List(AAZCommand): + """List all the consumer groups in a Namespace. An empty feed is returned if no consumer group exists in the Namespace. + """ + + _aaz_info = { + "version": "2022-01-01-preview", + "resources": [ + ["mgmt-plane", "/subscriptions/{}/resourcegroups/{}/providers/microsoft.eventhub/namespaces/{}/eventhubs/{}/consumergroups", "2022-01-01-preview"], + ] + } + + def _handler(self, command_args): + super()._handler(command_args) + return self.build_paging(self._execute_operations, self._output) + + _args_schema = None + + @classmethod + def _build_arguments_schema(cls, *args, **kwargs): + if cls._args_schema is not None: + return cls._args_schema + cls._args_schema = super()._build_arguments_schema(*args, **kwargs) + + # define Arg Group "" + + _args_schema = cls._args_schema + _args_schema.eventhub_name = AAZStrArg( + options=["--eventhub-name"], + help="The Event Hub name", + required=True, + fmt=AAZStrArgFormat( + max_length=256, + min_length=1, + ), + ) + _args_schema.namespace_name = AAZStrArg( + options=["--namespace-name"], + help="The Namespace name", + required=True, + fmt=AAZStrArgFormat( + max_length=50, + min_length=6, + ), + ) + _args_schema.resource_group = AAZResourceGroupNameArg( + required=True, + ) + _args_schema.skip = AAZIntArg( + options=["--skip"], + help="Skip is only used if a previous operation returned a partial result. If a previous response contains a nextLink element, the value of the nextLink element will include a skip parameter that specifies a starting point to use for subsequent calls.", + fmt=AAZIntArgFormat( + maximum=1000, + minimum=0, + ), + ) + _args_schema.top = AAZIntArg( + options=["--top"], + help="May be used to limit the number of results to the most recent N usageDetails.", + fmt=AAZIntArgFormat( + maximum=1000, + minimum=1, + ), + ) + return cls._args_schema + + def _execute_operations(self): + self.pre_operations() + self.ConsumerGroupsListByEventHub(ctx=self.ctx)() + self.post_operations() + + @register_callback + def pre_operations(self): + pass + + @register_callback + def post_operations(self): + pass + + def _output(self, *args, **kwargs): + result = self.deserialize_output(self.ctx.vars.instance.value, client_flatten=True) + next_link = self.deserialize_output(self.ctx.vars.instance.next_link) + return result, next_link + + class ConsumerGroupsListByEventHub(AAZHttpOperation): + CLIENT_TYPE = "MgmtClient" + + def __call__(self, *args, **kwargs): + request = self.make_request() + session = self.client.send_request(request=request, stream=False, **kwargs) + if session.http_response.status_code in [200]: + return self.on_200(session) + + return self.on_error(session.http_response) + + @property + def url(self): + return self.client.format_url( + "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventhubs/{eventHubName}/consumergroups", + **self.url_parameters + ) + + @property + def method(self): + return "GET" + + @property + def error_format(self): + return "MgmtErrorFormat" + + @property + def url_parameters(self): + parameters = { + **self.serialize_url_param( + "eventHubName", self.ctx.args.eventhub_name, + required=True, + ), + **self.serialize_url_param( + "namespaceName", self.ctx.args.namespace_name, + required=True, + ), + **self.serialize_url_param( + "resourceGroupName", self.ctx.args.resource_group, + required=True, + ), + **self.serialize_url_param( + "subscriptionId", self.ctx.subscription_id, + required=True, + ), + } + return parameters + + @property + def query_parameters(self): + parameters = { + **self.serialize_query_param( + "$skip", self.ctx.args.skip, + ), + **self.serialize_query_param( + "$top", self.ctx.args.top, + ), + **self.serialize_query_param( + "api-version", "2022-01-01-preview", + required=True, + ), + } + return parameters + + @property + def header_parameters(self): + parameters = { + **self.serialize_header_param( + "Accept", "application/json", + ), + } + return parameters + + def on_200(self, session): + data = self.deserialize_http_content(session) + self.ctx.set_var( + "instance", + data, + schema_builder=self._build_schema_on_200 + ) + + _schema_on_200 = None + + @classmethod + def _build_schema_on_200(cls): + if cls._schema_on_200 is not None: + return cls._schema_on_200 + + cls._schema_on_200 = AAZObjectType() + + _schema_on_200 = cls._schema_on_200 + _schema_on_200.next_link = AAZStrType( + serialized_name="nextLink", + ) + _schema_on_200.value = AAZListType() + + value = cls._schema_on_200.value + value.Element = AAZObjectType() + + _element = cls._schema_on_200.value.Element + _element.id = AAZStrType( + flags={"read_only": True}, + ) + _element.location = AAZStrType( + flags={"read_only": True}, + ) + _element.name = AAZStrType( + flags={"read_only": True}, + ) + _element.properties = AAZObjectType( + flags={"client_flatten": True}, + ) + _element.system_data = AAZObjectType( + serialized_name="systemData", + flags={"read_only": True}, + ) + _element.type = AAZStrType( + flags={"read_only": True}, + ) + + properties = cls._schema_on_200.value.Element.properties + properties.created_at = AAZStrType( + serialized_name="createdAt", + flags={"read_only": True}, + ) + properties.updated_at = AAZStrType( + serialized_name="updatedAt", + flags={"read_only": True}, + ) + properties.user_metadata = AAZStrType( + serialized_name="userMetadata", + ) + + system_data = cls._schema_on_200.value.Element.system_data + system_data.created_at = AAZStrType( + serialized_name="createdAt", + ) + system_data.created_by = AAZStrType( + serialized_name="createdBy", + ) + system_data.created_by_type = AAZStrType( + serialized_name="createdByType", + ) + system_data.last_modified_at = AAZStrType( + serialized_name="lastModifiedAt", + ) + system_data.last_modified_by = AAZStrType( + serialized_name="lastModifiedBy", + ) + system_data.last_modified_by_type = AAZStrType( + serialized_name="lastModifiedByType", + ) + + return cls._schema_on_200 + + +class _ListHelper: + """Helper class for List""" + + +__all__ = ["List"] diff --git a/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_show.py b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_show.py new file mode 100644 index 00000000000..3ba8de9f555 --- /dev/null +++ b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_show.py @@ -0,0 +1,245 @@ +# -------------------------------------------------------------------------------------------- +# Copyright (c) Microsoft Corporation. All rights reserved. +# Licensed under the MIT License. See License.txt in the project root for license information. +# +# Code generated by aaz-dev-tools +# -------------------------------------------------------------------------------------------- + +# pylint: skip-file +# flake8: noqa + +from azure.cli.core.aaz import * + + +@register_command( + "eventhubs eventhub consumer-group show", +) +class Show(AAZCommand): + """Get a description for the specified consumer group. + """ + + _aaz_info = { + "version": "2022-01-01-preview", + "resources": [ + ["mgmt-plane", "/subscriptions/{}/resourcegroups/{}/providers/microsoft.eventhub/namespaces/{}/eventhubs/{}/consumergroups/{}", "2022-01-01-preview"], + ] + } + + def _handler(self, command_args): + super()._handler(command_args) + self._execute_operations() + return self._output() + + _args_schema = None + + @classmethod + def _build_arguments_schema(cls, *args, **kwargs): + if cls._args_schema is not None: + return cls._args_schema + cls._args_schema = super()._build_arguments_schema(*args, **kwargs) + + # define Arg Group "" + + _args_schema = cls._args_schema + _args_schema.consumer_group_name = AAZStrArg( + options=["-n", "--name", "--consumer-group-name"], + help="The consumer group name", + required=True, + id_part="child_name_2", + fmt=AAZStrArgFormat( + max_length=50, + min_length=1, + ), + ) + _args_schema.eventhub_name = AAZStrArg( + options=["--eventhub-name"], + help="The Event Hub name", + required=True, + id_part="child_name_1", + fmt=AAZStrArgFormat( + max_length=256, + min_length=1, + ), + ) + _args_schema.namespace_name = AAZStrArg( + options=["--namespace-name"], + help="The Namespace name", + required=True, + id_part="name", + fmt=AAZStrArgFormat( + max_length=50, + min_length=6, + ), + ) + _args_schema.resource_group = AAZResourceGroupNameArg( + required=True, + ) + return cls._args_schema + + def _execute_operations(self): + self.pre_operations() + self.ConsumerGroupsGet(ctx=self.ctx)() + self.post_operations() + + @register_callback + def pre_operations(self): + pass + + @register_callback + def post_operations(self): + pass + + def _output(self, *args, **kwargs): + result = self.deserialize_output(self.ctx.vars.instance, client_flatten=True) + return result + + class ConsumerGroupsGet(AAZHttpOperation): + CLIENT_TYPE = "MgmtClient" + + def __call__(self, *args, **kwargs): + request = self.make_request() + session = self.client.send_request(request=request, stream=False, **kwargs) + if session.http_response.status_code in [200]: + return self.on_200(session) + + return self.on_error(session.http_response) + + @property + def url(self): + return self.client.format_url( + "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventhubs/{eventHubName}/consumergroups/{consumerGroupName}", + **self.url_parameters + ) + + @property + def method(self): + return "GET" + + @property + def error_format(self): + return "MgmtErrorFormat" + + @property + def url_parameters(self): + parameters = { + **self.serialize_url_param( + "consumerGroupName", self.ctx.args.consumer_group_name, + required=True, + ), + **self.serialize_url_param( + "eventHubName", self.ctx.args.eventhub_name, + required=True, + ), + **self.serialize_url_param( + "namespaceName", self.ctx.args.namespace_name, + required=True, + ), + **self.serialize_url_param( + "resourceGroupName", self.ctx.args.resource_group, + required=True, + ), + **self.serialize_url_param( + "subscriptionId", self.ctx.subscription_id, + required=True, + ), + } + return parameters + + @property + def query_parameters(self): + parameters = { + **self.serialize_query_param( + "api-version", "2022-01-01-preview", + required=True, + ), + } + return parameters + + @property + def header_parameters(self): + parameters = { + **self.serialize_header_param( + "Accept", "application/json", + ), + } + return parameters + + def on_200(self, session): + data = self.deserialize_http_content(session) + self.ctx.set_var( + "instance", + data, + schema_builder=self._build_schema_on_200 + ) + + _schema_on_200 = None + + @classmethod + def _build_schema_on_200(cls): + if cls._schema_on_200 is not None: + return cls._schema_on_200 + + cls._schema_on_200 = AAZObjectType() + + _schema_on_200 = cls._schema_on_200 + _schema_on_200.id = AAZStrType( + flags={"read_only": True}, + ) + _schema_on_200.location = AAZStrType( + flags={"read_only": True}, + ) + _schema_on_200.name = AAZStrType( + flags={"read_only": True}, + ) + _schema_on_200.properties = AAZObjectType( + flags={"client_flatten": True}, + ) + _schema_on_200.system_data = AAZObjectType( + serialized_name="systemData", + flags={"read_only": True}, + ) + _schema_on_200.type = AAZStrType( + flags={"read_only": True}, + ) + + properties = cls._schema_on_200.properties + properties.created_at = AAZStrType( + serialized_name="createdAt", + flags={"read_only": True}, + ) + properties.updated_at = AAZStrType( + serialized_name="updatedAt", + flags={"read_only": True}, + ) + properties.user_metadata = AAZStrType( + serialized_name="userMetadata", + ) + + system_data = cls._schema_on_200.system_data + system_data.created_at = AAZStrType( + serialized_name="createdAt", + ) + system_data.created_by = AAZStrType( + serialized_name="createdBy", + ) + system_data.created_by_type = AAZStrType( + serialized_name="createdByType", + ) + system_data.last_modified_at = AAZStrType( + serialized_name="lastModifiedAt", + ) + system_data.last_modified_by = AAZStrType( + serialized_name="lastModifiedBy", + ) + system_data.last_modified_by_type = AAZStrType( + serialized_name="lastModifiedByType", + ) + + return cls._schema_on_200 + + +class _ShowHelper: + """Helper class for Show""" + + +__all__ = ["Show"] diff --git a/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_update.py b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_update.py new file mode 100644 index 00000000000..0144c298d44 --- /dev/null +++ b/src/azure-cli/azure/cli/command_modules/eventhubs/aaz/latest/eventhubs/eventhub/consumer_group/_update.py @@ -0,0 +1,423 @@ +# -------------------------------------------------------------------------------------------- +# Copyright (c) Microsoft Corporation. All rights reserved. +# Licensed under the MIT License. See License.txt in the project root for license information. +# +# Code generated by aaz-dev-tools +# -------------------------------------------------------------------------------------------- + +# pylint: skip-file +# flake8: noqa + +from azure.cli.core.aaz import * + + +@register_command( + "eventhubs eventhub consumer-group update", +) +class Update(AAZCommand): + """Update an Event Hubs consumer group as a nested resource within a Namespace. + """ + + _aaz_info = { + "version": "2022-01-01-preview", + "resources": [ + ["mgmt-plane", "/subscriptions/{}/resourcegroups/{}/providers/microsoft.eventhub/namespaces/{}/eventhubs/{}/consumergroups/{}", "2022-01-01-preview"], + ] + } + + AZ_SUPPORT_GENERIC_UPDATE = True + + def _handler(self, command_args): + super()._handler(command_args) + self._execute_operations() + return self._output() + + _args_schema = None + + @classmethod + def _build_arguments_schema(cls, *args, **kwargs): + if cls._args_schema is not None: + return cls._args_schema + cls._args_schema = super()._build_arguments_schema(*args, **kwargs) + + # define Arg Group "" + + _args_schema = cls._args_schema + _args_schema.consumer_group_name = AAZStrArg( + options=["-n", "--name", "--consumer-group-name"], + help="The consumer group name", + required=True, + id_part="child_name_2", + fmt=AAZStrArgFormat( + max_length=50, + min_length=1, + ), + ) + _args_schema.eventhub_name = AAZStrArg( + options=["--eventhub-name"], + help="The Event Hub name", + required=True, + id_part="child_name_1", + fmt=AAZStrArgFormat( + max_length=256, + min_length=1, + ), + ) + _args_schema.namespace_name = AAZStrArg( + options=["--namespace-name"], + help="The Namespace name", + required=True, + id_part="name", + fmt=AAZStrArgFormat( + max_length=50, + min_length=6, + ), + ) + _args_schema.resource_group = AAZResourceGroupNameArg( + required=True, + ) + + # define Arg Group "Properties" + + _args_schema = cls._args_schema + _args_schema.user_metadata = AAZStrArg( + options=["--user-metadata"], + arg_group="Properties", + help="User Metadata is a placeholder to store user-defined string data with maximum length 1024. e.g. it can be used to store descriptive data, such as list of teams and their contact information also user-defined configuration settings can be stored.", + nullable=True, + ) + return cls._args_schema + + def _execute_operations(self): + self.pre_operations() + self.ConsumerGroupsGet(ctx=self.ctx)() + self.pre_instance_update(self.ctx.vars.instance) + self.InstanceUpdateByJson(ctx=self.ctx)() + self.InstanceUpdateByGeneric(ctx=self.ctx)() + self.post_instance_update(self.ctx.vars.instance) + self.ConsumerGroupsCreateOrUpdate(ctx=self.ctx)() + self.post_operations() + + @register_callback + def pre_operations(self): + pass + + @register_callback + def post_operations(self): + pass + + @register_callback + def pre_instance_update(self, instance): + pass + + @register_callback + def post_instance_update(self, instance): + pass + + def _output(self, *args, **kwargs): + result = self.deserialize_output(self.ctx.vars.instance, client_flatten=True) + return result + + class ConsumerGroupsGet(AAZHttpOperation): + CLIENT_TYPE = "MgmtClient" + + def __call__(self, *args, **kwargs): + request = self.make_request() + session = self.client.send_request(request=request, stream=False, **kwargs) + if session.http_response.status_code in [200]: + return self.on_200(session) + + return self.on_error(session.http_response) + + @property + def url(self): + return self.client.format_url( + "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventhubs/{eventHubName}/consumergroups/{consumerGroupName}", + **self.url_parameters + ) + + @property + def method(self): + return "GET" + + @property + def error_format(self): + return "MgmtErrorFormat" + + @property + def url_parameters(self): + parameters = { + **self.serialize_url_param( + "consumerGroupName", self.ctx.args.consumer_group_name, + required=True, + ), + **self.serialize_url_param( + "eventHubName", self.ctx.args.eventhub_name, + required=True, + ), + **self.serialize_url_param( + "namespaceName", self.ctx.args.namespace_name, + required=True, + ), + **self.serialize_url_param( + "resourceGroupName", self.ctx.args.resource_group, + required=True, + ), + **self.serialize_url_param( + "subscriptionId", self.ctx.subscription_id, + required=True, + ), + } + return parameters + + @property + def query_parameters(self): + parameters = { + **self.serialize_query_param( + "api-version", "2022-01-01-preview", + required=True, + ), + } + return parameters + + @property + def header_parameters(self): + parameters = { + **self.serialize_header_param( + "Accept", "application/json", + ), + } + return parameters + + def on_200(self, session): + data = self.deserialize_http_content(session) + self.ctx.set_var( + "instance", + data, + schema_builder=self._build_schema_on_200 + ) + + _schema_on_200 = None + + @classmethod + def _build_schema_on_200(cls): + if cls._schema_on_200 is not None: + return cls._schema_on_200 + + cls._schema_on_200 = AAZObjectType() + _UpdateHelper._build_schema_consumer_group_read(cls._schema_on_200) + + return cls._schema_on_200 + + class ConsumerGroupsCreateOrUpdate(AAZHttpOperation): + CLIENT_TYPE = "MgmtClient" + + def __call__(self, *args, **kwargs): + request = self.make_request() + session = self.client.send_request(request=request, stream=False, **kwargs) + if session.http_response.status_code in [200]: + return self.on_200(session) + + return self.on_error(session.http_response) + + @property + def url(self): + return self.client.format_url( + "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventhubs/{eventHubName}/consumergroups/{consumerGroupName}", + **self.url_parameters + ) + + @property + def method(self): + return "PUT" + + @property + def error_format(self): + return "MgmtErrorFormat" + + @property + def url_parameters(self): + parameters = { + **self.serialize_url_param( + "consumerGroupName", self.ctx.args.consumer_group_name, + required=True, + ), + **self.serialize_url_param( + "eventHubName", self.ctx.args.eventhub_name, + required=True, + ), + **self.serialize_url_param( + "namespaceName", self.ctx.args.namespace_name, + required=True, + ), + **self.serialize_url_param( + "resourceGroupName", self.ctx.args.resource_group, + required=True, + ), + **self.serialize_url_param( + "subscriptionId", self.ctx.subscription_id, + required=True, + ), + } + return parameters + + @property + def query_parameters(self): + parameters = { + **self.serialize_query_param( + "api-version", "2022-01-01-preview", + required=True, + ), + } + return parameters + + @property + def header_parameters(self): + parameters = { + **self.serialize_header_param( + "Content-Type", "application/json", + ), + **self.serialize_header_param( + "Accept", "application/json", + ), + } + return parameters + + @property + def content(self): + _content_value, _builder = self.new_content_builder( + self.ctx.args, + value=self.ctx.vars.instance, + ) + + return self.serialize_content(_content_value) + + def on_200(self, session): + data = self.deserialize_http_content(session) + self.ctx.set_var( + "instance", + data, + schema_builder=self._build_schema_on_200 + ) + + _schema_on_200 = None + + @classmethod + def _build_schema_on_200(cls): + if cls._schema_on_200 is not None: + return cls._schema_on_200 + + cls._schema_on_200 = AAZObjectType() + _UpdateHelper._build_schema_consumer_group_read(cls._schema_on_200) + + return cls._schema_on_200 + + class InstanceUpdateByJson(AAZJsonInstanceUpdateOperation): + + def __call__(self, *args, **kwargs): + self._update_instance(self.ctx.vars.instance) + + def _update_instance(self, instance): + _instance_value, _builder = self.new_content_builder( + self.ctx.args, + value=instance, + typ=AAZObjectType + ) + _builder.set_prop("properties", AAZObjectType, typ_kwargs={"flags": {"client_flatten": True}}) + + properties = _builder.get(".properties") + if properties is not None: + properties.set_prop("userMetadata", AAZStrType, ".user_metadata") + + return _instance_value + + class InstanceUpdateByGeneric(AAZGenericInstanceUpdateOperation): + + def __call__(self, *args, **kwargs): + self._update_instance_by_generic( + self.ctx.vars.instance, + self.ctx.generic_update_args + ) + + +class _UpdateHelper: + """Helper class for Update""" + + _schema_consumer_group_read = None + + @classmethod + def _build_schema_consumer_group_read(cls, _schema): + if cls._schema_consumer_group_read is not None: + _schema.id = cls._schema_consumer_group_read.id + _schema.location = cls._schema_consumer_group_read.location + _schema.name = cls._schema_consumer_group_read.name + _schema.properties = cls._schema_consumer_group_read.properties + _schema.system_data = cls._schema_consumer_group_read.system_data + _schema.type = cls._schema_consumer_group_read.type + return + + cls._schema_consumer_group_read = _schema_consumer_group_read = AAZObjectType() + + consumer_group_read = _schema_consumer_group_read + consumer_group_read.id = AAZStrType( + flags={"read_only": True}, + ) + consumer_group_read.location = AAZStrType( + flags={"read_only": True}, + ) + consumer_group_read.name = AAZStrType( + flags={"read_only": True}, + ) + consumer_group_read.properties = AAZObjectType( + flags={"client_flatten": True}, + ) + consumer_group_read.system_data = AAZObjectType( + serialized_name="systemData", + flags={"read_only": True}, + ) + consumer_group_read.type = AAZStrType( + flags={"read_only": True}, + ) + + properties = _schema_consumer_group_read.properties + properties.created_at = AAZStrType( + serialized_name="createdAt", + flags={"read_only": True}, + ) + properties.updated_at = AAZStrType( + serialized_name="updatedAt", + flags={"read_only": True}, + ) + properties.user_metadata = AAZStrType( + serialized_name="userMetadata", + ) + + system_data = _schema_consumer_group_read.system_data + system_data.created_at = AAZStrType( + serialized_name="createdAt", + ) + system_data.created_by = AAZStrType( + serialized_name="createdBy", + ) + system_data.created_by_type = AAZStrType( + serialized_name="createdByType", + ) + system_data.last_modified_at = AAZStrType( + serialized_name="lastModifiedAt", + ) + system_data.last_modified_by = AAZStrType( + serialized_name="lastModifiedBy", + ) + system_data.last_modified_by_type = AAZStrType( + serialized_name="lastModifiedByType", + ) + + _schema.id = cls._schema_consumer_group_read.id + _schema.location = cls._schema_consumer_group_read.location + _schema.name = cls._schema_consumer_group_read.name + _schema.properties = cls._schema_consumer_group_read.properties + _schema.system_data = cls._schema_consumer_group_read.system_data + _schema.type = cls._schema_consumer_group_read.type + + +__all__ = ["Update"] diff --git a/src/azure-cli/azure/cli/command_modules/eventhubs/commands.py b/src/azure-cli/azure/cli/command_modules/eventhubs/commands.py index ee9a307d6dc..e6356859fd6 100644 --- a/src/azure-cli/azure/cli/command_modules/eventhubs/commands.py +++ b/src/azure-cli/azure/cli/command_modules/eventhubs/commands.py @@ -14,7 +14,6 @@ def load_command_table(self, _): from azure.cli.command_modules.eventhubs._client_factory import (namespaces_mgmt_client_factory, event_hub_mgmt_client_factory, - consumer_groups_mgmt_client_factory, disaster_recovery_mgmt_client_factory, cluster_mgmt_client_factory, schema_registry_mgmt_client_factory, @@ -38,11 +37,6 @@ def load_command_table(self, _): client_factory=event_hub_mgmt_client_factory, resource_type=ResourceType.MGMT_EVENTHUB) - eh_consumer_groups_util = CliCommandType( - operations_tmpl='azure.mgmt.eventhub.operations#ConsumerGroupsOperations.{}', - client_factory=consumer_groups_mgmt_client_factory, - resource_type=ResourceType.MGMT_EVENTHUB) - eh_geodr_util = CliCommandType( operations_tmpl='azure.mgmt.eventhub.operations#DisasterRecoveryConfigsOperations.{}', client_factory=disaster_recovery_mgmt_client_factory, @@ -119,14 +113,6 @@ def load_command_table(self, _): g.command('delete', 'delete_authorization_rule') g.generic_update_command('update', getter_name='get_authorization_rule', setter_name='create_or_update_authorization_rule', custom_func_name='cli_autho_update') -# ConsumerGroup Region - with self.command_group('eventhubs eventhub consumer-group', eh_consumer_groups_util, resource_type=ResourceType.MGMT_EVENTHUB, client_factory=consumer_groups_mgmt_client_factory) as g: - g.custom_command('create', 'cli_consumergroup_create') - g.show_command('show', 'get') - g.command('list', 'list_by_event_hub') - g.command('delete', 'delete') - g.generic_update_command('update', custom_func_name='cli_consumergroup_update', custom_func_type=eventhubs_custom) - # DisasterRecoveryConfigs Region with self.command_group('eventhubs georecovery-alias', eh_geodr_util, resource_type=ResourceType.MGMT_EVENTHUB, client_factory=disaster_recovery_mgmt_client_factory) as g: g.custom_command('set', 'cli_geodr_create') diff --git a/src/azure-cli/azure/cli/command_modules/eventhubs/custom.py b/src/azure-cli/azure/cli/command_modules/eventhubs/custom.py index c36ca90e5f9..4b5d2a1560e 100644 --- a/src/azure-cli/azure/cli/command_modules/eventhubs/custom.py +++ b/src/azure-cli/azure/cli/command_modules/eventhubs/custom.py @@ -298,25 +298,6 @@ def cli_eventhub_keys_renew(client, resource_group_name, namespace_name, event_h ) -# ConsumerGroup region -def cli_consumergroup_create(client, resource_group_name, namespace_name, event_hub_name, name, user_metadata=None): - return client.create_or_update( - resource_group_name=resource_group_name, - namespace_name=namespace_name, - event_hub_name=event_hub_name, - consumer_group_name=name, - parameters={'user_metadata': user_metadata} - ) - - -def cli_consumergroup_update(cmd, instance, user_metadata=None): - if cmd.supported_api_version(resource_type=ResourceType.MGMT_EVENTHUB, min_api='2017-04-01'): - if user_metadata: - instance.user_metadata = user_metadata - - return instance - - # NetwrokRuleSet Region def cli_networkrule_createupdate(cmd, client, resource_group_name, namespace_name, subnet=None, ip_mask=None, ignore_missing_vnet_service_endpoint=False, action='Allow'): NWRuleSetVirtualNetworkRules = cmd.get_models('NWRuleSetVirtualNetworkRules', resource_type=ResourceType.MGMT_EVENTHUB) diff --git a/src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/recordings/test_eh_consumergroup.yaml b/src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/recordings/test_eh_consumergroup.yaml index e9ec6fecae9..869a11163aa 100644 --- a/src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/recordings/test_eh_consumergroup.yaml +++ b/src/azure-cli/azure/cli/command_modules/eventhubs/tests/latest/recordings/test_eh_consumergroup.yaml @@ -2,7 +2,7 @@ interactions: - request: body: '{"identity": {"type": "None"}, "location": "westus2", "properties": {"isAutoInflateEnabled": true, "maximumThroughputUnits": 4}, "sku": {"name": "Standard", "tier": "Standard"}, - "tags": {"{tag2: value2,": "", "tag1: value1}": ""}}' + "tags": {"{tag1: value1,": "", "tag2: value2}": ""}}' headers: Accept: - application/json @@ -19,13 +19,13 @@ interactions: ParameterSetName: - --resource-group --name --location --tags --sku --enable-auto-inflate --maximum-throughput-units User-Agent: - - AZURECLI/2.47.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: PUT uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002?api-version=2022-01-01-preview response: body: string: '{"sku":{"name":"Standard","tier":"Standard","capacity":1},"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002","name":"eventhubs-nscli000002","type":"Microsoft.EventHub/Namespaces","location":"West - US 2","tags":{"{tag2: value2,":"","tag1: value1}":""},"properties":{"minimumTlsVersion":"1.2","publicNetworkAccess":"Enabled","disableLocalAuth":false,"zoneRedundant":false,"isAutoInflateEnabled":true,"maximumThroughputUnits":4,"kafkaEnabled":true,"provisioningState":"Created","metricId":"326100e2-f69d-4268-8503-075374f62b6e:eventhubs-nscli000002","createdAt":"2023-04-04T02:46:15.94Z","updatedAt":"2023-04-04T02:46:15.94Z","serviceBusEndpoint":"https://eventhubs-nscli000002.servicebus.windows.net:443/","status":"Activating"}}' + US 2","tags":{"{tag1: value1,":"","tag2: value2}":""},"properties":{"minimumTlsVersion":"1.2","publicNetworkAccess":"Enabled","disableLocalAuth":false,"zoneRedundant":false,"isAutoInflateEnabled":true,"maximumThroughputUnits":4,"kafkaEnabled":true,"provisioningState":"Created","metricId":"326100e2-f69d-4268-8503-075374f62b6e:eventhubs-nscli000002","createdAt":"2023-04-04T02:53:09.37Z","updatedAt":"2023-04-04T02:53:09.37Z","serviceBusEndpoint":"https://eventhubs-nscli000002.servicebus.windows.net:443/","status":"Activating"}}' headers: cache-control: - no-cache @@ -34,7 +34,7 @@ interactions: content-type: - application/json; charset=utf-8 date: - - Tue, 04 Apr 2023 02:46:17 GMT + - Tue, 04 Apr 2023 02:53:12 GMT expires: - '-1' pragma: @@ -71,13 +71,13 @@ interactions: ParameterSetName: - --resource-group --name --location --tags --sku --enable-auto-inflate --maximum-throughput-units User-Agent: - - AZURECLI/2.47.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: GET uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002?api-version=2022-01-01-preview response: body: string: '{"sku":{"name":"Standard","tier":"Standard","capacity":1},"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002","name":"eventhubs-nscli000002","type":"Microsoft.EventHub/Namespaces","location":"West - US 2","tags":{"{tag2: value2,":"","tag1: value1}":""},"properties":{"minimumTlsVersion":"1.2","publicNetworkAccess":"Enabled","disableLocalAuth":false,"zoneRedundant":false,"isAutoInflateEnabled":true,"maximumThroughputUnits":4,"kafkaEnabled":true,"provisioningState":"Created","metricId":"326100e2-f69d-4268-8503-075374f62b6e:eventhubs-nscli000002","createdAt":"2023-04-04T02:46:15.94Z","updatedAt":"2023-04-04T02:46:15.94Z","serviceBusEndpoint":"https://eventhubs-nscli000002.servicebus.windows.net:443/","status":"Activating"}}' + US 2","tags":{"{tag1: value1,":"","tag2: value2}":""},"properties":{"minimumTlsVersion":"1.2","publicNetworkAccess":"Enabled","disableLocalAuth":false,"zoneRedundant":false,"isAutoInflateEnabled":true,"maximumThroughputUnits":4,"kafkaEnabled":true,"provisioningState":"Created","metricId":"326100e2-f69d-4268-8503-075374f62b6e:eventhubs-nscli000002","createdAt":"2023-04-04T02:53:09.37Z","updatedAt":"2023-04-04T02:53:09.37Z","serviceBusEndpoint":"https://eventhubs-nscli000002.servicebus.windows.net:443/","status":"Activating"}}' headers: cache-control: - no-cache @@ -86,7 +86,7 @@ interactions: content-type: - application/json; charset=utf-8 date: - - Tue, 04 Apr 2023 02:46:48 GMT + - Tue, 04 Apr 2023 02:53:42 GMT expires: - '-1' pragma: @@ -121,22 +121,22 @@ interactions: ParameterSetName: - --resource-group --name --location --tags --sku --enable-auto-inflate --maximum-throughput-units User-Agent: - - AZURECLI/2.47.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: GET uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002?api-version=2022-01-01-preview response: body: string: '{"sku":{"name":"Standard","tier":"Standard","capacity":1},"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002","name":"eventhubs-nscli000002","type":"Microsoft.EventHub/Namespaces","location":"West - US 2","tags":{"{tag2: value2,":"","tag1: value1}":""},"properties":{"minimumTlsVersion":"1.2","publicNetworkAccess":"Enabled","disableLocalAuth":false,"zoneRedundant":false,"isAutoInflateEnabled":true,"maximumThroughputUnits":4,"kafkaEnabled":true,"provisioningState":"Succeeded","metricId":"326100e2-f69d-4268-8503-075374f62b6e:eventhubs-nscli000002","createdAt":"2023-04-04T02:46:15.94Z","updatedAt":"2023-04-04T02:47:07.71Z","serviceBusEndpoint":"https://eventhubs-nscli000002.servicebus.windows.net:443/","status":"Active"}}' + US 2","tags":{"{tag1: value1,":"","tag2: value2}":""},"properties":{"minimumTlsVersion":"1.2","publicNetworkAccess":"Enabled","disableLocalAuth":false,"zoneRedundant":false,"isAutoInflateEnabled":true,"maximumThroughputUnits":4,"kafkaEnabled":true,"provisioningState":"Succeeded","metricId":"326100e2-f69d-4268-8503-075374f62b6e:eventhubs-nscli000002","createdAt":"2023-04-04T02:53:09.37Z","updatedAt":"2023-04-04T02:53:57.613Z","serviceBusEndpoint":"https://eventhubs-nscli000002.servicebus.windows.net:443/","status":"Active"}}' headers: cache-control: - no-cache content-length: - - '841' + - '842' content-type: - application/json; charset=utf-8 date: - - Tue, 04 Apr 2023 02:47:19 GMT + - Tue, 04 Apr 2023 02:54:13 GMT expires: - '-1' pragma: @@ -171,31 +171,31 @@ interactions: ParameterSetName: - --resource-group --name User-Agent: - - AZURECLI/2.47.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: GET uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002?api-version=2022-01-01-preview response: body: string: '{"sku":{"name":"Standard","tier":"Standard","capacity":1},"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002","name":"eventhubs-nscli000002","type":"Microsoft.EventHub/Namespaces","location":"West - US 2","tags":{"{tag2: value2,":"","tag1: value1}":""},"properties":{"minimumTlsVersion":"1.2","publicNetworkAccess":"Enabled","disableLocalAuth":false,"zoneRedundant":false,"isAutoInflateEnabled":true,"maximumThroughputUnits":4,"kafkaEnabled":true,"provisioningState":"Succeeded","metricId":"326100e2-f69d-4268-8503-075374f62b6e:eventhubs-nscli000002","createdAt":"2023-04-04T02:46:15.94Z","updatedAt":"2023-04-04T02:47:07.71Z","serviceBusEndpoint":"https://eventhubs-nscli000002.servicebus.windows.net:443/","status":"Active"}}' + US 2","tags":{"{tag1: value1,":"","tag2: value2}":""},"properties":{"minimumTlsVersion":"1.2","publicNetworkAccess":"Enabled","disableLocalAuth":false,"zoneRedundant":false,"isAutoInflateEnabled":true,"maximumThroughputUnits":4,"kafkaEnabled":true,"provisioningState":"Succeeded","metricId":"326100e2-f69d-4268-8503-075374f62b6e:eventhubs-nscli000002","createdAt":"2023-04-04T02:53:09.37Z","updatedAt":"2023-04-04T02:53:57.613Z","serviceBusEndpoint":"https://eventhubs-nscli000002.servicebus.windows.net:443/","status":"Active"}}' headers: cache-control: - no-cache content-length: - - '841' + - '842' content-type: - application/json; charset=utf-8 date: - - Tue, 04 Apr 2023 02:47:23 GMT + - Tue, 04 Apr 2023 02:54:16 GMT expires: - '-1' pragma: - no-cache server: - - Service-Bus-Resource-Provider/SN1 + - Service-Bus-Resource-Provider/CH3 - Microsoft-HTTPAPI/2.0 server-sb: - - Service-Bus-Resource-Provider/SN1 + - Service-Bus-Resource-Provider/CH3 strict-transport-security: - max-age=31536000; includeSubDomains transfer-encoding: @@ -225,21 +225,21 @@ interactions: ParameterSetName: - --resource-group --namespace-name --name User-Agent: - - AZURECLI/2.47.0 azsdk-python-azure-mgmt-eventhub/10.1.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 azsdk-python-azure-mgmt-eventhub/10.1.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: PUT uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003?api-version=2022-01-01-preview response: body: - string: '{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003","name":"eventhubs-eventhubcli000003","type":"Microsoft.EventHub/namespaces/eventhubs","location":"westus2","properties":{"messageRetentionInDays":7,"partitionCount":4,"status":"Active","createdAt":"2023-04-04T02:47:27.57Z","updatedAt":"2023-04-04T02:47:27.743Z","partitionIds":["0","1","2","3"]}}' + string: '{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003","name":"eventhubs-eventhubcli000003","type":"Microsoft.EventHub/namespaces/eventhubs","location":"westus2","properties":{"messageRetentionInDays":7,"partitionCount":4,"status":"Active","createdAt":"2023-04-04T02:54:20.413Z","updatedAt":"2023-04-04T02:54:20.537Z","partitionIds":["0","1","2","3"]}}' headers: cache-control: - no-cache content-length: - - '503' + - '504' content-type: - application/json; charset=utf-8 date: - - Tue, 04 Apr 2023 02:47:28 GMT + - Tue, 04 Apr 2023 02:54:20 GMT expires: - '-1' pragma: @@ -273,21 +273,21 @@ interactions: ParameterSetName: - --resource-group --namespace-name --name User-Agent: - - AZURECLI/2.47.0 azsdk-python-azure-mgmt-eventhub/10.1.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 azsdk-python-azure-mgmt-eventhub/10.1.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: GET uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003?api-version=2022-01-01-preview response: body: - string: '{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003","name":"eventhubs-eventhubcli000003","type":"Microsoft.EventHub/namespaces/eventhubs","location":"westus2","properties":{"messageRetentionInDays":7,"partitionCount":4,"status":"Active","createdAt":"2023-04-04T02:47:27.57","updatedAt":"2023-04-04T02:47:27.743","partitionIds":["0","1","2","3"]}}' + string: '{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003","name":"eventhubs-eventhubcli000003","type":"Microsoft.EventHub/namespaces/eventhubs","location":"westus2","properties":{"messageRetentionInDays":7,"partitionCount":4,"status":"Active","createdAt":"2023-04-04T02:54:20.413","updatedAt":"2023-04-04T02:54:20.537","partitionIds":["0","1","2","3"]}}' headers: cache-control: - no-cache content-length: - - '501' + - '502' content-type: - application/json; charset=utf-8 date: - - Tue, 04 Apr 2023 02:47:29 GMT + - Tue, 04 Apr 2023 02:54:23 GMT expires: - '-1' pragma: @@ -323,21 +323,21 @@ interactions: ParameterSetName: - --resource-group --namespace-name --eventhub-name --name --user-metadata User-Agent: - - AZURECLI/2.47.0 azsdk-python-azure-mgmt-eventhub/10.1.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: PUT uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004?api-version=2022-01-01-preview response: body: - string: '{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004","name":"clicg000004","type":"Microsoft.EventHub/namespaces/eventhubs/consumergroups","location":"westus2","properties":{"createdAt":"2023-04-04T02:47:33.1266724Z","updatedAt":"2023-04-04T02:47:33.1266724Z","userMetadata":"usermetadata"}}' + string: '{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004","name":"clicg000004","type":"Microsoft.EventHub/namespaces/eventhubs/consumergroups","location":"westus2","properties":{"createdAt":"2023-04-04T02:54:28.84514Z","updatedAt":"2023-04-04T02:54:28.84514Z","userMetadata":"usermetadata"}}' headers: cache-control: - no-cache content-length: - - '471' + - '467' content-type: - application/json; charset=utf-8 date: - - Tue, 04 Apr 2023 02:47:32 GMT + - Tue, 04 Apr 2023 02:54:28 GMT expires: - '-1' pragma: @@ -371,12 +371,12 @@ interactions: ParameterSetName: - --resource-group --namespace-name --eventhub-name --name User-Agent: - - AZURECLI/2.47.0 azsdk-python-azure-mgmt-eventhub/10.1.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: GET uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004?api-version=2022-01-01-preview response: body: - string: '{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004","name":"clicg000004","type":"Microsoft.EventHub/namespaces/eventhubs/consumergroups","location":"westus2","properties":{"createdAt":"2023-04-04T02:47:33.132Z","updatedAt":"2023-04-04T02:47:33.132Z","userMetadata":"usermetadata"}}' + string: '{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004","name":"clicg000004","type":"Microsoft.EventHub/namespaces/eventhubs/consumergroups","location":"westus2","properties":{"createdAt":"2023-04-04T02:54:28.852Z","updatedAt":"2023-04-04T02:54:28.852Z","userMetadata":"usermetadata"}}' headers: cache-control: - no-cache @@ -385,7 +385,7 @@ interactions: content-type: - application/json; charset=utf-8 date: - - Tue, 04 Apr 2023 02:47:35 GMT + - Tue, 04 Apr 2023 02:54:30 GMT expires: - '-1' pragma: @@ -417,21 +417,21 @@ interactions: ParameterSetName: - --resource-group --namespace-name --eventhub-name --name --user-metadata User-Agent: - - AZURECLI/2.47.0 azsdk-python-azure-mgmt-eventhub/10.1.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: GET uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004?api-version=2022-01-01-preview response: body: - string: '{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004","name":"clicg000004","type":"Microsoft.EventHub/namespaces/eventhubs/consumergroups","location":"westus2","properties":{"createdAt":"2023-04-04T02:47:33.13Z","updatedAt":"2023-04-04T02:47:33.13Z","userMetadata":"usermetadata"}}' + string: '{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004","name":"clicg000004","type":"Microsoft.EventHub/namespaces/eventhubs/consumergroups","location":"westus2","properties":{"createdAt":"2023-04-04T02:54:28.846Z","updatedAt":"2023-04-04T02:54:28.846Z","userMetadata":"usermetadata"}}' headers: cache-control: - no-cache content-length: - - '461' + - '463' content-type: - application/json; charset=utf-8 date: - - Tue, 04 Apr 2023 02:47:37 GMT + - Tue, 04 Apr 2023 02:54:32 GMT expires: - '-1' pragma: @@ -467,12 +467,12 @@ interactions: ParameterSetName: - --resource-group --namespace-name --eventhub-name --name --user-metadata User-Agent: - - AZURECLI/2.47.0 azsdk-python-azure-mgmt-eventhub/10.1.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: PUT uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004?api-version=2022-01-01-preview response: body: - string: '{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004","name":"clicg000004","type":"Microsoft.EventHub/namespaces/eventhubs/consumergroups","location":"westus2","properties":{"createdAt":"2023-04-04T02:47:39.6338333Z","updatedAt":"2023-04-04T02:47:39.6338333Z","userMetadata":"usermetadata-updated"}}' + string: '{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004","name":"clicg000004","type":"Microsoft.EventHub/namespaces/eventhubs/consumergroups","location":"westus2","properties":{"createdAt":"2023-04-04T02:54:34.0957811Z","updatedAt":"2023-04-04T02:54:34.0957811Z","userMetadata":"usermetadata-updated"}}' headers: cache-control: - no-cache @@ -481,7 +481,7 @@ interactions: content-type: - application/json; charset=utf-8 date: - - Tue, 04 Apr 2023 02:47:39 GMT + - Tue, 04 Apr 2023 02:54:33 GMT expires: - '-1' pragma: @@ -515,12 +515,12 @@ interactions: ParameterSetName: - --resource-group --namespace-name --eventhub-name User-Agent: - - AZURECLI/2.47.0 azsdk-python-azure-mgmt-eventhub/10.1.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: GET uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups?api-version=2022-01-01-preview response: body: - string: '{"value":[{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/$Default","name":"$Default","type":"Microsoft.EventHub/namespaces/eventhubs/consumergroups","location":"westus2","properties":{"createdAt":"2023-04-04T02:47:27.597Z","updatedAt":"2023-04-04T02:47:27.597Z"}},{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004","name":"clicg000004","type":"Microsoft.EventHub/namespaces/eventhubs/consumergroups","location":"westus2","properties":{"createdAt":"2023-04-04T02:47:33.129Z","updatedAt":"2023-04-04T02:47:39.676Z","userMetadata":"usermetadata-updated"}}]}' + string: '{"value":[{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/$Default","name":"$Default","type":"Microsoft.EventHub/namespaces/eventhubs/consumergroups","location":"westus2","properties":{"createdAt":"2023-04-04T02:54:20.424Z","updatedAt":"2023-04-04T02:54:20.424Z"}},{"id":"/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004","name":"clicg000004","type":"Microsoft.EventHub/namespaces/eventhubs/consumergroups","location":"westus2","properties":{"createdAt":"2023-04-04T02:54:28.846Z","updatedAt":"2023-04-04T02:54:34.159Z","userMetadata":"usermetadata-updated"}}]}' headers: cache-control: - no-cache @@ -529,7 +529,7 @@ interactions: content-type: - application/json; charset=utf-8 date: - - Tue, 04 Apr 2023 02:47:41 GMT + - Tue, 04 Apr 2023 02:54:36 GMT expires: - '-1' pragma: @@ -553,7 +553,7 @@ interactions: body: null headers: Accept: - - application/json + - '*/*' Accept-Encoding: - gzip, deflate CommandName: @@ -565,7 +565,7 @@ interactions: ParameterSetName: - --resource-group --namespace-name --eventhub-name --name User-Agent: - - AZURECLI/2.47.0 azsdk-python-azure-mgmt-eventhub/10.1.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: DELETE uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003/consumergroups/clicg000004?api-version=2022-01-01-preview response: @@ -577,7 +577,7 @@ interactions: content-length: - '0' date: - - Tue, 04 Apr 2023 02:47:44 GMT + - Tue, 04 Apr 2023 02:54:38 GMT expires: - '-1' pragma: @@ -609,7 +609,7 @@ interactions: ParameterSetName: - --resource-group --namespace-name --name User-Agent: - - AZURECLI/2.47.0 azsdk-python-azure-mgmt-eventhub/10.1.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 azsdk-python-azure-mgmt-eventhub/10.1.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: DELETE uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002/eventhubs/eventhubs-eventhubcli000003?api-version=2022-01-01-preview response: @@ -621,7 +621,7 @@ interactions: content-length: - '0' date: - - Tue, 04 Apr 2023 02:47:48 GMT + - Tue, 04 Apr 2023 02:54:42 GMT expires: - '-1' pragma: @@ -653,7 +653,7 @@ interactions: ParameterSetName: - --resource-group --name User-Agent: - - AZURECLI/2.47.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: DELETE uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/namespaces/eventhubs-nscli000002?api-version=2022-01-01-preview response: @@ -665,7 +665,7 @@ interactions: content-length: - '0' date: - - Tue, 04 Apr 2023 02:47:51 GMT + - Tue, 04 Apr 2023 02:54:45 GMT expires: - '-1' location: @@ -700,7 +700,7 @@ interactions: ParameterSetName: - --resource-group --name User-Agent: - - AZURECLI/2.47.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) + - AZURECLI/2.46.0 (AAZ) azsdk-python-core/1.24.0 Python/3.8.10 (Windows-10-10.0.22621-SP0) method: GET uri: https://management.azure.com/subscriptions/00000000-0000-0000-0000-000000000000/resourcegroups/cli_test_eh_consumergroup000001/providers/Microsoft.EventHub/locations/westus2/operationStatus/eventhubs-nscli000002?api-version=2022-01-01-preview&resourceType=Namespace response: @@ -710,7 +710,7 @@ interactions: cache-control: - no-cache date: - - Tue, 04 Apr 2023 02:48:22 GMT + - Tue, 04 Apr 2023 02:55:16 GMT expires: - '-1' pragma: