@@ -57,6 +57,12 @@ filter {
5757 }
5858 }
5959 }
60+ #Remove unnecessary spaces from the msg_all field
61+ if ([msg_all]){
62+ mutate {
63+ strip => ["msg_all"]
64+ }
65+ }
6066 #Checking if the log is in CEF format
6167 if ("CEF:" in [message] and [message] =~/\|(\w+)?(\s)?SonicWall(\s)?(\w+)?\|/){
6268 #......................................................................#
@@ -222,6 +228,58 @@ filter {
222228 grok { match => { "msg_all" => [" cs3=%{DATA:vpnpolicyDst} %{WORD:}="," cs3=%{GREEDYDATA:vpnpolicyDst}"] } }
223229
224230 }
231+
232+ # Clean double quotes from extracted fields
233+ mutate {
234+ gsub => [
235+ "fw_action", "^\"", "",
236+ "fw_action", "\"$", "",
237+ "msg", "^\"", "",
238+ "msg", "\"$", "",
239+ "note", "^\"", "",
240+ "note", "\"$", "",
241+ "rule", "^\"", "",
242+ "rule", "\"$", "",
243+ "user", "^\"", "",
244+ "user", "\"$", "",
245+ "vpnpolicy", "^\"", "",
246+ "vpnpolicy", "\"$", "",
247+ "vpnpolicyDst", "^\"", "",
248+ "vpnpolicyDst", "\"$", "",
249+ "fileid", "^\"", "",
250+ "fileid", "\"$", "",
251+ "referer", "^\"", "",
252+ "referer", "\"$", "",
253+ "time", "^\"", "",
254+ "time", "\"$", "",
255+ "cfs_category", "^\"", "",
256+ "cfs_category", "\"$", "",
257+ "ipscat", "^\"", "",
258+ "ipscat", "\"$", "",
259+ "app_cat", "^\"", "",
260+ "app_cat", "\"$", "",
261+ "appid", "^\"", "",
262+ "appid", "\"$", "",
263+ "arg", "^\"", "",
264+ "arg", "\"$", "",
265+ "app_name", "^\"", "",
266+ "app_name", "\"$", "",
267+ "contentObject", "^\"", "",
268+ "contentObject", "\"$", "",
269+ "request", "^\"", "",
270+ "request", "\"$", "",
271+ "anti_spyware_cat", "^\"", "",
272+ "anti_spyware_cat", "\"$", "",
273+ "anti_spyware_pri", "^\"", "",
274+ "anti_spyware_pri", "\"$", "",
275+ "mgmt_source_ip", "^\"", "",
276+ "mgmt_source_ip", "\"$", "",
277+ "radio", "^\"", "",
278+ "radio", "\"$", "",
279+ "station", "^\"", "",
280+ "station", "\"$", ""
281+ ]
282+ }
225283 #Checking if the src field exists and using grok to parse it
226284 if ([src]){
227285 grok {
@@ -292,7 +350,7 @@ filter {
292350 rename => { "[af_policy_id]" => "[logx][sonicwall][af_policy_id]" }
293351 rename => { "[af_policy]" => "[logx][sonicwall][af_policy]" }
294352 rename => { "[af_policy_type]" => "[logx][sonicwall][af_policy_type]" }
295- rename => { "[=%{WORD: af_policy_service]" => "[logx][sonicwall][af_policy_service]" }
353+ rename => { "[af_policy_service]" => "[logx][sonicwall][af_policy_service]" }
296354 rename => { "[af_policy_action]" => "[logx][sonicwall][af_policy_action]" }
297355 rename => { "[af_policy_object]" => "[logx][sonicwall][af_policy_object]" }
298356 rename => { "[active_interface]" => "[logx][sonicwall][active_interface]" }
0 commit comments