commit 0baf0a3ada0b52c8455290e278388157dd179960
author Ildar Svetlov <isvetlov@mirantis.com> Mon Jan 22 14:14:15 2018 +0400
committer Ildar Svetlov <isvetlov@mirantis.com> Mon Jan 22 14:14:15 2018 +0400
tree 18d1d7c7fee4ae761fe5f778a6924236f8a91507
parent e0266266e39e739fba320f822c5435428467114c

Parse multiline Openstack logs

Change-Id: Ib64d80fd182bc06491c08fbf684d09352d7ab17f

heka/files/lua/common/patterns.lua

diff --git a/heka/files/lua/common/patterns.lua b/heka/files/lua/common/patterns.lua
index e330ee3..58f7767 100644
--- a/heka/files/lua/common/patterns.lua
+++ b/heka/files/lua/common/patterns.lua
@@ -16,6 +16,8 @@
 local l      = require 'lpeg'
 l.locale(l)
 
+local utils  = require 'lma_utils'
+
 local tonumber = tonumber
 
 local M = {}
@@ -77,7 +79,7 @@
 -- [-] is the "request" part, it can take multiple forms. See below.
 openstack = l.Ct(l.Cg(Timestamp, "Timestamp")* sp * l.Cg(Pid, "Pid") * sp *
     l.Cg(SeverityLabel, "SeverityLabel") * sp * l.Cg(programname, "PythonModule") *
-    sp * l.Cg(Message, "Message"))
+    sp * l.Cg(Message / utils.chomp, "Message"))
 
 -- Capture for OpenStack request context producing three values: RequestId,
 -- UserId and TenantId.