azure-mgmt-eventhub/azure/mgmt/eventhub/operations/consumer_groups_operations.py
def create_or_update(
            self, resource_group_name, namespace_name, event_hub_name, consumer_group_name, user_metadata=None, custom_headers=None, raw=False, **operation_config):
        """Creates or updates an Event Hubs consumer group as a nested resource
        within a Namespace.

        :param resource_group_name: Name of the resource group within the
         azure subscription.
        :type resource_group_name: str
        :param namespace_name: The Namespace name
        :type namespace_name: str
        :param event_hub_name: The Event Hub name
        :type event_hub_name: str
        :param consumer_group_name: The consumer group name
        :type consumer_group_name: str
        :param user_metadata: 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.
        :type user_metadata: str
        :param dict custom_headers: headers that will be added to the request
        :param bool raw: returns the direct response alongside the
         deserialized response
        :param operation_config: :ref:`Operation configuration
         overrides<msrest:optionsforoperations>`.
        :return: ConsumerGroup or ClientRawResponse if raw=true
        :rtype: ~azure.mgmt.eventhub.models.ConsumerGroup or
         ~msrest.pipeline.ClientRawResponse
        :raises:
         :class:`ErrorResponseException<azure.mgmt.eventhub.models.ErrorResponseException>`
        """
        parameters = models.ConsumerGroup(user_metadata=user_metadata)

        # Construct URL
        url = '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventhubs/{eventHubName}/consumergroups/{consumerGroupName}'
        path_format_arguments = {
            'resourceGroupName': self._serialize.url("resource_group_name", resource_group_name, 'str', max_length=90, min_length=1),
            'namespaceName': self._serialize.url("namespace_name", namespace_name, 'str', max_length=50, min_length=6),
            'eventHubName': self._serialize.url("event_hub_name", event_hub_name, 'str', min_length=1),
            'consumerGroupName': self._serialize.url("consumer_group_name", consumer_group_name, 'str', max_length=50, min_length=1),
            'subscriptionId': self._serialize.url("self.config.subscription_id", self.config.subscription_id, 'str')
        }
        url = self._client.format_url(url, **path_format_arguments)

        # Construct parameters
        query_parameters = {}
        query_parameters['api-version'] = self._serialize.query("self.api_version", self.api_version, 'str')

        # Construct headers
        header_parameters = {}
        header_parameters['Content-Type'] = 'application/json; charset=utf-8'
        if self.config.generate_client_request_id:
            header_parameters['x-ms-client-request-id'] = str(uuid.uuid1())
        if custom_headers:
            header_parameters.update(custom_headers)
        if self.config.accept_language is not None:
            header_parameters['accept-language'] = self._serialize.header("self.config.accept_language", self.config.accept_language, 'str')

        # Construct body
        body_content = self._serialize.body(parameters, 'ConsumerGroup')

        # Construct and send request
        request = self._client.put(url, query_parameters)
        response = self._client.send(
            request, header_parameters, body_content, stream=False, **operation_config)

        if response.status_code not in [200]:
            raise models.ErrorResponseException(self._deserialize, response)

        deserialized = None

        if response.status_code == 200:
            deserialized = self._deserialize('ConsumerGroup', response)

        if raw:
            client_raw_response = ClientRawResponse(deserialized, response)
            return client_raw_response

        return deserialized
Creates or updates an Event Hubs consumer group as a nested resource
        within a Namespace.

        :param resource_group_name: Name of the resource group within the
         azure subscription.
        :type resource_group_name: str
        :param namespace_name: The Namespace name
        :type namespace_name: str
        :param event_hub_name: The Event Hub name
        :type event_hub_name: str
        :param consumer_group_name: The consumer group name
        :type consumer_group_name: str
        :param user_metadata: 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.
        :type user_metadata: str
        :param dict custom_headers: headers that will be added to the request
        :param bool raw: returns the direct response alongside the
         deserialized response
        :param operation_config: :ref:`Operation configuration
         overrides<msrest:optionsforoperations>`.
        :return: ConsumerGroup or ClientRawResponse if raw=true
        :rtype: ~azure.mgmt.eventhub.models.ConsumerGroup or
         ~msrest.pipeline.ClientRawResponse
        :raises:
         :class:`ErrorResponseException<azure.mgmt.eventhub.models.ErrorResponseException>`
        
Creates or updates an Event Hubs consumer group as a nested resource
within a Namespace.
Creates or updates an Event Hubs consumer group as a nested resource within a Namespace .
def create_or_update(
            self, resource_group_name, namespace_name, event_hub_name, consumer_group_name, user_metadata=None, custom_headers=None, raw=False, **operation_config):
        parameters = models.ConsumerGroup(user_metadata=user_metadata)
        url = '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventhubs/{eventHubName}/consumergroups/{consumerGroupName}'
        path_format_arguments = {
            'resourceGroupName': self._serialize.url("resource_group_name", resource_group_name, 'str', max_length=90, min_length=1),
            'namespaceName': self._serialize.url("namespace_name", namespace_name, 'str', max_length=50, min_length=6),
            'eventHubName': self._serialize.url("event_hub_name", event_hub_name, 'str', min_length=1),
            'consumerGroupName': self._serialize.url("consumer_group_name", consumer_group_name, 'str', max_length=50, min_length=1),
            'subscriptionId': self._serialize.url("self.config.subscription_id", self.config.subscription_id, 'str')
        }
        url = self._client.format_url(url, **path_format_arguments)
        query_parameters = {}
        query_parameters['api-version'] = self._serialize.query("self.api_version", self.api_version, 'str')
        header_parameters = {}
        header_parameters['Content-Type'] = 'application/json; charset=utf-8'
        if self.config.generate_client_request_id:
            header_parameters['x-ms-client-request-id'] = str(uuid.uuid1())
        if custom_headers:
            header_parameters.update(custom_headers)
        if self.config.accept_language is not None:
            header_parameters['accept-language'] = self._serialize.header("self.config.accept_language", self.config.accept_language, 'str')
        body_content = self._serialize.body(parameters, 'ConsumerGroup')
        request = self._client.put(url, query_parameters)
        response = self._client.send(
            request, header_parameters, body_content, stream=False, **operation_config)
        if response.status_code not in [200]:
            raise models.ErrorResponseException(self._deserialize, response)
        deserialized = None
        if response.status_code == 200:
            deserialized = self._deserialize('ConsumerGroup', response)
        if raw:
            client_raw_response = ClientRawResponse(deserialized, response)
            return client_raw_response
        return deserialized
