d288a28589
Usually, we should import an option before we use it, otherwise, NoSuchOpt exception will be raised. When we import a module, the options in that module are registered, (or imported), so we don't need to explicitly import them again. However, it is a bit hard for developers, reviewers and maintainers to track between files just to check if a specific option is imported or not. So it is good (not required) whenever we use an option, we import it explicitly, such kind of redundant is acceptable. But not the case that we already import a module A, then import_opt|group registered or imported in that module again, this is obviously unnecessary and should be avoid. Change-Id: I8672d9f12d862f9a622e5557d9c8dc2fe6717f5e Closes-Bug: #1389229
44 lines
1.4 KiB
Python
44 lines
1.4 KiB
Python
# -*- encoding: utf-8 -*-
|
|
#
|
|
# Copyright 2014 OpenStack Foundation
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
import logging
|
|
|
|
from oslo.config import cfg
|
|
|
|
from ceilometer.i18n import _
|
|
from ceilometer import service
|
|
from ceilometer import storage
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
|
|
|
|
def dbsync():
|
|
service.prepare_service()
|
|
storage.get_connection_from_config(cfg.CONF, 'metering').upgrade()
|
|
storage.get_connection_from_config(cfg.CONF, 'alarm').upgrade()
|
|
storage.get_connection_from_config(cfg.CONF, 'event').upgrade()
|
|
|
|
|
|
def expirer():
|
|
service.prepare_service()
|
|
if cfg.CONF.database.time_to_live > 0:
|
|
LOG.debug(_("Clearing expired metering data"))
|
|
storage_conn = storage.get_connection_from_config(cfg.CONF)
|
|
storage_conn.clear_expired_metering_data(
|
|
cfg.CONF.database.time_to_live)
|
|
else:
|
|
LOG.info(_("Nothing to clean, database time to live is disabled"))
|