final

fluent/fluent.conf

@@ -4,22 +4,6 @@
   bind 0.0.0.0
 </source>
 
-# <filter mongo.*>
-#   @type parser
-#   key_name log
-#   reserve_data true
-#   <parse>
-#     @type json # apache2, nginx, etc.
-#   </parse>
-# </filter>
-
-# <filter mongo.mongo>
-#   @type record_transformer
-
-#   # remove key1 and key2 keys from record
-#   remove_keys $.log.t
-# </filter>
-
 <filter mongo.redis>
   @type record_transformer
   <record>
@@ -28,6 +12,13 @@
   
 </filter>
 
+<filter mongo.*>
+  @type record_transformer
+  <record>
+  tag ${tag}
+  </record>
+</filter>
+
 
 <match mongo.*>
   @type copy