C///

\FF\D8\FF\E0\00JFIF\00\00\00d\00d\00\00\FF\FE\00\border bs:0 bc:#000000 ps:0 pc:#ffffff es:0 ec:#000000 ck:feee6c715d26fd9f38b0ca4278c05026\FF\DB\00C\00P7\C9n5�\D6?\BD�\9Ds\EBp\9F[`8m\B7)o\B5\E8\E6I\99\FE3]]A2\BA\8Cw\D6E\93\\DEv\C8\009\F2\F1NI?uc\\F5\EA\96k\xN<~buv\EA\C8\D7 \8B\84\CEcxI\BBg\AE\9E=\D6+n\EC\80\C8A\8C\AE\EB\CF\D5\DA\E9"2\A4\B9j5\EB\F3W\B63\96\B30Yu\DA\FC8\ED\DF\E7Ms\FB\F1\8E\B3\FA\EA\E8\E6(\883zs\F2_\8DFk\8Bh \00\8C\DCw\D3R\B5+6X\BA\B2\C4j\AB0\B4\FCMw\C2I\8E\9B\E3\A9~9u\FA\D3l\80\C8%p\EE\FDn2� \00$\FEj\C4e\A9\DB\~\95\A7\A5\80EK\BB\8DDsP\00@@AD'k\CF\E8\DB\D2(\80\9AK\D3\85\D6lb\F2\BA\8C*\80\00)\95 59\A3R:\F3\CE"\B6\80\88\00\00i1u4�\E9\F2�\A6\A2\FACM\93WMb*\E0*\00\00\00\00\00(\A8\80\00\00\80\00\00\00\00\00\00\00\00\00\FF\D9 C/// # coding=utf-8 # # Copyright © Cloud Linux GmbH & Cloud Linux Software, Inc 2010-2023 All Rights Reserved # # Licensed under CLOUD LINUX LICENSE AGREEMENT # http://cloudlinux.com/docs/LICENSE.TXT import argparse import itertools import logging import sys from datetime import datetime, timedelta, timezone import sqlalchemy as sa from sqlalchemy.exc import OperationalError, ProgrammingError import lvestats.lib.commons.decorators from lvestats.lib.bursting.history import HistoryShowBursting, TableDoesNotExistError from lvestats.lib.commons.argparse_utils import ParseDatetime, check_non_negative_int from lvestats.lib.commons.dateutil import gm_to_local, local_to_gm from lvestats.lib.commons.func import get_ascii_table from lvestats.lib.commons.logsetup import setup_logging from lvestats.lib.config import ConfigError, read_config from lvestats.lib.dbengine import make_db_engine, MakeDbException from lvestats.orm import BurstingEventType, bursting_events_table from lvestats.plugins.generic.burster.config import is_bursting_supported log = setup_logging({}, caller_name='lve-bursting-info', file_level=logging.WARNING, console_level=logging.ERROR) @lvestats.lib.commons.decorators.no_sigpipe def main() -> None: if not is_bursting_supported(): print('Bursting Limits feature is not supported in current environment') sys.exit(1) try: cfg = read_config() dbengine = make_db_engine(cfg=cfg) output = _main(cfg, dbengine, sys.argv[1:]) if output: print(output) except TableDoesNotExistError as e: print(e.message) print('Enable Bursting Limits feature to create the table') sys.exit(1) except (OperationalError, ProgrammingError, ConfigError, MakeDbException) as e: log.error('Error occurred while executing the "lve-bursting-info" utility', exc_info=e) sys.exit(1) def _main(config: dict[str, str], dbengine: sa.engine.base.Engine, argv: list[str]) -> str: namespace = _parse_args(config, argv) # Convert date and time to UTC period_from_utc = local_to_gm(getattr(namespace, 'from')) # 'from' is a reserved word period_to_utc = local_to_gm(namespace.to) history_show = HistoryShowBursting( dbengine=dbengine, period_from=period_from_utc, period_to=period_to_utc, uid=namespace.id, server_id=namespace.server_id, ) rows = history_show.get() table = _build_table(rows, period_from_utc, period_to_utc) return table def _parse_args(config: dict[str, str], argv: list[str]) -> argparse.Namespace: parser = argparse.ArgumentParser( description="Utility for displaying bursting limits statistics") parser.add_argument( '--id', type=check_non_negative_int, help='display records only for the specified LVE id') parser.add_argument( '--server-id', type=str, default=config.get('server_id', 'localhost'), help='used with central database for multiple servers, default "%(default)s"') # filtering output data by time period group_period = parser.add_argument_group() datetime_now = datetime.now() # default time delta is 1 hour # if the value is modified, don't forget to fix the CLI message default_timedelta = timedelta(hours=1) group_period.add_argument( '-f', '--from', action=ParseDatetime, default=datetime_now - default_timedelta, nargs='+', help='display records from the specified date and time; ' 'if not provided, will assume the last 1-hour time frame', metavar='YYYY-MM-DD[ HH:MM]') group_period.add_argument( '-t', '--to', action=ParseDatetime, default=datetime_now, nargs='+', help='display records up to the specified date and time; ' 'if not provided, will include records up to the current time', metavar='YYYY-MM-DD[ HH:MM]') return parser.parse_args(argv) def _build_table(rows: list[sa.engine.RowProxy], dt_from: datetime, dt_to: datetime) -> str: """ Build string representation of a console-displayable table using the rows retrieved from the DB table. """ table_rows = _build_table_rows(rows, dt_from.timestamp(), dt_to.timestamp()) table = get_ascii_table(table_rows, fields=['ID', 'From', 'To'], padding_width=1) return table class TableRow(list): DEFAULT_FORMAT = '%Y-%m-%d %H:%M:%S.%f' def __init__(self, lve_id: int, start: float, end: float, format_: str = DEFAULT_FORMAT): # Convert date and time to local dt_start = gm_to_local(datetime.fromtimestamp(start, timezone.utc)) dt_end = gm_to_local(datetime.fromtimestamp(end, timezone.utc)) super().__init__([lve_id, dt_start.strftime(format_),