Serializes a log message to Logstash Event Format. More...

Inheritance diagram for Monolog\Formatter\LogstashFormatter:

Collaboration diagram for Monolog\Formatter\LogstashFormatter:

Public Member Functions

__construct ($applicationName, $systemName=null, $extraPrefix=null, $contextPrefix='ctxt_', $version=self::V0)

format (array $record)

{Formats a log record.

Parameters

array $record A record to format

Returns: mixed The formatted record

} More...

Public Member Functions inherited from Monolog\Formatter\NormalizerFormatter

__construct ($dateFormat=null)

format (array $record)

{Formats a log record.

Parameters

array $record A record to format

Returns: mixed The formatted record

} More...

formatBatch (array $records)

{Formats a set of log records.

Parameters

array $records A set of records to format

Returns: mixed The formatted set of records

} More...

Data Fields
const	V0 = 0

const	V1 = 1

Data Fields inherited from Monolog\Formatter\NormalizerFormatter
const	SIMPLE_DATE = "Y-m-d H:i:s"

Protected Member Functions
	formatV0 (array $record)

	formatV1 (array $record)

Protected Member Functions inherited from Monolog\Formatter\NormalizerFormatter
	normalize ($data)

	normalizeException (Exception $e)

	toJson ($data, $ignoreErrors=false)

Protected Attributes
	$systemName

	$applicationName

	$extraPrefix

	$contextPrefix

	$version

Protected Attributes inherited from Monolog\Formatter\NormalizerFormatter
	$dateFormat

Detailed Description

Serializes a log message to Logstash Event Format.

See also: http://logstash.net/; https://github.com/logstash/logstash/blob/master/lib/logstash/event.rb

Author: Tim Mower timot.nosp@m.hy.m.nosp@m.ower@.nosp@m.gmai.nosp@m.l.com

Definition at line 22 of file LogstashFormatter.php.

Constructor & Destructor Documentation

◆ __construct()

Monolog\Formatter\LogstashFormatter::__construct	(	$applicationName,
		$systemName = `null`,
		$extraPrefix = `null`,
		$contextPrefix = `'ctxt_'`,
		$version = `self::V0`
	)

Parameters

string	$applicationName	the application that sends the data, used as the "type" field of logstash
string	$systemName	the system/machine name, used as the "source" field of logstash, defaults to the hostname of the machine
string	$extraPrefix	prefix for extra keys inside logstash "fields"
string	$contextPrefix	prefix for context keys inside logstash "fields", defaults to ctxt_

Definition at line 58 of file LogstashFormatter.php.

References Monolog\Formatter\LogstashFormatter\$applicationName, Monolog\Formatter\LogstashFormatter\$contextPrefix, Monolog\Formatter\LogstashFormatter\$extraPrefix, Monolog\Formatter\LogstashFormatter\$systemName, and Monolog\Formatter\LogstashFormatter\$version.

     {
         // logstash requires a ISO 8601 format date with optional millisecond precision.
         parent::__construct('Y-m-d\TH:i:s.uP');
 
         $this->systemName = $systemName ?: gethostname();
         $this->applicationName = $applicationName;
         $this->extraPrefix = $extraPrefix;
         $this->contextPrefix = $contextPrefix;
         $this->version = $version;
     }

Member Function Documentation

◆ format()

Monolog\Formatter\LogstashFormatter::format ( array $record )

{Formats a log record.

Parameters

array $record A record to format

Returns: mixed The formatted record

}

Implements Monolog\Formatter\FormatterInterface.

Definition at line 73 of file LogstashFormatter.php.

References Monolog\Formatter\LogstashFormatter\formatV0(), Monolog\Formatter\LogstashFormatter\formatV1(), and Monolog\Formatter\NormalizerFormatter\toJson().

     {
         $record = parent::format($record);
 
         if ($this->version === self::V1) {
             $message = $this->formatV1($record);
         } else {
             $message = $this->formatV0($record);
         }
 
         return $this->toJson($message) . "\n";
     }

Here is the call graph for this function:

◆ formatV0()

Monolog\Formatter\LogstashFormatter::formatV0 ( array $record )

protected

Definition at line 86 of file LogstashFormatter.php.

References Monolog\Formatter\LogstashFormatter\$applicationName.

Referenced by Monolog\Formatter\LogstashFormatter\format().

     {
         if (empty($record['datetime'])) {
             $record['datetime'] = gmdate('c');
         }
         $message = array(
             '@timestamp' => $record['datetime'],
             '@source' => $this->systemName,
             '@fields' => array()
         );
         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) {
             $message['@type'] = $this->applicationName;
         }
         if (isset($record['extra']['server'])) {
             $message['@source_host'] = $record['extra']['server'];
         }
         if (isset($record['extra']['url'])) {
             $message['@source_path'] = $record['extra']['url'];
         }
         if (!empty($record['extra'])) {
             foreach ($record['extra'] as $key => $val) {
                 $message['@fields'][$this->extraPrefix . $key] = $val;
             }
         }
         if (!empty($record['context'])) {
             foreach ($record['context'] as $key => $val) {
                 $message['@fields'][$this->contextPrefix . $key] = $val;
             }
         }
 
         return $message;
     }

Here is the caller graph for this function:

◆ formatV1()

Monolog\Formatter\LogstashFormatter::formatV1 ( array $record )

protected

Definition at line 129 of file LogstashFormatter.php.

References Monolog\Formatter\LogstashFormatter\$applicationName.

Referenced by Monolog\Formatter\LogstashFormatter\format().

     {
         if (empty($record['datetime'])) {
             $record['datetime'] = gmdate('c');
         }
         $message = array(
             '@timestamp' => $record['datetime'],
             '@version' => 1,
             'host' => $this->systemName,
         );
         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) {
             $message['type'] = $this->applicationName;
         }
         if (!empty($record['extra'])) {
             foreach ($record['extra'] as $key => $val) {
                 $message[$this->extraPrefix . $key] = $val;
             }
         }
         if (!empty($record['context'])) {
             foreach ($record['context'] as $key => $val) {
                 $message[$this->contextPrefix . $key] = $val;
             }
         }
 
         return $message;
     }