lib/logstash/inputs/google_cloud_storage.rb
# Fetches new files ready to be processed, downloads and processes them and finally
# runs post-processing steps.
Fetches new files ready to be processed, downloads and processes them and finally
runs post-processing steps.
Fetches new files ready to be processed downloads and processes them and finally runs post - processing steps .
def list_download_process
    list_processable_blobs do |blob|
      @logger.info("Found matching blob #{blob.uri}")
      download_and_process(blob)
      postprocess(blob)
    end
  end
def list_download_process list_processable_blobs do | blob | @logger . info ( "Found matching blob #{blob.uri}" ) download_and_process ( blob ) postprocess ( blob ) end end
Fetches new files ready to be processed, downloads and processes them and finally
runs post-processing steps.
Fetches new files ready to be processed downloads and processes them and finally runs post - processing steps .