mirror/php-monolog
1
0
Fork 0
mirror of https://github.com/Seldaek/monolog.git synced 2025-08-09 14:46:46 +02:00
Code Issues Releases Wiki Activity

Checking each entry individually instead of using @.

Browse Source
This commit is contained in:
Bruno Pedro
2014-04-08 10:43:04 +02:00
parent 3c0c213b41
commit ffb1701834
1 changed files with 21 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
src/Monolog/Formatter/LogstashFormatter.php
View File

@@ -90,19 +90,22 @@ class LogstashFormatter extends NormalizerFormatter
} }
$message = array( $message = array(
'@timestamp' => $record['datetime'], '@timestamp' => $record['datetime'],
'@message' => @$record['message'],
'@tags' => array(@$record['channel']),
'@source' => $this->systemName, '@source' => $this->systemName,
'@fields' => array( '@fields' => array()
'channel' => @$record['channel'],
'level' => @$record['level']
)
); );
if (isset($record['message'])) {
$message['@message'] = $record['message'];
}
if (isset($record['channel'])) {
$message['@tags'] = array($record['channel']);
$message['@fields']['channel'] = $record['channel'];
}
if (isset($record['level'])) {
$message['@fields']['level'] = $record['level'];
}
if ($this->applicationName) { if ($this->applicationName) {
$message['@type'] = $this->applicationName; $message['@type'] = $this->applicationName;
} }
if (isset($record['extra']['server'])) { if (isset($record['extra']['server'])) {
$message['@source_host'] = $record['extra']['server']; $message['@source_host'] = $record['extra']['server'];
} }
@@ -131,13 +134,18 @@ class LogstashFormatter extends NormalizerFormatter
$message = array( $message = array(
'@timestamp' => $record['datetime'], '@timestamp' => $record['datetime'],
'@version' => 1, '@version' => 1,
'message' => @$record['message'],
'host' => $this->systemName, 'host' => $this->systemName,
'type' => @$record['channel'],
'channel' => @$record['channel'],
'level' => @$record['level_name']
); );
if (isset($record['message'])) {
$message['message'] = $record['message'];
}
if (isset($record['channel'])) {
$message['type'] = $record['channel'];
$message['channel'] = $record['channel'];
}
if (isset($record['level_name'])) {
$message['level'] = $record['level_name'];
}
if ($this->applicationName) { if ($this->applicationName) {
$message['type'] = $this->applicationName; $message['type'] = $this->applicationName;
} }