diff --git a/ceilometer/compute/pollsters/net.py b/ceilometer/compute/pollsters/net.py index 00fb40d9e4..117c2fd2c6 100644 --- a/ceilometer/compute/pollsters/net.py +++ b/ceilometer/compute/pollsters/net.py @@ -24,6 +24,7 @@ from oslo.utils import timeutils import ceilometer from ceilometer.compute import plugin from ceilometer.compute.pollsters import util +from ceilometer.compute import util as compute_util from ceilometer.compute.virt import inspector as virt_inspector from ceilometer.openstack.common.gettextutils import _ from ceilometer.openstack.common import log @@ -45,6 +46,9 @@ class _Base(plugin.ComputePollster): resource_metadata['instance_type'] = (instance.flavor['id'] if instance.flavor else None) + compute_util.add_reserved_user_metadata(instance.metadata, + resource_metadata) + if vnic_data.fref is not None: rid = vnic_data.fref else: diff --git a/ceilometer/tests/compute/pollsters/test_net.py b/ceilometer/tests/compute/pollsters/test_net.py index 44bb584705..26a157a8d7 100644 --- a/ceilometer/tests/compute/pollsters/test_net.py +++ b/ceilometer/tests/compute/pollsters/test_net.py @@ -22,9 +22,23 @@ import mock from ceilometer.compute import manager from ceilometer.compute.pollsters import net from ceilometer.compute.virt import inspector as virt_inspector +from ceilometer import sample from ceilometer.tests.compute.pollsters import base +class FauxInstance(object): + + def __init__(self, **kwargs): + for name, value in kwargs.items(): + setattr(self, name, value) + + def __getitem__(self, key): + return getattr(self, key) + + def get(self, key, default): + return getattr(self, key, default) + + class TestNetPollster(base.TestPollsterBase): def setUp(self): @@ -67,6 +81,37 @@ class TestNetPollster(base.TestPollsterBase): ] self.inspector.inspect_vnics = mock.Mock(return_value=vnics) + self.INSTANCE_PROPERTIES = {'name': 'display name', + 'OS-EXT-SRV-ATTR:instance_name': + 'instance-000001', + 'OS-EXT-AZ:availability_zone': 'foo-zone', + 'reservation_id': 'reservation id', + 'id': 'instance id', + 'user_id': 'user id', + 'tenant_id': 'tenant id', + 'architecture': 'x86_64', + 'kernel_id': 'kernel id', + 'os_type': 'linux', + 'ramdisk_id': 'ramdisk id', + 'status': 'active', + 'ephemeral_gb': 0, + 'root_gb': 20, + 'disk_gb': 20, + 'image': {'id': 1, + 'links': [{"rel": "bookmark", + 'href': 2}]}, + 'hostId': '1234-5678', + 'flavor': {'id': 1, + 'disk': 20, + 'ram': 512, + 'vcpus': 2, + 'ephemeral': 0}, + 'metadata': {'metering.autoscale.group': + 'X' * 512, + 'metering.ephemeral_gb': 42}} + + self.faux_instance = FauxInstance(**self.INSTANCE_PROPERTIES) + @mock.patch('ceilometer.pipeline.setup_pipeline', mock.MagicMock()) def _check_get_samples(self, factory, expected): mgr = manager.AgentManager() @@ -132,6 +177,23 @@ class TestNetPollster(base.TestPollsterBase): ], ) + @mock.patch('ceilometer.pipeline.setup_pipeline', mock.MagicMock()) + def test_metadata(self): + factory = net.OutgoingBytesPollster + pollster = factory() + sm = pollster.make_vnic_sample(self.faux_instance, + name='network.outgoing.bytes', + type=sample.TYPE_CUMULATIVE, + unit='B', + volume=100, + vnic_data=self.vnic0) + + user_metadata = sm.resource_metadata['user_metadata'] + expected = self.INSTANCE_PROPERTIES[ + 'metadata']['metering.autoscale.group'][:256] + self.assertEqual(expected, user_metadata['autoscale_group']) + self.assertEqual(2, len(user_metadata)) + class TestNetPollsterCache(base.TestPollsterBase):