From bbbf9c117c05c5db632a7f959297eb883701fe32 Mon Sep 17 00:00:00 2001 From: Eric Herot <400447+eherot@users.noreply.github.com> Date: Sun, 5 Nov 2023 17:24:31 -0500 Subject: [PATCH] Explicitly say that we are downloading and what the content length is --- README.md | 2 +- lib/logstash/inputs/s3/processor.rb | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/README.md b/README.md index 4578499..492036d 100644 --- a/README.md +++ b/README.md @@ -116,4 +116,4 @@ It is more important to the community that you are able to contribute. For more information about contributing, see the [CONTRIBUTING](https://github.com/elastic/logstash/blob/master/CONTRIBUTING.md) file. -Arbitrary change to trigger a build #2 +Arbitrary change to trigger a build #3 diff --git a/lib/logstash/inputs/s3/processor.rb b/lib/logstash/inputs/s3/processor.rb index 6a70089..22e60d2 100644 --- a/lib/logstash/inputs/s3/processor.rb +++ b/lib/logstash/inputs/s3/processor.rb @@ -18,6 +18,8 @@ def handle(remote_file) return if !validator.process?(remote_file) @logger.debug("Remote file passed validation. Downloading data.", :remote_file => remote_file) + puts "remote_file.content_length: #{remote_file.content_length} which is > 0. Downloading!" + remote_file.download! @logger.debug("File downloaded. Emitting events.", :remote_file => remote_file)