3668a76fe4
The __future__ module [1] was used in this context to ensure compatibility between python 2 and python 3. We previously dropped the support of python 2.7 [2] and now we only support python 3 so we don't need to continue to use this module and the imports listed below. Imports commonly used and their related PEPs: - `division` is related to PEP 238 [3] - `print_function` is related to PEP 3105 [4] - `unicode_literals` is related to PEP 3112 [5] - `with_statement` is related to PEP 343 [6] - `absolute_import` is related to PEP 328 [7] [1] https://docs.python.org/3/library/__future__.html [2] https://governance.openstack.org/tc/goals/selected/ussuri/drop-py27.html [3] https://www.python.org/dev/peps/pep-0238 [4] https://www.python.org/dev/peps/pep-3105 [5] https://www.python.org/dev/peps/pep-3112 [6] https://www.python.org/dev/peps/pep-0343 [7] https://www.python.org/dev/peps/pep-0328 Change-Id: I74f1cce5430d81aa7dad08920baa9d771271f871
113 lines
3.7 KiB
Python
113 lines
3.7 KiB
Python
# -*- coding: utf-8 -*-
|
|
# Copyright 2014 Objectif Libre
|
|
#
|
|
# 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.
|
|
#
|
|
|
|
from oslo_config import cfg
|
|
from oslo_utils import importutils as i_utils
|
|
|
|
from cloudkitty import config # noqa
|
|
from cloudkitty import service
|
|
from cloudkitty import storage
|
|
from cloudkitty import utils as ck_utils
|
|
from cloudkitty import write_orchestrator
|
|
|
|
CONF = cfg.CONF
|
|
CONF.import_opt('period', 'cloudkitty.collector', 'collect')
|
|
CONF.import_opt('backend', 'cloudkitty.config', 'output')
|
|
CONF.import_opt('basepath', 'cloudkitty.config', 'output')
|
|
STORAGES_NAMESPACE = 'cloudkitty.storage.backends'
|
|
|
|
|
|
class DBCommand(object):
|
|
|
|
def __init__(self):
|
|
self._storage = None
|
|
self._output = None
|
|
self._load_storage_backend()
|
|
self._load_output_backend()
|
|
|
|
def _load_storage_backend(self):
|
|
self._storage = storage.get_storage()
|
|
|
|
def _load_output_backend(self):
|
|
backend = i_utils.import_class(CONF.output.backend)
|
|
self._output = backend
|
|
|
|
def generate(self):
|
|
if not CONF.command.tenant:
|
|
if not CONF.command.begin:
|
|
CONF.command.begin = ck_utils.get_month_start()
|
|
if not CONF.command.end:
|
|
CONF.command.end = ck_utils.get_next_month()
|
|
tenants = self._storage.get_tenants(CONF.command.begin,
|
|
CONF.command.end)
|
|
else:
|
|
tenants = [CONF.command.tenant]
|
|
for tenant in tenants:
|
|
wo = write_orchestrator.WriteOrchestrator(self._output,
|
|
tenant,
|
|
self._storage,
|
|
CONF.output.basepath)
|
|
wo.init_writing_pipeline()
|
|
if not CONF.command.begin:
|
|
wo.restart_month()
|
|
wo.process()
|
|
|
|
def tenants_list(self):
|
|
if not CONF.command.begin:
|
|
CONF.command.begin = ck_utils.get_month_start()
|
|
if not CONF.command.end:
|
|
CONF.command.end = ck_utils.get_next_month()
|
|
tenants = self._storage.get_tenants(CONF.command.begin,
|
|
CONF.command.end)
|
|
print('Tenant list:')
|
|
for tenant in tenants:
|
|
print(tenant)
|
|
|
|
|
|
def call_generate(command_object):
|
|
command_object.generate()
|
|
|
|
|
|
def call_tenants_list(command_object):
|
|
command_object.tenants_list()
|
|
|
|
|
|
def add_command_parsers(subparsers):
|
|
parser = subparsers.add_parser('generate')
|
|
parser.set_defaults(func=call_generate)
|
|
parser.add_argument('--tenant', nargs='?')
|
|
parser.add_argument('--begin', nargs='?')
|
|
parser.add_argument('--end', nargs='?')
|
|
|
|
parser = subparsers.add_parser('tenants_list')
|
|
parser.set_defaults(func=call_tenants_list)
|
|
parser.add_argument('--begin', nargs='?')
|
|
parser.add_argument('--end', nargs='?')
|
|
|
|
|
|
command_opt = cfg.SubCommandOpt('command',
|
|
title='Command',
|
|
help='Available commands',
|
|
handler=add_command_parsers)
|
|
|
|
CONF.register_cli_opt(command_opt)
|
|
|
|
|
|
def main():
|
|
service.prepare_service()
|
|
command_object = DBCommand()
|
|
CONF.command.func(command_object)
|