/usr/lib/python2.7/dist-packages/carbon/log.py is in graphite-carbon 1.0.2-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 | import os
import time
from sys import stdout, stderr
from zope.interface import implements
from twisted.python.log import startLoggingWithObserver, textFromEventDict, msg, err, ILogObserver
from twisted.python.syslog import SyslogObserver
from twisted.python.logfile import DailyLogFile
class CarbonLogFile(DailyLogFile):
"""Overridden to support logrotate.d"""
def __init__(self, *args, **kwargs):
DailyLogFile.__init__(self, *args, **kwargs)
# avoid circular dependencies
from carbon.conf import settings
self.enableRotation = settings.ENABLE_LOGROTATION
def _openFile(self):
"""
Fix Umask Issue https://twistedmatrix.com/trac/ticket/7026
"""
openMode = self.defaultMode or 0777
self._file = os.fdopen(os.open(
self.path, os.O_CREAT|os.O_RDWR, openMode), 'r+', 1)
self.closed = False
# Try our best to update permissions for files which already exist.
if self.defaultMode:
try:
os.chmod(self.path, self.defaultMode)
except OSError:
pass
# Seek is needed for uniformity of stream positioning
# for read and write between Linux and BSD systems due
# to differences in fopen() between operating systems.
self._file.seek(0, os.SEEK_END)
self.lastDate = self.toDate(os.stat(self.path)[8])
def shouldRotate(self):
if self.enableRotation:
return DailyLogFile.shouldRotate(self)
else:
return False
def write(self, data):
if not self.enableRotation:
if not os.path.exists(self.path):
self.reopen()
else:
path_stat = os.stat(self.path)
fd_stat = os.fstat(self._file.fileno())
if not (path_stat.st_ino == fd_stat.st_ino
and path_stat.st_dev == fd_stat.st_dev):
self.reopen()
DailyLogFile.write(self, data)
# Backport from twisted >= 10
def reopen(self):
self.close()
self._openFile()
class CarbonLogObserver(object):
implements(ILogObserver)
def log_to_dir(self, logdir):
self.logdir = logdir
self.console_logfile = CarbonLogFile('console.log', logdir)
self.custom_logs = {}
self.observer = self.logdir_observer
def log_to_syslog(self, prefix):
observer = SyslogObserver(prefix).emit
def syslog_observer(event):
event["system"] = event.get("type", "console")
observer(event)
self.observer = syslog_observer
def __call__(self, event):
return self.observer(event)
def stdout_observer(self, event):
stdout.write(formatEvent(event, includeType=True) + '\n')
stdout.flush()
def logdir_observer(self, event):
message = formatEvent(event)
log_type = event.get('type')
if log_type is not None and log_type not in self.custom_logs:
self.custom_logs[log_type] = CarbonLogFile(log_type + '.log', self.logdir)
logfile = self.custom_logs.get(log_type, self.console_logfile)
logfile.write(message + '\n')
logfile.flush()
# Default to stdout
observer = stdout_observer
carbonLogObserver = CarbonLogObserver()
def formatEvent(event, includeType=False):
event['isError'] = 'failure' in event
message = textFromEventDict(event)
if includeType:
typeTag = '[%s] ' % event.get('type', 'console')
else:
typeTag = ''
timestamp = time.strftime("%d/%m/%Y %H:%M:%S")
return "%s :: %s%s" % (timestamp, typeTag, message)
logToDir = carbonLogObserver.log_to_dir
logToSyslog = carbonLogObserver.log_to_syslog
def logToStdout():
startLoggingWithObserver(carbonLogObserver)
def cache(message, **context):
context['type'] = 'cache'
msg(message, **context)
def clients(message, **context):
context['type'] = 'clients'
msg(message, **context)
def creates(message, **context):
context['type'] = 'creates'
msg(message, **context)
def updates(message, **context):
context['type'] = 'updates'
msg(message, **context)
def listener(message, **context):
context['type'] = 'listener'
msg(message, **context)
def relay(message, **context):
context['type'] = 'relay'
msg(message, **context)
def aggregator(message, **context):
context['type'] = 'aggregator'
msg(message, **context)
def query(message, **context):
context['type'] = 'query'
msg(message, **context)
def debug(message, **context):
if debugEnabled:
msg(message, **context)
debugEnabled = False
def setDebugEnabled(enabled):
global debugEnabled
debugEnabled = enabled
|