Source code for insights.ocp

Top level OpenShift 4 component
The :py:func:`conf` component recognizes insights-operator and must-gather
import logging
import os
import yaml

from fnmatch import fnmatch
from insights.core.plugins import component, datasource
from insights.core.context import InsightsOperatorContext, MustGatherContext

from insights.core.archives import extract
from insights.parsr.query import from_dict, Result
from insights.util import content_type

log = logging.getLogger(__name__)
contexts = [InsightsOperatorContext, MustGatherContext]

    # requires pyyaml installed after libyaml
    Loader = yaml.CSafeLoader
except:"Couldn't find libyaml loader. Falling back to python loader.")
    Loader = yaml.SafeLoader

def _get_files(path):
    for root, dirs, names in os.walk(path):
        for name in names:
            yield os.path.join(root, name)

def _load(path):
    with open(path) as f:
        doc = yaml.load(f, Loader=Loader)
        return from_dict(doc)

def _process(path, excludes=None):
    excludes = excludes if excludes is not None else []
    for f in _get_files(path):
        if excludes and any(fnmatch(f, e) for e in excludes):
            yield _load(f)
        except Exception:
            log.debug("Failed to load %s; skipping.", f)

def analyze(paths, excludes=None):
    if not isinstance(paths, list):
        paths = [paths]

    results = []
    for path in paths:
        if content_type.from_file(path) == "text/plain":
        elif os.path.isdir(path):
            results.extend(_process(path, excludes))
            with extract(path) as ex:
                results.extend(_process(ex.tmp_dir, excludes))

    return Result(children=results)

def conf_root(broker):
    for ctx in contexts:
        if ctx in broker:
            return broker[ctx].root

[docs]@component(conf_root) def conf(root): """ The ``conf`` component parses all configuration in an insights-operator or must-gather archive and returns an object that is part of the parsr common data model. It can be navigated and queried in a standard way. See the `tutorial`_ for details. .. _tutorial: """ return analyze(root, excludes=["*.log"])