0回答
我正在尝试从python2.7调用一个在conf名称中包含vars的logstash命令，我尝试运行的完整shell命令是：下面是我的Python代码：b = '/tmp/%s.txt' % (listname)
c = '/tm
浏览 0提问于2017-06-14得票数 0
回答已采纳
假设我有一个Logstash实例在运行，但想要干净利落地停止它，例如更改它的配置。
如何停止Logstash实例，同时确保它完成将批量数据发送到Elasticsearch？我不想在停止logstash时丢失任何日志。
浏览 6提问于2015-04-20得票数 9
回答已采纳
我正在使用logstash将消息放入AWS Kinesis流，输出插件需要身份验证，此身份验证将引用环境变量或来自文件。我们不必在logstash配置中设置用户和访问密钥，默认情况下，它将引用环境变量或文件。现在，此凭据将更改，我必须重新加载logstash管道。使用热重新加载或自动重新加载时，我认为logstash将查找配置中的任何更改，但在我的示例中，logstash配置不会更
浏览 29提问于2019-04-18得票数 0
我们刚刚从2.X切换到5.X，我试图了解如何在管道配置文件中使用环境变量。管道配置文件如下所示： mutate {
add_field => { "some_field" => "${HOSTNAME}"}添加HOSTNAME作为通常的环境变量，并在read-EOM部件之间添加它，但没有任何积极的结果。如果我将下面的部分添加到/usr/share/logst
浏览 6提问于2017-02-16得票数 4
当我试图设置一个使用http输入插件的管道时，我在logstash中收到了这个错误Error: Cannot assign requested address。我正在尝试使用Python请求http库将数据从Python进程发送到logstash。我不确定在logstash http输入配置中使用哪个主机和端口。我应该使用默认值、logstash pod ClusterIP服务IP、logstash pod IP还是其他什么？inpu
浏览 17提问于2019-07-12得票数 1
回答已采纳
您的第一个答案是使用perl或python并通过管道将输入传递给C程序，但不幸的是，我要输入的变量不是从C程序的参数中获取值，而是交互地提示用户输入值。我的缓冲区有8个字节的大小，任何超过8个字节的东西都会覆盖前面的变量，这正是我想要的，我想用值1335覆盖那个变量。要覆盖的变量是b，并且它是int类型。因此，将1335转换为十六进制得到537，我必须用8个a覆盖缓冲区，然后是十六进制37，05，0
浏览 11提问于2016-08-14得票数 0
回答已采纳
我的主要目的是发送日志到Kiabana，我得到了一个host和port的Logstash (我的老板给我的)test_logger.setLevel(logging.INFO)
test_logger.addHandler(host, 5
浏览 18提问于2021-05-26得票数 0
回答已采纳
它在logstash .Can中没有被解析，有人帮助识别问题。: u'AAAA='}, u'message_type': u'LICENSE', u'cert_serial_number': u'AAAASSSSEERRTTYUUIIOOOasa='}
我需要在logstash
浏览 2提问于2016-01-16得票数 0
我使用了数据处理器管道如下所示。但失败了。纠正我这里的任何错误。"formats" : ["YYYY-MM-ddThh:mm:ss.Z"] } ]我创建了管道并使用了重新索引
浏览 0提问于2019-02-13得票数 0
回答已采纳
我在我的ubuntu服务器中有我的logstash配置，它从postgres数据库读取数据并将数据发送到弹性搜索。我已经在每15分钟配置了一个日程，logstash将查看postgres表，如果表中有任何更改，它会将数据发送给弹性搜索。我在网上提到了很
浏览 3提问于2019-10-23得票数 2
回答已采纳
是否可以在logstash配置中引用环境变量？
在我的例子中，我想让我在环境中设置的elasticsearch地址是可配置的。
浏览 3提问于2014-06-03得票数 13
2回答
我配置了logstash和其他东西，并将syslog测试消息发送到logstash。一切都很好。现在我尝试从Cisco WLC和Cisco交换机发送syslog消息到logstash，并且消息编码似乎是错误的。在logstash日志文件中，我看到以下条目(我删除了消息)
2018-01-09T16:04:24,603logstash.codecs.plain收到了一个与您配置的字符编码不同的事件。{:text=>"0\x82\u0002B\u0002\u0001\u0001\u000...
浏览 7提问于2018-01-09得票数 0
回答已采纳
每次我启动logstash管道时，管道都会挂起，不会做任何事情，也不会超时或产生错误。就在它停下来之前就到了。主使用者clientId=logstash-0，将分区demotest2-0的groupId=logstash重置偏移量定位为FetchPosition{offset=0，offsetEpoch=Optional.empty我运行以下命令：
zookeeperkafka服务器(kafka_2.12-3.2.1)默认为0.0.0.0:9092(一个生产者)，在控制台中创建了一些消息
浏览 7提问于2022-08-17得票数 0
我已经设置了一个logstash管道，使用jdbc输入和elasticsearch输出监视logstash.conf的目录。我启用了.logstash_jdbc_test_last_run，它记录执行查询的时间：在命令行上运行logstash时，我的管道成功地处理了logstash文件：
[2019-08-23T15:26:48,168][INFO ][logstash.inpu
浏览 0提问于2019-08-23得票数 0
回答已采纳
1回答
由于这种设置，我们无法按照在存储日志的服务器上安装Filebeat的正常路线，将消息推送到logstash安装中。在这个服务器上有一些进程(Filebeat，logstash，另一个elasticsearch实例？)将这些信息保存在本地商店中
intranet中的另一个工具连接到DMZ工具，并提取所有收集的日志以供进一步处理。到目前为止，我们的研究只得到了将日志信息推送给logstash或elasticsearch的
浏览 1提问于2019-12-10得票数 2
回答已采纳
我想设计摄取管道，它将数据从雪花数据仓库中提取到elasticsearch服务中。我已经探索并发现了以下方法，请建议最好的方法来设计管道。还请向我指出任何可用的文档。设置日志存储服务器，在其中安装logstash服务。使用jdbc雪花插件定义一个将数据从雪花中提取到弹性服务中的管道，在弹性云中使用logstash管道。在摄入时通过rest触发管道。这个云管道设置似乎没有太多关于如何通过rest进行i
浏览 13提问于2022-04-01得票数 0
如何通过管道将文件的输出传递给Python中的变量？
有可能吗？假设通过管道将netstat的输出传递给Python语言中的变量x？
浏览 2提问于2010-07-01得票数 5
回答已采纳
它可以在每次启动容器时使用脚本来完成，该脚本将启动ES并执行对它的HTTP请求，但它看起来真的很难看。
浏览 3提问于2015-11-12得票数 4
我使用logstash、filebeat和grok将数据从日志发送到弹性搜索实例。这是管道中的grok配置。现在，我知道这些文件是在哪一年创建的，我想知道是否有可能在这个过程中为字段添加价值，也就是说，在发送到elasticsearch之前，以某种方式将Jan 15 11:18:25转换为2016 Jan 15
浏览 0提问于2018-01-24得票数 0
回答已采纳
1回答
我有一个Azure密钥库定义的秘密，我可以在devops管道使用"Azure KeyVault“任务访问。现在，我需要将秘密变量传递给python内联脚本。由于它是加密的，python不能直接读取值。我怎么能解密和传递它们。秘密保存Databricks访问令牌。我们正在尝试使用DevOps管道创建Databricks集群。我的Yaml有以下任务
带有参数的<e
浏览 5提问于2019-12-16得票数 0
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
