in lib/logstash/outputs/kusto.rb [376:400]
def recover_past_files
require 'find'
path_last_char = @path.length - 1
pattern_start = @path.index('%') || path_last_char
last_folder_before_pattern = @path.rindex('/', pattern_start) || path_last_char
new_path = path[0..last_folder_before_pattern]
begin
return unless Dir.exist?(new_path)
@logger.info("Going to recover old files in path #{@new_path}")
old_files = Find.find(new_path).select { |p| /.*\.
@logger.info("Found #{old_files.length} old file(s), sending them now...")
old_files.each do |file|
kusto_send_file(file)
end
rescue Errno::ENOENT => e
@logger.warn('No such file or directory', exception: e.class, message: e.message, path: new_path, backtrace: e.backtrace)
end
end