Collection name can be used dynamically when using mongo tail

Signed-off-by: Kim Sung-Jun <[email protected]>
clauzewitz · Sep 11, 2019 · 670b533 · 670b533
1 parent 55f39ed
commit 670b533
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/fluent/plugin/in_mongo_tail.rb b/lib/fluent/plugin/in_mongo_tail.rb
@@ -69,6 +69,8 @@ def configure(conf)
         raise Fluent::ConfigError, "One of 'database' or 'url' must be specified"
       end
 
+      date = Time.now
+      @collection = date.strftime(collection)
       @last_id = @id_store_file ? get_last_id : nil
       @connection_options[:ssl] = @ssl