LOGSTASH过滤器|同一文件的多个模式
是一种用于日志数据处理和转换的工具，它可以通过定义一系列过滤规则，对输入的日志数据进行解析、过滤、转换和格式化，以便更好地理解和分析日志信息。
是指在一个日志文件中存在多种不同的日志模式，每种模式对应着不同的日志格式。使用LOGSTASH过滤器可以根据不同的模式，将日志数据分别解析和处理，以便后续的分析和存储。
LOGSTASH过滤器的分类：
- Grok过滤器：用于解析和匹配结构化的日志数据，可以根据预定义的模式或自定义的正则表达式，将日志数据中的字段提取出来，并赋予相应的含义。
- Date过滤器：用于解析和处理日期和时间相关的字段，可以将字符串类型的日期时间转换为标准的时间格式，以便后续的时间序列分析。
- Mutate过滤器：用于对字段进行修改和转换，可以添加、删除、重命名和替换字段的值，以满足特定的需求。
- Drop过滤器：用于丢弃不符合条件的日志事件，可以根据指定的条件，过滤掉不需要的日志数据。
- Translate过滤器：用于根据预定义的映射表，将某个字段的值进行转换，可以将一些特定的值映射为更易理解的文本。
LOGSTASH过滤器的优势：
- 灵活性：LOGSTASH过滤器提供了多种过滤器类型和配置选项，可以根据具体需求进行灵活的配置和定制。
- 可扩展性：LOGSTASH过滤器支持自定义的正则表达式和模式，可以适应不同的日志格式和数据结构。
- 高性能：LOGSTASH过滤器采用了高效的并发处理机制，能够快速处理大量的日志数据。
- 可视化：LOGSTASH过滤器的配置和运行状态可以通过Kibana等可视化工具进行监控和管理，方便用户进行调试和优化。
LOGSTASH过滤器的应用场景：
- 日志分析：通过解析和过滤日志数据，提取关键信息，进行日志分析和故障排查。
- 安全监控：通过过滤和转换网络设备的日志数据，实时监控网络安全事件，及时发现和应对潜在的安全威胁。
- 应用性能监控：通过解析和处理应用程序的日志数据，监控应用性能指标，及时发现和解决性能问题。
- 数据清洗和转换：通过过滤和转换数据，将不同格式和结构的数据统一为标准格式，以便后续的数据分析和挖掘。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云LOGSTASH服务：https://cloud.tencent.com/product/logstash
- 腾讯云日志服务CLS：https://cloud.tencent.com/product/cls
- 腾讯云云原生应用引擎TKE：https://cloud.tencent.com/product/tke
- 腾讯云云服务器CVM：https://cloud.tencent.com/product/cvm
- 腾讯云数据库TencentDB：https://cloud.tencent.com/product/cdb
- 腾讯云人工智能AI：https://cloud.tencent.com/product/ai
- 腾讯云物联网IoT Hub：https://cloud.tencent.com/product/iothub
- 腾讯云移动开发MPS：https://cloud.tencent.com/product/mps
- 腾讯云对象存储COS：https://cloud.tencent.com/product/cos
- 腾讯云区块链BCS：https://cloud.tencent.com/product/bcs
- 腾讯云元宇宙：https://cloud.tencent.com/product/vr
相关·内容
需要一点帮助来找出管道没有启动的原因。
[ERROR][logstash.agent] Cannot create pipeline {:reason=>"Expected one of #, => at line 39, column 52 (byte 563) after filter {\n grok {\n patterns_dir => \"/etc/logstash/patterns.d\" \n match => {\n \"%{SYSLOGBASE} %{POSTFIXSMTPDCONNECTS}\""}
浏览 4提问于2018-02-15得票数 0
回答已采纳
1回答
我正在创建logstash管道，我将日志文件作为输入并在elasticsearch上读取这些日志。我想在我的日志存储管道配置中添加geoip过滤器，但是当我添加它时，它会失败并关闭。
以下是一个错误：
[2022-03-17T12:41:05,243][WARN ][logstash.outputs.elasticsearch][main]
Elasticsearch Output configured with `ecs_compatibility => v8`, which
resolved to an UNRELEASED preview of version 8.0
浏览 9提问于2022-03-17得票数 0
回答已采纳
现在，当logstash过滤器获得eof时，似乎logstash过滤器还在运行，但是文件没有更多的日志输出到elasticsearch索引。
当文件(eof)结束时，我如何摆脱logstash过滤器来执行其他任务？
浏览 2提问于2015-07-22得票数 2
回答已采纳
1回答
我有弹性Beats (像节拍器和audit节拍)将数据发送到logstash。为了测试目的，我想模拟一些从拍子到日志存储输入的数据。
我在节拍中使用logstash输出插件(yaml配置文件)：
output.logstash:
enabled: true
hosts: ["127.0.0.1:5044"]
以及logstash中的B拍输入插件(.conf管道配置文件)：
input {
beats {
port => "5044"
}
}
我天真地假设拍子是通过HTTP请求与logstash通信的，所以我使用Pos
浏览 3提问于2020-09-11得票数 1
回答已采纳
我需要使用Logstash解析nginx日志，我发现了这个问题： Nginx grok pattern for logstash 我想尝试问题中的模式，所以我创建了包含以下内容的配置文件： input {
file {
path => "/var/log/nginx/access.log"
type => "access"
}
}
filter {
grok {
match => {
"message" => '%{IPORHOST:clientip} %{NGU
浏览 112提问于2021-03-24得票数 0
回答已采纳
你好，谢谢你抽出时间。我需要创建配置文件，这是输入：
2017-02-14T13:39:33+02:00 PulseSecure: 2017-02-14 13:39:33 - ive - 10.16.4.225 dpnini(用户)[]-测试密码域限制对dpnini/用户失败
这是所需的文本文件输出：
{“时间戳”：“2017-02-14T13:39:33+02:00”、“供应商”：“PulseSecure”、"localEventTime":"2017-02-14 13:39:33“、"userIP":"10.16.4.225”、“用
浏览 5提问于2017-03-07得票数 1
回答已采纳
我有一个CSV形式的IMDB数据库转储。CSV如下所示：
name, movie, role
"'El Burro' Van Rankin, Jorge","Serafín (1999)",PLAYED_IN
"'El Burro' Van Rankin, Jorge","Serafín (1999)",PLAYED_IN
"'El Burro' Van Rankin, Jorge","Serafín (1999)",PLAYED_IN
.......
浏览 6提问于2017-01-18得票数 0
回答已采纳
1回答
到目前为止，我有一个正在运行的ELK安装，我想使用它来分析来自不同来源的日志文件：
nginx-原木
八月原木
等等..。
我正在使用file节拍从日志文件中收集内容，并使用这个filebeat.yml将其发送到logstash：
filebeat.inputs:
- type: log
enabled: true
paths:
- /var/log/*.log
- /var/nginx/example_com/logs/
output.logstash:
hosts: ["localhost:5044"]
在logstash中
浏览 0提问于2019-01-14得票数 0
回答已采纳
1回答
有人知道什么是错误吗？
#/usr/java/jre1.7.0/bin/java -cp /home/spatel/logstash logstash.runner agent -f logstash-syslog.conf
Grok::PatternError: pattern %{IPORHOST:device} not defined
compile at /home/spatel/logstash/gems/jls-grok-0.10.7/lib/grok-pure.rb:131
loop at org/jrub
浏览 2提问于2012-12-06得票数 0
回答已采纳
我安装了elasticsearch和kibana，并且我正在学习本教程。和我完美地插入和读取数据，例如：
PUT /customer/external/1?pretty
{
"name": "John Doe"
}
因此，这让我想知道，我需要logstash或filebeats做什么？我的计划是将网站上的每个web请求记录到elasticsearch以进行分析。
我需要安装logstash吗？我不明白我要它做什么。(我不打算将其存储在文件中)我将从PHP脚本中读取请求信息(例如，ip地址、时间、user_id等)，然后简单地通过HTTP REST REQUE
浏览 0提问于2017-02-25得票数 6
我刚刚安装了一个ELK堆栈，但是对于/etc/ logstash /conf.d .d中的logstash配置，我有两个输入源正在从一个linux服务器上转发，该服务器上安装了一个logstash转发器，其“文件”如下：
{
"paths": ["/var/log/syslog","/var/log/auth.log"],
"fields": { "type": "syslog" }
},
{
"paths": ["/va
浏览 3提问于2015-04-29得票数 3
回答已采纳
考虑到建议，我设置了logstash编码器+ logstash转发程序，以将所有内容推送到logstash，并最终在ElasticSearch中索引所有内容。
这是我的配置：
logstash.xml
<included>
<include resource="org/springframework/boot/logging/logback/base.xml"/>
<property name="FILE_LOGSTASH" value="${LOG_FILE:-${LOG_PATH:-${LOG_TEMP
浏览 4提问于2015-08-31得票数 2
回答已采纳
我想使用logstash conf文件将日志从不同位置发送到elasticsearch。
input {
file
{
path => "C:/Users/611166850/Desktop/logstash-5.0.2/logstash-5.0.2/logs/logs/ce.log"
type => "CE"
start_position => "beginning"
}
file
{
path => "C:/Users/611166850/Desktop/logsta
浏览 5提问于2017-01-24得票数 0
我对logstash很陌生，我试着通过不同的博客/链接来了解它的细节。我遇到了一个问题，我想解析Json字符串，它嵌入在一个普通的字符串行中。
输入串
{“时间戳”：1485518878968，"h":"297268184dde"，"l":" INFO "，"cN":"org.com.logstash.demo"，"mN":"loadProperties"，“m”：“从//var/tmp/conf加载属性文件”}。
我想提取突出显示的Json字符串并在Json
浏览 1提问于2017-02-06得票数 0
回答已采纳
我有一个日志文件，其中包含复杂的消息类型。下面是一个示例：
2016-07-07 13:30:02 [Main] *** Program start ***
2016-07-07 13:30:02 [UnzipFile] Before file collection
2016-07-07 13:30:02 [GetZipCol] Start get sorted zip file collection
2016-07-07 13:30:02 [GetZipCol] End get sorted zip file collection
2016-07-07 13:30:02 [Main] [ER
浏览 1提问于2016-07-07得票数 0
回答已采纳
我在Kubernetes中安装了一个文件节拍的-> logstash -> elasticsearch -> kibana堆栈，其中包含了头盔图表：
helm repo add incubator http://storage.googleapis.com/kubernetes-charts-incubator
helm install --name elastic --namespace monitoring incubator/elasticsearch --set client.replicas=1,master.replicas=2,data.replicas=1
浏览 1提问于2018-09-11得票数 4
1回答
我是ELK堆栈的新手，但是在阅读了文档之后，我仍然无法让logstash识别
日志如下所示
2014-11-30 03:30:01.000118,122.99.34.242,123.56.212.1,44,u,q,NA,0 ? a.root-servers.net A
我的logstash过滤器是这样的
filter {
date {
#2014-11-30 03:30:01.000118,122.99.34.242,123.56.212.1,44,u,q,NA,0 ? a.root-servers.net A
m
浏览 2提问于2014-12-03得票数 0
1回答
是否有一种方法可以从已经定义的字段中保存字段？
我有以下过滤器：
grok {
match => [ "message", "\[%{TIMESTAMP_ISO8601:timestamp}\]\s+\[%{DATA:homebridge_app}\]\s+%{GREEDYDATA:log_message}" ]
}
这将导致"log_message“填充如下所示：
Current temperature for Entryway Thermostat is: 20.5 C
Current humidity for Entryway Therm
浏览 5提问于2017-10-27得票数 1
回答已采纳
我是ELK新手，我想建立一个用ES索引Microsoft和应用.NET日志的解决方案。
我知道不同的方法：
1) 应用服务器:日志文件➔Logstash➔收集服务器: Redis➔Logstash➔ES集群: ES➔Kibana
此方法的缺点是必须在每个生成日志的Windows服务器上安装、配置和维护一个logstash实例
2) 应用服务器:日志文件➔文件➔收集服务器: Logstash➔Redis➔Logstash➔ES集群: ES➔Kibana
这种方法的缺点是，当前文件拍不支持多行日志条目，而且我的.NET应用程序会产生多行异常。我不知道如何配置中间logstash+redis+log
浏览 0提问于2015-12-20得票数 0
回答已采纳
我搜索了logstash文档，但是找不到logstash是如何执行过滤器的。
我会举例解释：
多个配置文件，apache.conf nginx.conf logic.conf --无论是nginx还是apache --配置文件都包含一个过滤器，如果满足它们的类型，它将触发，并添加一个名为"please_do_logic“的标记。
logic.conf包含几个grok过滤器，这些过滤器将从nginx.conf和apache.conf中的前几行挂起的日志行中提取请求部分。
我有两个问题：
logstash如何决定首先执行哪个配置文件？
如何确保在执行logic.co
浏览 0提问于2014-06-10得票数 0
回答已采纳
我运行两个Logstash实例，一个作为“发货人”，一个作为“索引器”。
我希望发货人拿起原木，然后用伐木机把它们转发给索引机。索引器写入elasticsearch。
为了进行过滤，应该在哪里定义过滤器？在发货人身上？索引器？两者都有？
示例过滤器是key+value提取和时间戳标识。
从文档中也不清楚伐木工人是如何编码/解码消息的，所以我不确定我在处理什么。
(对于奖金，答案是否也适用于物流代理？)
使用Logstash 1.4.2。配置如下。
机器“托运人”
input{
file{
path=>["/var/log/blah.log"]
tags
浏览 1提问于2015-02-27得票数 1
回答已采纳
我正在摄取许多日志，包括/var/log/syslog、/var/log/messages，但也包括一些通用事件格式(，CEF)的专有日志，以及其他各种格式的专有日志。这些日志的条目是从运行在不同节点上的File节拍中发送到Logstash的，例如：
filebeat.inputs:
- type: log
enabled: true
paths:
- /var/log/messages
- /var/log/syslog
- /var/log/acme/audit.log
- /var/log/acme/debug.log
浏览 0提问于2018-12-06得票数 1
回答已采纳
我使用elasticsearch和logstash来可视化带有kibana的数据集。
我按照规范创建了一个配置文件，让elasticsearch和kibana启动并运行，然后加载配置文件。当我完成加载文件时，我将收到下面的消息。我知道文件没有加载，因为我会在提示符中看到数据集。我还在kibana仪表板中搜索索引，但它没有向我显示索引。
下面是我收到的提示消息：
Thread.exclusive is deprecated, use Thread::Mutex
Sending Logstash logs to D:/AMS/Softwares/logstash-7.4.2/logs which
浏览 5提问于2019-11-25得票数 0
回答已采纳
假设您的日志防火墙文件中有3行不同的行，并且您希望：
使用专用的弹性搜索输出将结果存储到弹性搜索集群中。
我应该在我的logstash.conf中做什么?？
谢谢。
浏览 2提问于2015-04-14得票数 0
我在Linux - AWS ec2-instance上使用Elasticsearch 5.5.0和logstash 5.5.0。
有一个位于/etc/logstash/conf.d中的logstash_etl.conf文件：
input {
jdbc {
jdbc_connection_string => "jdbc:mysql://localhost:3306/mydatabase"
jdbc_user => "root"
jdbc_password => ""
浏览 2提问于2018-04-07得票数 0
我想从五个新闻网站上获得RSS提要，其中RSS日志存储输入插件，以及twitter推特和twitter插件，我为创建了一个logstash配置文件，另一个用于twitter。我的问题是，我能通过这个命令bin/logstash -f first_config.conf和bin/logstash -f second_config.conf运行多个logstash实例吗?如果可以的话，我会面临瓶颈问题吗？
浏览 0提问于2016-11-10得票数 0
1回答
我使用的是LogStash，它接受来自日志文件的数据，该文件有不同类型的日志。
我试过这个：
filter {
grok {
match => { "message" => "%{WORD:tag} %{WORD:message} %{WORD:value}
}
}
但它不起作用。
浏览 13提问于2016-08-19得票数 0
回答已采纳
1回答
我正在使用elk堆栈来分析日志数据，并且必须处理大量的日志数据。看起来所有的日志都可以用logstash/grok解析。
有没有一种方法可以用基班纳搜索无法解析的日志？
浏览 1提问于2015-06-13得票数 0
回答已采纳
在Logstash中，我希望使用日期过滤器将字符串转换为时间戳。字符串如下所示： Fri Nov 05 06:24:28.651 CET 2021 我尝试了以下模式，但没有效果： date {
match => [ "syslog_timestamp", "EEE MMM dd HH:mm:ss.SSS ZZZ yyyy"]
locale => "en_US"
timezone => "Europe/Berlin"
target => "sysl
浏览 28提问于2021-11-05得票数 0
我有rsyslog通过TCP将日志转发到logstash。如果logstash不可用，rsyslog将建立队列。
如果logstash可用，但elasticsearch已死亡，或由于某种原因无法写入文件系统。
是否有一种方式使logstash拒绝进一步的TCP消息。
谢谢
浏览 5提问于2014-04-25得票数 1
我一直在遵循这个指南：
我希望这将帮助我测试我的logstash过滤器，看看我是否在完全使用它们之前获得了所需的输出。
作为指南的一部分，它告诉您设置输入和输出，然后设置过滤器文件。输入似乎工作得很好：
input {
stdin { }
}
输出是这样的：
output {
stdout {
codec => json
}
file {
codec => json
path => /tmp/debug-filters.json
}
}
当我尝试运行logstash进程时，我得到了以下错
浏览 0提问于2014-11-01得票数 6
回答已采纳
1回答
我的原木行是这样的：
11:05:44,924 DEBUG DataFeed:? - Data received: data=TextMessage={ Header={ JMSMessageID={ID:someId} JMSDestination={Topic[someTopic]} JMSReplyTo={null} JMSDeliveryMode={NON_PERSISTENT} JMSRedelivered={false} JMSCorrelationID={null} JMSType={null} JMSTimestamp={Tue Aug 30 11:05:44 BST 2016
浏览 2提问于2016-08-30得票数 0
回答已采纳
我使用OSSEC收集日志，并使用logstash将JSON日志转发到logstash。这是我的逻辑存储配置。
input {
lumberjack {
port => 10516
type => "lumberjack"
ssl_certificate => "/etc/pki/tls/certs/logstash-forwarder.crt"
ssl_key => "/etc/pki/tls/private/logstash-forwarder.key"
codec =&
浏览 5提问于2015-09-23得票数 1
回答已采纳
我使用ELK(filebeat，logstash，elasticsearch，kibana)来进行日志管理。在一个日志文件中，我有三种格式。我在用
在一种格式中，我有date+parameters+json+stacktrace。这种格式文本有多行。在第二种格式中，它只是date+requestMethod(Get或post)+一些文本。就在一条线上。在第三种格式中，它有date+模块名：(在本例中是paymentAdmin)+json
我想我可以使用logStash来处理这三种格式，包括if、else if子句和3种匹配器。有人能告诉我如何写if，否则if子句来处理一个日志文件中的3种格式吗
浏览 0提问于2018-04-11得票数 1
回答已采纳
1回答
我有一个日志文件，它是一个对象数组，如下所示：
[
{ "cate1": "data1a", "cate2": "data2a" },
{ "cate1": "data1b", "cate2": "data2b" },
{ "cate1": "data1c", "cate2": "data2c" }
]
我需要数组中的每个对象成为Elasticsearch中的一个单独的条目，而每个"c
浏览 0提问于2016-07-19得票数 2
您好，我是ELK堆栈的新手
在后台运行logstash进程，当它获得匹配的文件模式时，它会显示如下所示
我想在这里了解path.data选项的重要性，请帮帮我
[FATAL][logstash.runner] Logstash could not be started because there is already another instance using the configured data directory. If you wish to run multiple instances, you must change the "path.data" setting
浏览 3提问于2018-06-28得票数 9
我已经创建了一个logstash脚本来读取一个日志文件，该文件具有不同的时间戳格式"2018-05-08T12:18:53.506+0530“。我正在尝试使用log stash中的日期过滤器将其解析为日期
date{
match => ["edrTimestamp","yyyy-MM-dd'T'HH:mm:ss.SSS'Z'","ISO8601"]
target => "edrTimestamp"
}
运行上面的logstash脚本，它会创建一个弹性搜索索引。
浏览 7提问于2018-05-23得票数 1
我目前正在尝试用Kubernetes配置Logstash集群，我希望让每个logstash节点以只读方式安装一个卷和管道。然后将这个卷作为读/写安装在单个管理实例上，在其中我可以编辑信任。
这在K8s和GCEPersistentDisk中是可能的吗？
浏览 2提问于2018-11-30得票数 4
回答已采纳
2回答
我们已经在日常日志上配置了ELK堆栈，并使用Kibana UI对日志集执行基本的搜索/查询操作。
我们的一些日志在消息中有一个特定的字段，而另一些则没有。因此，在配置Logstash时，我们没有将它配置为一个单独的字段。
我有这样的日志：
[28/Jun/2016:23:59:56 +0530] 192.168.xxx.xxx [API:Profile]get_data_login: Project password success: 9xxxxxxxxx0
[28/Jun/2016:23:59:56 +0530] 192.168.xxx.xxx [API:Profile]session_e
浏览 4提问于2016-06-29得票数 3
回答已采纳
我正在编写一个Logstash配置文件。
我有个滤嘴器。我想知道grok过滤器中的匹配是如何工作的。
我提到了逻辑存储端的一个例子，并看到了以下内容：
Ex日志：55.3.244.1 GET /index.html 15824 0.043
它是用下面的过滤器解析的：
filter {
grok {
match => { "message" => "%{IP:client} %{WORD:method} %{URIPATHPARAM:request} %{NUMBER:bytes} %{NUMBER:duration}" }
}
这意味
浏览 5提问于2016-07-12得票数 0
我试图在中使用Logstash，.yml文件如下所示：
user-service:
image: images/user-service
ports:
- "2222:2222"
links:
- logstash
logstash:
image: images/logstash
command: logstash -e 'input{} output{}'
ports:
- "5045:5045"
如控制台所示，logstash开始和结束：
logstash_1 | Sending Logstash's l
浏览 3提问于2016-12-13得票数 3
回答已采纳
1回答
匹配整个文件
、、
我正在尝试使用logstash将整个文本文件作为消息提供给ElasticSearch。我正在尝试使用多行编解码器，但是我不知道我必须使用什么模式。((.|\n)*)此正则表达式匹配所有文本，但这不适用于logstash。
input {
file {
path => "/opt/rp/*.txt"
type => "rp"
start_position => "beginning"
stat_interval => 1
codec => multilin
浏览 0提问于2015-08-07得票数 0
1回答
缺少索引模式
、、、、
我在Kibana中遗漏了一些索引模式，我一直在试图弄清楚为什么会出现这种情况。我已经安装了logstash、elasticsearch和kibana并启动了服务。如何在本节中显示logstash、apache-access等？只有文件节拍显示。 ? 我对localhost和port使用CURL命令来查看索引，只显示kibana和filebeat，apache-access和logstash看不到。 有没有人可以指引我正确的方向来解决这个问题，并且能够在patterns部分下看到“logstash”和“apache-access”。
浏览 59提问于2021-03-23得票数 0
我一直试图从logstash.yml文件中运行一个非常简单的SQL查询，并对AWS进行查询。
logstash.yml文件：
input {
jdbc {
jdbc_connection_string => "jdbc:postgresql://abcxyz.ap-south-1.rds.amazonaws.com:5432/k***"
jdbc_user => "k***"
jdbc_password => "p**********s"
浏览 9提问于2021-12-23得票数 0
我正在使用Logstash将Glassfish 4日志文件发送到ElasticSearch接收器。如何使用Logstash从消息字段中删除尾随的换行符？
{
"@timestamp" => "2013-11-21T13:29:33.081Z",
"message" => "[2013-11-21T13:29:32.577+0000] [glassfish 4.0] [INFO] [] [javax.resourceadapter.mqjmsra.lifecycle] [tid: _ThreadID=142 _Thre
浏览 0提问于2013-11-21得票数 2
回答已采纳
我正在尝试(并且失败)让定制模式使用logstash2.4.0。以下是conf文件的相关部分：
#some parsing happens above...
grok {
patterns_dir => ["/config_dir/patterns"]
match => [ "syslog_message", "%{QID:qid}:" ]
}
(完整配置位于末尾)-- patterns目录仅包含文件sendmail.grok：
#########
QID a
运行这个I get (重新格式
浏览 0提问于2016-10-25得票数 0
我有一个正在做的项目，想试着从logstash开始将它挂接到ELK堆栈上。实际上，我让python将这段代码写入一个名为stockLog的文件：
{'price': 30.98, 'timestamp': '2015-08-03 09:51:54', 'symbol':'FORTY',
'ceiling': Decimal('31.21'), 'floor': Decimal('30.68')}
我已经安装了logstash，并且(理想情况下)可以
浏览 1提问于2015-08-04得票数 0
我是个新手，不爱乱七八糟。我正在尝试为我的logstash实例设置多个配置文件。使用file节拍将数据发送到logstash。即使我为这两个logstash配置文件创建了过滤器，我也会得到重复的数据。
Logstash配置文件- 1：
input {
beats {
port => 5045
}
}
filter {
if [fields][env] == "prod" {
grok { match => { "message" => "%{LOGLEVEL:loglevel}] %{GREEDYD
浏览 1提问于2022-01-20得票数 0
回答已采纳
我在当地安装了logstash-elasticsearch-kibana。现在我想配置logstash来将数据推送到elasticsearch中，下面的代码与弹性页面指南中的教程相同。但我无法成功地运行配置文件。有一次例外，但我不知道为什么，然后我又试了一次，但还是失败了
这是第一个管道. This
input {
file {
path => "D:/grok.log"
start_position => beginning
}
}
filter {
grok {
match => {
浏览 4提问于2015-08-25得票数 1
例如，下面是我的日志文件
[2016-10-18 12:05:53.228] log example
[2016-10-18 11:55:53.228] 19249060-91df-11e6-be68-753fa0e2c729 logg example
[2016-10-18 11:35:53.228] 19249060-91ff-11e6-be68-753fa0e2c729 loggg example /api/userbasic/userinfo?requestedUserId=19249060-91df-11e6-be68-753fa0e2c729
log.here的grok过滤器我
浏览 1提问于2016-11-11得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
