Nessuna descrizione http://j1x-huginn.herokuapp.com

read_file_agent.rb 1.1KB

    module Agents class ReadFileAgent < Agent include FormConfigurable include FileHandling cannot_be_scheduled! consumes_file_pointer! def default_options { 'data_key' => 'data' } end description do <<-MD The ReadFileAgent takes events from `FileHandling` agents, reads the file, and emits the contents as a string. `data_key` specifies the key of the emitted event which contains the file contents. #{receiving_file_handling_agent_description} MD end event_description <<-MD { "data" => '...' } MD form_configurable :data_key, type: :string def validate_options if options['data_key'].blank? errors.add(:base, "The 'data_key' options is required.") end end def working? received_event_without_error? end def receive(incoming_events) incoming_events.each do |event| next unless io = get_io(event) create_event payload: { interpolated['data_key'] => io.read } end end end end