kibana_prometheus_exporter.__main__

Complexity

Total Complexity

0

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Importance

Changes

0

import asyncio
import logging
import sys

from prometheus_client.core import REGISTRY
from prometheus_client.exposition import start_http_server

from .config import Config
from .kibana_collector import KibanaCollector

logger = logging.getLogger(__name__)

try:
    config = Config()
except ValueError as e:
    logger.critical(e)
    logger.critical("Invalid configuration. Exiting.")
    sys.exit(1)


logger.info("Starting Kibana Prometheus exporter version %s\n" % config.version + config.description())

REGISTRY.register(
    KibanaCollector(
        config.kibana_url,
        kibana_login=config.kibana_login,
        kibana_password=config.kibana_password,
        ignore_ssl=config.ignore_ssl,
    )
)

try:
    start_http_server(config.listen_port)
except PermissionError as e:
    logger.critical("Cannot bind to port %s. Permission denied.", config.listen_port)
    sys.exit(2)

loop = asyncio.new_event_loop()
try:
    loop.run_forever()
except KeyboardInterrupt:
    loop.stop()
    loop.close()