使用 Logstash 进行数据摄取

Welcome to Logstash! It's a powerful, open-source data collection engine with real-time pipelining capabilities. It's a key component of the Elastic Stack (ELK stack), alongside Elasticsearch and Kibana.

Think of Logstash as the 'L' in ELK. Its job is to ingest data from various sources, process it, and then send it to a 'stash' (often Elasticsearch) for storage and analysis.

Logstash works by processing data through a pipeline. This pipeline consists of three main stages:

• Input: Where data is collected from its source.
• Filter: Where data is processed, parsed, and transformed.
• Output: Where processed data is sent to its destination.

Data flows sequentially from input to filter to output, allowing for flexible and powerful data manipulation.

The input stage is responsible for collecting data from various sources. Logstash supports a wide array of input plugins, allowing it to connect to almost any data source.

Common input sources include:

• Files: Reading logs from disk.
• Beats: Receiving data from lightweight data shippers like Filebeat or Metricbeat.
• HTTP/TCP/UDP: Listening for network traffic.
• Databases: Pulling data from relational databases.

Here's a simple Logstash configuration snippet using the file input plugin. This tells Logstash to read all .log files from the specified directory.

The type field helps categorize the incoming events, which can be useful later in filters or outputs.

The filter stage is where the magic happens! This is where you parse, modify, and enrich your raw data before it's sent to its destination.

Filter plugins can:

• Parse unstructured data: Like Apache logs using Grok.
• Mutate fields: Rename, remove, or add new fields.
• Add geographic data: Based on IP addresses using GeoIP.
• Perform conditional logic: Process data differently based on its content.

The grok filter is incredibly powerful for parsing unstructured log data into structured fields. It uses regular expressions but with pre-defined patterns for common log formats.

This example uses the COMBINEDAPACHELOG pattern to parse a typical Apache web server log line, extracting fields like IP address, timestamp, request, and status code.

Finally, the output stage is where Logstash sends the processed events. An event can be sent to multiple outputs simultaneously.

Common output destinations include:

• Elasticsearch: The most common destination for further indexing and search.
• Stdout: For debugging and testing your pipeline.
• File: Writing processed data to a new file.
• Kafka/Redis: For queuing or further processing by other systems.

This is a standard output configuration to send your processed data to an Elasticsearch cluster. You specify the hosts (your Elasticsearch node addresses) and the index name.

The %{+YYYY.MM.dd} syntax dynamically creates daily indices, which is a common practice for time-series data.

Now, let's combine all three stages into a single, complete Logstash configuration file. This pipeline reads Nginx access logs, parses them with Grok, and then sends the structured data to Elasticsearch.

This configuration would typically be saved as a .conf file, e.g., nginx-pipeline.conf.

To run your Logstash pipeline, you typically execute the logstash command-line tool, pointing it to your configuration file.

Before running it for real, it's good practice to test your configuration file for syntax errors using the --config.test_and_exit flag. This ensures your pipeline is valid before processing any data.

Which of the following statements about Logstash's pipeline stages are TRUE?

In this lesson, we explored Logstash, a crucial part of the Elastic Stack for data ingestion. We learned about its core pipeline concept, comprising input, filter, and output stages.

You now understand how Logstash collects data from various sources, transforms it using powerful filters like Grok, and then dispatches it to destinations such as Elasticsearch. This capability is essential for preparing diverse data for effective search and analysis.