diff --git a/lib/logstash/inputs/sqlite.rb b/lib/logstash/inputs/sqlite.rb index 7dd434a..95afabb 100644 --- a/lib/logstash/inputs/sqlite.rb +++ b/lib/logstash/inputs/sqlite.rb @@ -157,7 +157,7 @@ def run(queue) rows = get_n_rows_from_table(@db, table_name, offset, @batch) count += rows.count rows.each do |row| - event = LogStash::Event.new("host" => @host, "db" => @db) + event = LogStash::Event.new("host" => @host, "db" => @path) decorate(event) # store each column as a field in the event. row.each do |column, element|