x
/
distil
Code Issues Proposed changes

Dn not update some resource properties for each period 

Change-Id: I2f27dd11c516d34d8c914191f72034c91fe7d517
Closes-Bug: #1599308
This commit is contained in:
Lingxian Kong 2016-07-06 10:42:16 +12:00
parent ab768cf012
commit 834765a2d7
2 changed files with 18 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
distil/collector/base.py
View File

@ -138,7 +138,7 @@ class BaseCollector(object):
return os_distro
def _get_resource_info(self, resource_id, resource_type, entry,
def _get_resource_info(self, project_id, resource_id, resource_type, entry,
defined_meta):
resource_info = {'type': resource_type}
@ -156,13 +156,15 @@ class BaseCollector(object):
# Or value isn't present.
pass
if resource_type == 'Virtual Machine':
resource_info['os_distro'] = self._get_os_distro(entry)
if resource_type == 'Object Storage Container':
# NOTE(flwang): It's safe to get container name by /, since
# Swift doesn't allow container name with /.
idx = resource_id.index('/') + 1
resource_info['name'] = resource_id[idx:]
# If the resource is already created, don't update properties below.
if not db_api.resource_get_by_ids(project_id, [resource_id]):
if resource_type == 'Virtual Machine':
resource_info['os_distro'] = self._get_os_distro(entry)
if resource_type == 'Object Storage Container':
# NOTE(flwang): It's safe to get container name by /, since
# Swift doesn't allow container name with /.
idx = resource_id.index('/') + 1
resource_info['name'] = resource_id[idx:]
return resource_info
@ -181,19 +183,16 @@ class BaseCollector(object):
if transformed:
res_id = mapping.get('res_id_template', '%s') % res_id
res_info = self._get_resource_info(
project_id,
res_id,
mapping['type'],
entries[-1],
mapping['metadata']
)
new_res = {
'tenant_id': project_id,
'info': res_info
}
res = resources.setdefault(res_id, new_res)
res.update({'info': res_info})
LOG.debug('resource: %s', res)
res = resources.setdefault(res_id, res_info)
res.update(res_info)
LOG.debug('resource info: %s', res)
for service, volume in transformed.items():
entry = {

7
distil/db/sqlalchemy/api.py
View File

@ -221,14 +221,15 @@ def usages_add(project_id, resources, usage_entries, last_collect):
try:
with session.begin(subtransactions=True):
for (id, res) in six.iteritems(resources):
for (id, res_info) in six.iteritems(resources):
res_db = _get_resource(session, project_id, id)
if res_db:
res_db.info = json.dumps(res['info'])
orig_info = json.loads(res_db.info)
res_db.info = json.dumps(orig_info.update(res_info))
else:
resource_ref = Resource(
id=id,
info=json.dumps(res['info']),
info=json.dumps(res_info),
tenant_id=project_id,
created=timestamp
)