How to get value from JSON in Fluentd?

[Pietro Zanella]

Hi,

I have the follow JSON:

  

{
   "activityTimestamp" : "2016-05-13T14:14:57.387Z",
   "activityType" : "TEST",
   "description" : "message",

   "geoIP" : {
      "anonymizerStatus" : "private",
      "countryCode" : "GB",
      "ipAddress" : "127.0.0.1",
   },
   "householdId" : "000000",
   "ipAddress" : "127.0.0.1",
   ...

}

I need to output the timestamp, description and countryCode; can I access to countryCode using Fluentd?
How can I do? Have you any idea?

My <match> tag is:

<match tag.output>
  @type file
  path /home/out/test_
  buffer_path /home/out/buffer
  format csv
  delimiter |
  fields activityTimestamp,description,countryCode
  ...
</match>

Help me!

Thanks in advance!

[Mr. Fiber]

Currently, csv formatter doesn't support nested field access.

Applying flatten-hash filter before output is one way: https://github.com/kazegusuri/fluent-plugin-flatten-hash#filter

Masahiro

--
You received this message because you are subscribed to the Google Groups "Fluentd Google Group" group.
To unsubscribe from this group and stop receiving emails from it, send an email to fluentd+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[Pietro Zanella]

Thanks a lot Masahiro!

I found another solution to get countryCode inside complex json object:

    <filter tag.kafka>

       @type record_transformer

       enable_ruby yes

       auto_typecast yes

       <record>

            country ${record ["geoIP"]["countryCode"]}

       </record>

       ...

    </filter>

Thanks for the support!

--
You received this message because you are subscribed to a topic in the Google Groups "Fluentd Google Group" group.
To unsubscribe from this topic, visit https://groups.google.com/d/topic/fluentd/KUOOyx7R4qs/unsubscribe.
To unsubscribe from this group and all its topics, send an email to fluentd+unsubscribe@googlegroups.com.