def create_or_update ( self , resource_group_name , namespace_name , event_hub_name , consumer_group_name , user_metadata = None , custom_headers = None , raw = False , ** operation_config ) : parameters = models . ConsumerGroup ( user_metadata = user_metadata ) url = '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.EventHub/namespaces/{namespaceName}/eventhubs/{eventHubName}/consumergroups/{consumerGroupName}' path_format_arguments = { 'resourceGroupName' : self . _serialize . url ( "resource_group_name" , resource_group_name , 'str' , max_length = 90 , min_length = 1 ) , 'namespaceName' : self . _serialize . url ( "namespace_name" , namespace_name , 'str' , max_length = 50 , min_length = 6 ) , 'eventHubName' : self . _serialize . url ( "event_hub_name" , event_hub_name , 'str' , min_length = 1 ) , 'consumerGroupName' : self . _serialize . url ( "consumer_group_name" , consumer_group_name , 'str' , max_length = 50 , min_length = 1 ) , 'subscriptionId' : self . _serialize . url ( "self.config.subscription_id" , self . config . subscription_id , 'str' ) } url = self . _client . format_url ( url , ** path_format_arguments ) query_parameters = { } query_parameters [ 'api-version' ] = self . _serialize . query ( "self.api_version" , self . api_version , 'str' ) header_parameters = { } header_parameters [ 'Content-Type' ] = 'application/json; charset=utf-8' if self . config . generate_client_request_id : header_parameters [ 'x-ms-client-request-id' ] = str ( uuid . uuid1 ( ) ) if custom_headers : header_parameters . update ( custom_headers ) if self . config . accept_language is not None : header_parameters [ 'accept-language' ] = self . _serialize . header ( "self.config.accept_language" , self . config . accept_language , 'str' ) body_content = self . _serialize . body ( parameters , 'ConsumerGroup' ) request = self . _client . put ( url , query_parameters ) response = self . _client . send ( request , header_parameters , body_content , stream = False , ** operation_config ) if response . status_code not in [ 200 ] : raise models . ErrorResponseException ( self . _deserialize , response ) deserialized = None if response . status_code == 200 : deserialized = self . _deserialize ( 'ConsumerGroup' , response ) if raw : client_raw_response = ClientRawResponse ( deserialized , response ) return client_raw_response return deserialized
Creates or updates an Event Hubs consumer group as a nested resource
within a Namespace.
Creates or updates an Event Hubs consumer group as a nested resource within a Namespace .
"""Creates or updates an Event Hubs consumer group as a nested resource
        within a Namespace.

        :param resource_group_name: Name of the resource group within the
         azure subscription.
        :type resource_group_name: str
        :param namespace_name: The Namespace name
        :type namespace_name: str
        :param event_hub_name: The Event Hub name
        :type event_hub_name: str
        :param consumer_group_name: The consumer group name
        :type consumer_group_name: str
        :param user_metadata: 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.
        :type user_metadata: str
        :param dict custom_headers: headers that will be added to the request
        :param bool raw: returns the direct response alongside the
         deserialized response
        :param operation_config: :ref:`Operation configuration
         overrides<msrest:optionsforoperations>`.
        :return: ConsumerGroup or ClientRawResponse if raw=true
        :rtype: ~azure.mgmt.eventhub.models.ConsumerGroup or
         ~msrest.pipeline.ClientRawResponse
        :raises:
         :class:`ErrorResponseException<azure.mgmt.eventhub.models.ErrorResponseException>`
        """ # Construct URL # Construct parameters # Construct headers # Construct body # Construct and send request
ConsumerGroup or ClientRawResponse if raw=true
ConsumerGroup or ClientRawResponse if raw = true
~azure.mgmt.eventhub.models.ConsumerGroup or
~msrest.pipeline.ClientRawResponse
None
self
resource_group_name
Name of the resource group within the
azure subscription.
Name of the resource group within the azure subscription .
namespace_name
The Namespace name
The Namespace name
event_hub_name
The Event Hub name
The Event Hub name
consumer_group_name
The consumer group name
The consumer group name
user_metadata
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.
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 .
custom_headers
headers that will be added to the request
headers that will be added to the request
raw
returns the direct response alongside the
deserialized response
returns the direct response alongside the deserialized response
operation_config
:ref:`Operation configuration
overrides`.
: ref : ` Operation configuration overrides ` .