diff options
| author | Éric Lemoine <elemoine@mirantis.com> | 2016-02-26 14:50:32 +0100 |
|---|---|---|
| committer | Éric Lemoine <elemoine@mirantis.com> | 2016-02-26 14:50:32 +0100 |
| commit | 95cf542f8d5a28ae726b6864d61672982c645510 (patch) | |
| tree | 7b07d319b4a4efd89229224e88e88a8d8ae2e3d2 /docker | |
| parent | 287e4faf99c2fe7a5d0a57334df35a6dc5e71f72 (diff) | |
| download | kolla-95cf542f8d5a28ae726b6864d61672982c645510.tar.gz kolla-95cf542f8d5a28ae726b6864d61672982c645510.zip | |
Fix parsing of RabbitMQ logs
Currently Heka fails to parse the RabbitMQ logs. There are two
problems:
1. The rabbit-sasl.log file is ignored but the file_match expression
does not match.
2. The delimiter used in the RegexSplitter makes Heka stop on the
very first log entry. '\n\n(=[^=]+====' (with two \n's) is
a better delimiter. deliver_incomplete_final is used to get the
final log entry.
TrivialFix
Change-Id: I94720340d5b2d6fd5d7641b9ff58733f6cd882ee
Diffstat (limited to 'docker')
| -rw-r--r-- | docker/heka/plugins/decoders/os_rabbitmq_log.lua | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/docker/heka/plugins/decoders/os_rabbitmq_log.lua b/docker/heka/plugins/decoders/os_rabbitmq_log.lua index 44d2bc44f..5ce6c65fc 100644 --- a/docker/heka/plugins/decoders/os_rabbitmq_log.lua +++ b/docker/heka/plugins/decoders/os_rabbitmq_log.lua @@ -54,6 +54,8 @@ function process_message () msg.Timestamp = m.Timestamp msg.Payload = m.Message + msg.Logger = read_message("Logger") + if utils.label_to_severity_map[m.SeverityLabel] then msg.Severity = utils.label_to_severity_map[m.SeverityLabel] elseif m.SeverityLabel == 'CRASH' then |