def METHOD_NAME(self, resource_group, location):
    account_name = self.get_resource_name('iot')
    async_iot_hub = self.iothub_client.iot_hub_resource.begin_create_or_update(
        resource_group.name,
        account_name,
        {
            'location': location,
            'subscriptionid': self.get_settings_value("SUBSCRIPTION_ID"),
            'resourcegroup': resource_group.name,
            'sku': {
              'name': 'S1',
              'capacity': 2
            },
            'properties': {
              'enable_file_upload_notifications': False,
              'operations_monitoring_properties': {
                'events': {
                  "C2DCommands": "Error",
                  "DeviceTelemetry": "Error",
                  "DeviceIdentityOperations": "Error",
                  "Connections": "Information"
                }
              },
              "features": "None",
            }
        }
    )
    async_iot_hub.wait()
    cg_account_name = self.get_resource_name('consumergrp')
    consumer_group = self.iothub_client.iot_hub_resource.create_event_hub_consumer_group(
        resource_group.name,
        account_name,
        'events',
        cg_account_name
    )
    consumer_group = self.iothub_client.iot_hub_resource.get_event_hub_consumer_group(
        resource_group.name,
        account_name,
        'events',
        consumer_group.name
    )
    consumer_groups = list(self.iothub_client.iot_hub_resource.list_event_hub_consumer_groups(
        resource_group.name,
        account_name,
        'events'
    ))
    assert any(group.name == consumer_group.name for group in consumer_groups)
    self.iothub_client.iot_hub_resource.delete_event_hub_consumer_group(
        resource_group.name,
        account_name,
        'events',
        consumer_group.name
    )