File Manager

003 File Manager

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

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

📁 ..
📄 __init__.py(5.98 KB)
📁 __pycache__
📄 appoptics_return.py(6.11 KB)
📄 carbon_return.py(8.24 KB)
📄 cassandra_cql_return.py(15.17 KB)
📄 cassandra_return.py(2.07 KB)
📄 couchbase_return.py(8.91 KB)
📄 couchdb_return.py(10.35 KB)
📄 django_return.py(2.27 KB)
📄 elasticsearch_return.py(12.18 KB)
📄 etcd_return.py(6.32 KB)
📄 highstate_return.py(15.59 KB)
📄 influxdb_return.py(8.03 KB)
📄 kafka_return.py(2.12 KB)
📄 librato_return.py(4.29 KB)
📄 local.py(541 B)
📄 local_cache.py(17.1 KB)
📄 mattermost_returner.py(4.08 KB)
📄 memcache_return.py(5.72 KB)
📄 mongo_future_return.py(10.08 KB)
📄 mongo_return.py(6.11 KB)
📄 multi_returner.py(2.82 KB)
📄 mysql.py(18.61 KB)
📄 nagios_nrdp_return.py(4.92 KB)
📄 odbc.py(7.77 KB)
📄 pgjsonb.py(17.18 KB)
📄 postgres.py(10.2 KB)
📄 postgres_local_cache.py(10.73 KB)
📄 pushover_returner.py(6.55 KB)
📄 rawfile_json.py(2.23 KB)
📄 redis_return.py(8.52 KB)
📄 sentry_return.py(5.3 KB)
📄 slack_returner.py(6.02 KB)
📄 slack_webhook_return.py(11.22 KB)
📄 sms_return.py(2.64 KB)
📄 smtp_return.py(8.2 KB)
📄 splunk.py(6.69 KB)
📄 sqlite3_return.py(7.73 KB)
📄 syslog_return.py(5.26 KB)
📄 telegram_return.py(1.92 KB)
📄 xmpp_return.py(4.85 KB)
📄 zabbix_return.py(2.45 KB)

Editing: cassandra_return.py

"""
Return data to a Cassandra ColumnFamily

Here's an example Keyspace / ColumnFamily setup that works with this
returner::

create keyspace salt;
    use salt;
    create column family returns
      with key_validation_class='UTF8Type'
      and comparator='UTF8Type'
      and default_validation_class='UTF8Type';

Required python modules: pycassa

To use the cassandra returner, append '--return cassandra' to the salt command. ex:

salt '*' test.ping --return cassandra
"""

import logging

import salt.utils.jid

try:
    import pycassa  # pylint: disable=import-error

HAS_PYCASSA = True
except ImportError:
    HAS_PYCASSA = False

log = logging.getLogger(__name__)

__opts__ = {
    "cassandra.servers": ["localhost:9160"],
    "cassandra.keyspace": "salt",
    "cassandra.column_family": "returns",
    "cassandra.consistency_level": "ONE",
}

# Define the module's virtual name
__virtualname__ = "cassandra"

def __virtual__():
    if not HAS_PYCASSA:
        return False, "Could not import cassandra returner; pycassa is not installed."
    return __virtualname__

def returner(ret):
    """
    Return data to a Cassandra ColumnFamily
    """

consistency_level = getattr(
        pycassa.ConsistencyLevel, __opts__["cassandra.consistency_level"]
    )

pool = pycassa.ConnectionPool(
        __opts__["cassandra.keyspace"], __opts__["cassandra.servers"]
    )
    ccf = pycassa.ColumnFamily(
        pool,
        __opts__["cassandra.column_family"],
        write_consistency_level=consistency_level,
    )

columns = {"fun": ret["fun"], "id": ret["id"]}
    if isinstance(ret["return"], dict):
        for key, value in ret["return"].items():
            columns["return.{}".format(key)] = str(value)
    else:
        columns["return"] = str(ret["return"])

log.debug(columns)
    ccf.insert(ret["jid"], columns)

def prep_jid(nocache=False, passed_jid=None):  # pylint: disable=unused-argument
    """
    Do any work necessary to prepare a JID, including sending a custom id
    """
    return passed_jid if passed_jid is not None else salt.utils.jid.gen_jid(__opts__)

003 File Manager

Editing: cassandra_return.py

Upload File

Create Folder