File Manager

003 File Manager

Current Path: /usr/local/lib/python3.8/site-packages/salt/runners

usr / local / lib / python3.8 / site-packages / salt / runners /

📁 ..
📄 __init__.py(26 B)
📁 __pycache__
📄 asam.py(11.2 KB)
📄 auth.py(1.69 KB)
📄 bgp.py(17.5 KB)
📄 cache.py(12.72 KB)
📄 cloud.py(4.18 KB)
📄 config.py(913 B)
📄 ddns.py(8.89 KB)
📄 digicertapi.py(21.63 KB)
📄 doc.py(1.39 KB)
📄 drac.py(5.29 KB)
📄 error.py(545 B)
📄 event.py(2.1 KB)
📄 f5.py(9.58 KB)
📄 fileserver.py(17.37 KB)
📄 git_pillar.py(3.98 KB)
📄 http.py(2.35 KB)
📄 jobs.py(17.45 KB)
📄 launchd.py(1.35 KB)
📄 lxc.py(18.14 KB)
📄 manage.py(25.84 KB)
📄 mattermost.py(4.68 KB)
📄 mine.py(1.68 KB)
📄 nacl.py(8.15 KB)
📄 net.py(38.97 KB)
📄 network.py(2.42 KB)
📄 pagerduty.py(4.5 KB)
📄 pillar.py(5.14 KB)
📄 pkg.py(1.35 KB)
📄 queue.py(8.88 KB)
📄 reactor.py(4.97 KB)
📄 salt.py(4.69 KB)
📄 saltutil.py(21.5 KB)
📄 sdb.py(2.14 KB)
📄 smartos_vmadm.py(11.73 KB)
📄 spacewalk.py(9.8 KB)
📄 ssh.py(771 B)
📄 state.py(8.88 KB)
📄 survey.py(5.84 KB)
📄 test.py(1.75 KB)
📄 thin.py(1.74 KB)
📄 vault.py(10.09 KB)
📄 venafiapi.py(6.68 KB)
📄 virt.py(17.59 KB)
📄 vistara.py(5.6 KB)
📄 winrepo.py(8.57 KB)

Editing: survey.py

"""
A general map/reduce style salt runner for aggregating results
returned by several different minions.

.. versionadded:: 2014.7.0

Aggregated results are sorted by the size of the minion pools which returned
matching results.

Useful for playing the game: *"some of these things are not like the others..."*
when identifying discrepancies in a large infrastructure managed by salt.
"""

import salt.client
from salt.exceptions import SaltClientError

def hash(*args, **kwargs):
    """
    Return the MATCHING minion pools from the aggregated and sorted results of
    a salt command

.. versionadded:: 2014.7.0

This command is submitted via a salt runner using the
    general form::

salt-run survey.hash [survey_sort=up/down] <target>
                  <salt-execution-module> <salt-execution-module parameters>

Optionally accept a ``survey_sort=`` parameter. Default: ``survey_sort=down``

CLI Example #1: (functionally equivalent to ``salt-run manage.up``)

.. code-block:: bash

salt-run survey.hash "*" test.ping

CLI Example #2: (find an "outlier" minion config file)

.. code-block:: bash

salt-run survey.hash "*" file.get_hash /etc/salt/minion survey_sort=up
    """

return _get_pool_results(*args, **kwargs)

def diff(*args, **kwargs):
    """
    Return the DIFFERENCE of the result sets returned by each matching minion
    pool

.. versionadded:: 2014.7.0

These pools are determined from the aggregated and sorted results of
    a salt command.

This command displays the "diffs" as a series of 2-way differences --
    namely the difference between the FIRST displayed minion pool
    (according to sort order) and EACH SUBSEQUENT minion pool result set.

Differences are displayed according to the Python ``difflib.unified_diff()``
    as in the case of the salt execution module ``file.get_diff``.

This command is submitted via a salt runner using the general form::

salt-run survey.diff [survey_sort=up/down] <target>
                     <salt-execution-module> <salt-execution-module parameters>

Optionally accept a ``survey_sort=`` parameter. Default:
    ``survey_sort=down``

CLI Example #1: (Example to display the "differences of files")

.. code-block:: bash

salt-run survey.diff survey_sort=up "*" cp.get_file_str file:///etc/hosts
    """
    # TODO: The salt execution module "cp.get_file_str file:///..." is a
    # non-obvious way to display the differences between files using
    # survey.diff .  A more obvious method needs to be found or developed.

import difflib

bulk_ret = _get_pool_results(*args, **kwargs)

is_first_time = True
    for k in bulk_ret:
        print("minion pool :\n------------")
        print(k["pool"])
        print("pool size :\n----------")
        print("    " + str(len(k["pool"])))
        if is_first_time:
            is_first_time = False
            print("pool result :\n------------")
            print("    " + bulk_ret[0]["result"])
            print()
            continue

outs = 'differences from "{}" results :'.format(bulk_ret[0]["pool"][0])
        print(outs)
        print("-" * (len(outs) - 1))
        from_result = bulk_ret[0]["result"].splitlines()
        for idx, _ in enumerate(from_result):
            from_result[idx] += "\n"
        to_result = k["result"].splitlines()
        for idx, _ in enumerate(to_result):
            to_result[idx] += "\n"
        outs = ""
        outs += "".join(
            difflib.unified_diff(
                from_result,
                to_result,
                fromfile=bulk_ret[0]["pool"][0],
                tofile=k["pool"][0],
                n=0,
            )
        )
        print(outs)
        print()

return bulk_ret

def _get_pool_results(*args, **kwargs):
    """
    A helper function which returns a dictionary of minion pools along with
    their matching result sets.
    Useful for developing other "survey style" functions.
    Optionally accepts a "survey_sort=up" or "survey_sort=down" kwargs for
    specifying sort order.
    Because the kwargs namespace of the "salt" and "survey" command are shared,
    the name "survey_sort" was chosen to help avoid option conflicts.
    """
    # TODO: the option "survey.sort=" would be preferred for namespace
    # separation but the kwargs parser for the salt-run command seems to
    # improperly pass the options containing a "." in them for later modules to
    # process. The "_" is used here instead.

import hashlib

tgt = args[0]
    cmd = args[1]
    ret = {}

sort = kwargs.pop("survey_sort", "down")
    direction = sort != "up"

tgt_type = kwargs.pop("tgt_type", "compound")
    if tgt_type not in ["compound", "pcre"]:
        tgt_type = "compound"

kwargs_passthru = {
        key: value for (key, value) in kwargs.items() if not key.startswith("_")
    }

with salt.client.get_local_client(__opts__["conf_file"]) as client:
        try:
            minions = client.cmd(
                tgt,
                cmd,
                args[2:],
                timeout=__opts__["timeout"],
                tgt_type=tgt_type,
                kwarg=kwargs_passthru,
            )
        except SaltClientError as client_error:
            print(client_error)
            return ret

# hash minion return values as a string
    for minion in sorted(minions):
        digest = hashlib.sha256(
            str(minions[minion]).encode(__salt_system_encoding__)
        ).hexdigest()
        if digest not in ret:
            ret[digest] = {}
            ret[digest]["pool"] = []
            ret[digest]["result"] = str(minions[minion])

ret[digest]["pool"].append(minion)

sorted_ret = []
    for k in sorted(ret, key=lambda k: len(ret[k]["pool"]), reverse=direction):
        # return aggregated results, sorted by size of the hash pool

sorted_ret.append(ret[k])

return sorted_ret

003 File Manager

Editing: survey.py

Upload File

Create Folder