File Manager

003 File Manager

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

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

📁 ..
📄 __init__.py(18.16 KB)
📁 __pycache__
📄 adb.py(5.2 KB)
📄 aix_account.py(1.33 KB)
📄 avahi_announce.py(8.53 KB)
📄 bonjour_announce.py(8.21 KB)
📄 btmp.py(8.33 KB)
📄 cert_info.py(5.82 KB)
📄 diskusage.py(3.35 KB)
📄 glxinfo.py(1.84 KB)
📄 haproxy.py(3.02 KB)
📄 inotify.py(11.88 KB)
📄 journald.py(2.61 KB)
📄 junos_rre_keys.py(723 B)
📄 load.py(5.95 KB)
📄 log_beacon.py(3.67 KB)
📄 memusage.py(1.57 KB)
📄 napalm_beacon.py(11.61 KB)
📄 network_info.py(4.66 KB)
📄 network_settings.py(6.53 KB)
📄 pkg.py(2.57 KB)
📄 proxy_example.py(1.48 KB)
📄 ps.py(2.23 KB)
📄 salt_monitor.py(4.06 KB)
📄 salt_proxy.py(1.81 KB)
📄 sensehat.py(2.82 KB)
📄 service.py(6.15 KB)
📄 sh.py(3.1 KB)
📄 smartos_imgadm.py(2.6 KB)
📄 smartos_vmadm.py(3.34 KB)
📄 status.py(4.11 KB)
📄 swapusage.py(1.57 KB)
📄 telegram_bot_msg.py(2.45 KB)
📄 twilio_txt_msg.py(2.65 KB)
📄 watchdog.py(4.79 KB)
📄 wtmp.py(10.17 KB)

Editing: journald.py

"""
A simple beacon to watch journald for specific entries
"""
import logging

import salt.utils.beacons
import salt.utils.data

try:
    import systemd.journal  # pylint: disable=no-name-in-module

HAS_SYSTEMD = True
except ImportError:
    HAS_SYSTEMD = False

log = logging.getLogger(__name__)

__virtualname__ = "journald"

def __virtual__():
    if HAS_SYSTEMD:
        return __virtualname__
    return False

def _get_journal():
    """
    Return the active running journal object
    """
    if "systemd.journald" in __context__:
        return __context__["systemd.journald"]
    __context__["systemd.journald"] = systemd.journal.Reader()
    # get to the end of the journal
    __context__["systemd.journald"].seek_tail()
    __context__["systemd.journald"].get_previous()
    return __context__["systemd.journald"]

def validate(config):
    """
    Validate the beacon configuration
    """
    # Configuration for journald beacon should be a list of dicts
    if not isinstance(config, list):
        return (False, "Configuration for journald beacon must be a list.")
    else:
        config = salt.utils.beacons.list_to_dict(config)

for name in config.get("services", {}):
            if not isinstance(config["services"][name], dict):
                return (
                    False,
                    "Services configuration for journald beacon must be a list of"
                    " dictionaries.",
                )
    return True, "Valid beacon configuration"

def beacon(config):
    """
    The journald beacon allows for the systemd journal to be parsed and linked
    objects to be turned into events.

This beacons config will return all sshd jornal entries

.. code-block:: yaml

beacons:
          journald:
            - services:
                sshd:
                  SYSLOG_IDENTIFIER: sshd
                  PRIORITY: 6
    """
    ret = []
    journal = _get_journal()

config = salt.utils.beacons.list_to_dict(config)

while True:
        cur = journal.get_next()
        if not cur:
            break

for name in config.get("services", {}):
            n_flag = 0
            for key in config["services"][name]:
                if isinstance(key, str):
                    key = salt.utils.data.decode(key)
                if key in cur:
                    if config["services"][name][key] == cur[key]:
                        n_flag += 1
            if n_flag == len(config["services"][name]):
                # Match!
                sub = salt.utils.data.simple_types_filter(cur)
                sub.update({"tag": name})
                ret.append(sub)
    return ret

003 File Manager

Editing: journald.py

Upload File

Create Folder