可以在过滤器中使用ruby代码吗？如下所示： csv{ code => "
fieldArray = event['message'].split(',')
浏览 1提问于2015-08-19得票数 1
我正在使用logstash来读取一些日志。我有一个日志文件，时间戳只包含时间字段，即08:28:20,500，但没有日期字段。我想把它和今天的日期联系起来。我应该如何使用日期过滤器来完成这个任务。编辑后使用ruby作为过滤器，我已经设法解决了这个问题。然而，偶尔也会出现红宝石例外情况。从下面可以看出，第一条信息遇到了红宝石异常，而第二条消息运行良好。org.jboss.as.quickstarts.logging.LoggingExample",
浏览 0提问于2016-07-25得票数 0
回答已采纳
我有以下logstash配置： elasticsearch { hosts => ["localhost:9200"] }}
code => "
@@exists_pattern = ['foo', 'bar'].match => [ "my_timestamp&quo
浏览 29提问于2017-06-29得票数 2
回答已采纳
我试图从Logstash中的Ruby过滤器插件中调用一些Python代码。我遇到的问题是试图在Ruby脚本调用的Python代码中使用外部依赖关系造成的。正如我所预料的，Ruby没有“看到”那些依赖项，但是我以前从未使用过Ruby，也没有编写过Logstash过滤器插件，所以请帮助。:)input {
浏览 16提问于2022-10-17得票数 0
回答已采纳
我想得到帮助在红宝石过滤器的代码。我用ruby过滤器测试代码，如下所示，但我得到了_rubyexception。ruby { event['newfield'] = 'test' }:t
浏览 42提问于2016-08-03得票数 2
回答已采纳
1回答
我的logstash.conf中多次出现以下情况。if [body][content][totalConsumers] !
浏览 0提问于2016-04-11得票数 0
1回答
我在我的Logstash日志中得到了以下内容，并且无法知道它是从哪里来的：
filter { {
convert => [ "dt", "strin
浏览 3提问于2016-05-19得票数 3
1回答
我有logstash设置，从Redis列表中读取。目前，这些列表中的数据是空字符串，是否有一种方法可以使用压缩字符串，解压缩它们，然后处理相同的字符串？Logstash转发器(伐木工人)对我没有用，在我的例子中，我不得不使用Redis作为中间角色。当前的体系结构如下所示：我想：
.Net应用->压缩字符串-> redis列表-&g
浏览 0提问于2014-09-30得票数 0
回答已采纳
我正在考虑使用mutate过滤器和rename选项，但我不知道如何使用相应的正则表达式来实现： mutate { "any_field_with_underscore
浏览 2提问于2015-06-26得票数 1
我期待着在Logstash中接收到的输入上使用数学运算，但无法看到任何这样的过滤器。所以我想要一个简单的除法运算，如下所示：我可以看到一个，上面写着Logstash有数学过滤器，但这不是可见的。
浏览 219提问于2016-06-28得票数 7
回答已采纳
我有一个红宝石脚本，需要第三方宝石，我正在使用的过滤器部分的日志存储与码头建设出来。我正在使用logstash基映像，并在docker文件中安装ruby宝石。例如
RUN echo "gem '*
浏览 35提问于2022-08-24得票数 0
我的目标是能够根据传入日志文件中定义的变量动态计算logstash存储桶的日期。当需要访问出现在输出部分的过滤器部分中的变量时，我会感到困惑。
浏览 3提问于2017-04-13得票数 0
在这里，当我尝试使用logstash将MySQL值转换为嵌套的elasticsearch字段时，会得到以下错误。["org.logstash.Accessors.newCollectionException(Accessors.java:195)"input { }然而，如果我将重命名为一个尚未在映射中的字段，那么它工作得很好，并且它正确地将值添加为嵌套属性，我已经尝试
浏览 0提问于2017-08-08得票数 3
回答已采纳
2回答
我有下面的logstash输出插件，其中有一个条件，在启动管道时会产生来自logstash的错误。
卡夫卡输出过滤器支持条件词吗？在输出{r\n id => "plugin_SharedAlarmCreated"\r\n bootstrap_servers => " kafka -1:9092，kafka-2:9092，kafka:72:in initialize'", "/usr
浏览 8提问于2022-10-15得票数 0
回答已采纳
但是我想以一种不同的方式使用它，但是我不知道它是一个好的解决方案还是浪费时间/磁盘空间。我已经有一台FreeBSD 10.2机器充当远程syslog服务器，我的想法是将所有日志集中在这台机器上，而syslog服务器用logstash-forwarder将日志转发给ELK服务器。很明显，这种方法会提高这个设置的磁盘要求，但另一方面，我只安装了一台安装了logstash-forwarder守护进程的机器，这对我来说似乎不错。
但说到问题。logstash解析器将[host]与发送日志消息的服务器的主机名匹配，在这种方
浏览 0提问于2015-11-23得票数 8
回答已采纳
我正在尝试截断通过我的logstash转发器传入的消息。我的数据可以被截断，并且在没有截断的情况下，它会在我的日志提供程序中被截断，导致json中断。我已经将以下配置添加到我的logstash配置中 mutate { }我可能做错了什么，或者我应该使用另一种
浏览 0提问于2016-06-30得票数 2
我使用logstash2.1.3，我想在我的时区中显示@时间戳字段，就像“@时间戳”=> "2015-03-09T04:24:29.718+08:00“一样，我尝试在过滤器中使用ruby转换。filter event['@timestamp'].localti
浏览 2提问于2016-04-29得票数 0
回答已采纳
2回答
我已经为logstash编写了一个自定义过滤器插件来调用一个java类。要求：自定义插件:对于队列中的每条消息，调用java类require "logstash/filters/base"require "logstash/namespace"require "test.j
浏览 5提问于2016-12-29得票数 1
回答已采纳
我在一个CSV文件中读取了Logstash，该文件包含一个字段my_id，是一个由数字组成的8位字符串。我对Logstash非常陌生，但我一直在阅读，我认为我需要使用grok过滤器来完成这个任务--我创建第一个字段的尝试到目前为止还没有奏效
浏览 1提问于2016-08-02得票数 2
回答已采纳
云服务器
ICP备案
实时音视频
即时通信 IM
云直播
腾讯云开发者
