filebeat每次重启时,如果registry没有删除,都会对registry里记录的每个文件,重新打开一个Harvester,即使文件没有更新过
1条回答 默认 最新
- 你知我知皆知 2024-08-10 14:31关注
以下回答参考 皆我百晓生、券券喵儿 等免费微信小程序相关内容作答,并由本人整理回复。
要解决这个问题,我们可以使用Go语言中的
time.Sleep
来控制Filebeat重启的速度。这样可以确保在重新启动前等待一段时间,以避免对Registry中所有文件的重新处理。以下是一个简单的示例:
package main import ( "fmt" "log" "github.com/elastic/filebeat/filebeat" ) func main() { // 获取当前时间点 now := filebeat.Now() // 指定重试次数和等待时间(单位:秒) retryCount := 5 sleepDuration := time.Second * 2 for i := 0; i < retryCount; i++ { if err := filebeat.Start(); err == nil { break } log.Printf("Filebeat is starting... (retry %d/%d)", i+1, retryCount) time.Sleep(sleepDuration) } fmt.Println("Filebeat has started successfully!") }
在这个例子中,我们首先获取了当前的时间戳,并设置了重试次数和等待时间。然后,我们进入了一个循环,每执行一次就检查Filebeat是否已经成功启动。如果Filebeat成功启动,则退出循环并打印一条消息;否则,我们将等待指定的睡眠时间后再次尝试启动Filebeat。
注意,这个解决方案假设你的Filebeat进程已经在运行并且有足够的时间来完成初始化。如果你的环境是多线程或者多进程的,你可能需要考虑使用更复杂的并发控制机制来防止多个实例同时启动Filebeat。
此外,这个解决方案并没有提供任何监控或错误处理的功能。在实际部署中,你应该添加适当的错误处理逻辑,以便在出现异常时能够正确地处理它们。
解决 无用评论 打赏 举报
悬赏问题
- ¥15 安装CentOS6时卡住
- ¥20 c语言写的8051单片机存储器mt29的模块程序
- ¥60 求直线方程 使平面上n个点在直线同侧并且距离总和最小
- ¥50 java算法,给定试题的难度数量(简单,普通,困难),和试题类型数量(单选,多选,判断),以及题库中各种类型的题有多少道,求能否随机抽题。
- ¥50 rk3588板端推理
- ¥250 opencv怎么去掉 数字0中间的斜杠。
- ¥15 这种情况的伯德图和奈奎斯特曲线怎么分析?
- ¥250 paddleocr带斜线的0很容易识别成9
- ¥15 电子档案元素采集(tiff及PDF扫描图片)
- ¥15 flink-sql-connector-rabbitmq使用