Mcafee DAM syslog parsing Logstash


Hi Community,

i'm looking for logstash idea how to parse the next content:
<15>#externalId=0#rt=1XXXX1#cs1=SaXXM XXXX,XXX,XXXX,XXXX,XXXXX FROM xxxxx.dbo.xxxxx WHERE xxxxx \\= @X1 AND (xxxxx is null) ORDER BY xxxxx ASC ,xxxxx ASC ,xxxxx ASC#cs3=#cs3Label=AccessedObjects#cs2Label=SqlStatement\u0000

i hashed the real values but the columns are real, also the delimiter is by request i customize the sender to delim using "#",
i tried the following config:

input {
  tcp {
    port => 5002
    type => syslog
    tags => ["dam"]
  udp {
    port => 5002
    type => syslog
    tags => ["dam"]

filter {
  if "dam" in [tags] {
    ruby {
        code => "
            fieldArray = event.get('message').split('#')
            for field in fieldArray
                field = field.delete('#')
                result = field.split('=',1)
                temp_key = 'key_' + result[0]
                temp_value = 'value_' + result[1]
                event.set(temp_key, temp_value)


i tried lot of trick even using KV, i believe i'm doing something wrong :frowning:

[2017-01-29T00:04:10,785][ERROR][logstash.filters.ruby ] Ruby exception occurred: can't convert nil into String

Thanks in advance.

(Christian Dahlqvist) #2

You should be able to use a grok filter to capture the start of the message before the key-value string and store the rest into a variable. You can then use the kv filter with custom field separator ('#') to parse the key-value list in this variable before using a mutate filter to it.



Thank you for the reply, believe it or not I tried pretty much everything :wink:
Is there any chance there is sample?


(Magnus Bäck) #4

Show us what you have right now and it'll be easier for us to point you in the right direction.


i mention it above, the configuration and the data sample

(Magnus Bäck) #6

I thought you had actually tried using grok and kv as Christian mentioned. You're looking for something like this:

filter {
  grok {
    match => ["message", "^<%{INT}>#%{GREEDYDATA:kv}"]
  kv {
    source => "kv"
    field_split => "#"

(system) #7

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.