Logstash-input-mongodb configuration file

Elastic Stack Logstash
1

Hi all,

I am trying to pull data out of mongodb and to process it with Logstash.

Know that I want to pull all the data from a DB named "test" and so I started with the collection named "student". This is my configuration file.

input {
	mongodb {
		uri => 'mongodb://localhost:27017/test'
		placeholder_db_dir => '/opt/logstash-mongodb/'
		placeholder_db_name => 'logstash_sqlite.db'
		collection => 'student'
		batch_size => 202
	}
}

filter {

}

output {
	elasticsearch {
		host => "localhost:9200"
		user => elastic
		password => changeme
		index => "testStudent"
	}
	stdout { codec => rubydebug }
}

I am having an error saying:
Pipelines YAML file is empty.

Is this because I left the filter part empty?

2

Where did you put this configuration?
You need to put it in a .conf file under this path (if you installed logstash as a service in Linux) /etc/logstash/conf.d/

3

Logstash is installed from a TGZ
I put the config file in ~/Downloads/logstash/config

4

And how you started Logstash?
Can you please check the logs and see if there is any abnormal behavior

5

started logstash with this cmd:
bin/logstash --path.data file_name.conf

I actually tried to load csv data with this exact same process: the config file in logstash/config + the same cmd

6

Apparently, you need to configure Logstash pipelines when you're configuring more than one pipeline

7

within logstash/config there is the piplines.yml file and here is what it contains:

# List of pipelines to be loaded by Logstash
#
# This document must be a list of dictionaries/hashes, where the keys/values are pipeline settings.
# Default values for ommitted settings are read from the `logstash.yml` file.
# When declaring multiple pipelines, each MUST have its own `pipeline.id`.
#
# Example of two pipelines:
#
# - pipeline.id: test
#   pipeline.workers: 1
#   pipeline.batch.size: 1
#   config.string: "input { generator {} } filter { sleep { time => 1 } } output { stdout { codec => dots } }"
# - pipeline.id: another_test
#   queue.type: persisted
#   path.config: "/tmp/logstash/*.config"
#
# Available options:
#
#   # name of the pipeline
#   pipeline.id: mylogs
#
#   # The configuration string to be used by this pipeline
#   config.string: "input { generator {} } filter { sleep { time => 1 } } output { stdout { codec => dots } }"
#
#   # The path from where to read the configuration text
#   path.config: "/etc/conf.d/logstash/myconfig.cfg"
#
#   # How many worker threads execute the Filters+Outputs stage of the pipeline
#   pipeline.workers: 1 (actually defaults to number of CPUs)
#
#   # How many events to retrieve from inputs before sending to filters+workers
#   pipeline.batch.size: 125
#
#   # How long to wait in milliseconds while polling for the next event
#   # before dispatching an undersized batch to filters+outputs
#   pipeline.batch.delay: 50
#
#   # How many workers should be used per output plugin instance
#   pipeline.output.workers: 1
#
#   # Internal queuing model, "memory" for legacy in-memory based queuing and
#   # "persisted" for disk-based acked queueing. Defaults is memory
#   queue.type: memory
#
#   # If using queue.type: persisted, the page data files size. The queue data consists of
#   # append-only data files separated into pages. Default is 64mb
#   queue.page_capacity: 64mb
#
#   # If using queue.type: persisted, the maximum number of unread events in the queue.
#   # Default is 0 (unlimited)
#   queue.max_events: 0
#
#   # If using queue.type: persisted, the total capacity of the queue in number of bytes.
#   # Default is 1024mb or 1gb
#   queue.max_bytes: 1024mb
#
#   # If using queue.type: persisted, the maximum number of acked events before forcing a checkpoint
#   # Default is 1024, 0 for unlimited
#   queue.checkpoint.acks: 1024
#
#   # If using queue.type: persisted, the maximum number of written events before forcing a checkpoint
#   # Default is 1024, 0 for unlimited
#   queue.checkpoint.writes: 1024
#
#   # If using queue.type: persisted, the interval in milliseconds when a checkpoint is forced on the head page
#   # Default is 1000, 0 for no periodic checkpoint.
#   queue.checkpoint.interval: 1000
#
#   # Enable Dead Letter Queueing for this pipeline.
#   dead_letter_queue.enable: false
#
#   If using dead_letter_queue.enable: true, the maximum size of dead letter queue for this pipeline. Entries
#   will be dropped if they would increase the size of the dead letter queue beyond this setting.
#   Default is 1024mb
#   dead_letter_queue.max_bytes: 1024mb
#
#   If using dead_letter_queue.enable: true, the directory path where the data files will be stored.
#   Default is path.data/dead_letter_queue
#
#   path.dead_letter_queue:

I did not make any changes to this pipelines.yml file because I am not running multiple pipelines (at least as for now).

8

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.