norikra + fluentd + mongodb

fluentd.conf

<source>
    type forward
</source>

<match data.**>
    type copy
    <store>
        type norikra
        norikra 127.0.0.1:26571

        target_map_tag    true
        remove_tag_prefix data

        <default>
            auto_field false
        </default>
    </store>
#    <store>
#        type stdout
#    </store>
</match>

<source>
    type norikra
    norikra 127.0.0.1:26571

    <fetch>
      method sweep
      tag    query_name
      tag_prefix norikra.event
      interval 10s
    </fetch>
</source>

<match norikra.event.**>
    type copy
    <store>
        type mongo
        database norikra
        tag_mapped
        capped
        capped_size 100m
        remove_tag_prefix norikra.event
    </store>
    <store>
        type stdout
    </store>
</match>