File Manager

003 File Manager

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

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

📁 ..
📄 __init__.py(3.62 KB)
📁 __pycache__
📄 docker_events.py(2.84 KB)
📄 fluent.py(2.05 KB)
📄 http_logstash.py(2.84 KB)
📄 ircbot.py(10.22 KB)
📄 junos_syslog.py(13.18 KB)
📄 libvirt_events.py(21.28 KB)
📄 logentries.py(5.64 KB)
📄 logstash_engine.py(1.77 KB)
📄 napalm_syslog.py(11.59 KB)
📄 reactor.py(720 B)
📄 redis_sentinel.py(2.88 KB)
📄 script.py(3.33 KB)
📄 slack.py(35.79 KB)
📄 sqs_events.py(4.65 KB)
📄 stalekey.py(3.67 KB)
📄 test.py(932 B)
📄 thorium.py(314 B)
📄 webhook.py(2.78 KB)

Editing: logstash_engine.py

"""
An engine that reads messages from the salt event bus and pushes
them onto a logstash endpoint.

.. versionadded:: 2015.8.0

:configuration:

Example configuration

.. code-block:: yaml

engines:
          - logstash:
              host: log.my_network.com
              port: 5959
              proto: tcp

:depends: logstash
"""

import logging

import salt.utils.event

try:
    import logstash
except ImportError:
    logstash = None

log = logging.getLogger(__name__)

__virtualname__ = "logstash"

def __virtual__():
    return (
        __virtualname__
        if logstash is not None
        else (False, "python-logstash not installed")
    )

def event_bus_context(opts):
    if opts.get("id").endswith("_master"):
        event_bus = salt.utils.event.get_master_event(
            opts, opts["sock_dir"], listen=True
        )
    else:
        event_bus = salt.utils.event.get_event(
            "minion",
            transport=opts["transport"],
            opts=opts,
            sock_dir=opts["sock_dir"],
            listen=True,
        )
    return event_bus

def start(host, port=5959, tag="salt/engine/logstash", proto="udp"):
    """
    Listen to salt events and forward them to logstash
    """

if proto == "tcp":
        logstashHandler = logstash.TCPLogstashHandler
    elif proto == "udp":
        logstashHandler = logstash.UDPLogstashHandler

logstash_logger = logging.getLogger("python-logstash-logger")
    logstash_logger.setLevel(logging.INFO)
    logstash_logger.addHandler(logstashHandler(host, port, version=1))

with event_bus_context(__opts__) as event_bus:
        log.debug("Logstash engine started")
        while True:
            event = event_bus.get_event()
            if event:
                logstash_logger.info(tag, extra=event)

003 File Manager

Editing: logstash_engine.py

Upload File

Create Folder