mirror of
https://github.com/ansible-collections/community.general.git
synced 2025-04-24 19:31:26 -07:00
6b6d03290a
Revert "Remove auto-added invocation return value as it is not used by v2 and could leak sensitive data." This reverts commit6ce6b20268. Remove the note that invocation was removed as we've now restored it. Revert "keyword not in ubuntu 14.04" This reverts commit5c01622457. Revert "remove invocation keyword check" This reverts commit5177cb3f74.
92 lines
3.1 KiB
Python
92 lines
3.1 KiB
Python
# (C) 2012, Michael DeHaan, <michael.dehaan@gmail.com>
|
|
|
|
# This file is part of Ansible
|
|
#
|
|
# Ansible is free software: you can redistribute it and/or modify
|
|
# it under the terms of the GNU General Public License as published by
|
|
# the Free Software Foundation, either version 3 of the License, or
|
|
# (at your option) any later version.
|
|
#
|
|
# Ansible is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with Ansible. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
# Make coding more python3-ish
|
|
from __future__ import (absolute_import, division, print_function)
|
|
__metaclass__ = type
|
|
|
|
import os
|
|
import time
|
|
import json
|
|
|
|
from ansible.utils.unicode import to_bytes
|
|
from ansible.plugins.callback import CallbackBase
|
|
|
|
# NOTE: in Ansible 1.2 or later general logging is available without
|
|
# this plugin, just set ANSIBLE_LOG_PATH as an environment variable
|
|
# or log_path in the DEFAULTS section of your ansible configuration
|
|
# file. This callback is an example of per hosts logging for those
|
|
# that want it.
|
|
|
|
|
|
class CallbackModule(CallbackBase):
|
|
"""
|
|
logs playbook results, per host, in /var/log/ansible/hosts
|
|
"""
|
|
CALLBACK_VERSION = 2.0
|
|
CALLBACK_TYPE = 'notification'
|
|
CALLBACK_NAME = 'log_plays'
|
|
|
|
TIME_FORMAT="%b %d %Y %H:%M:%S"
|
|
MSG_FORMAT="%(now)s - %(category)s - %(data)s\n\n"
|
|
|
|
def __init__(self, display):
|
|
|
|
super(CallbackModule, self).__init__(display)
|
|
|
|
if not os.path.exists("/var/log/ansible/hosts"):
|
|
os.makedirs("/var/log/ansible/hosts")
|
|
|
|
def log(self, host, category, data):
|
|
if type(data) == dict:
|
|
if '_ansible_verbose_override' in data:
|
|
# avoid logging extraneous data
|
|
data = 'omitted'
|
|
else:
|
|
data = data.copy()
|
|
invocation = data.pop('invocation', None)
|
|
data = json.dumps(data)
|
|
if invocation is not None:
|
|
data = json.dumps(invocation) + " => %s " % data
|
|
|
|
path = os.path.join("/var/log/ansible/hosts", host)
|
|
now = time.strftime(self.TIME_FORMAT, time.localtime())
|
|
|
|
msg = to_bytes(self.MSG_FORMAT % dict(now=now, category=category, data=data))
|
|
with open(path, "ab") as fd:
|
|
fd.write(msg)
|
|
|
|
def runner_on_failed(self, host, res, ignore_errors=False):
|
|
self.log(host, 'FAILED', res)
|
|
|
|
def runner_on_ok(self, host, res):
|
|
self.log(host, 'OK', res)
|
|
|
|
def runner_on_skipped(self, host, item=None):
|
|
self.log(host, 'SKIPPED', '...')
|
|
|
|
def runner_on_unreachable(self, host, res):
|
|
self.log(host, 'UNREACHABLE', res)
|
|
|
|
def runner_on_async_failed(self, host, res, jid):
|
|
self.log(host, 'ASYNC_FAILED', res)
|
|
|
|
def playbook_on_import_for_host(self, host, imported_file):
|
|
self.log(host, 'IMPORTED', imported_file)
|
|
|
|
def playbook_on_not_import_for_host(self, host, missing_file):
|
|
self.log(host, 'NOTIMPORTED', missing_file)
|