CentOS如何自定義Filebeat的輸入插件

在CentOS上自定義Filebeat的輸入插件，可以按照以下步驟進行：

1. 安裝Filebeat

首先，確保你已經在CentOS上安裝了Filebeat。如果還沒有安裝，可以使用以下命令進行安裝：

sudo yum install filebeat

2. 創建自定義輸入插件

Filebeat的輸入插件通常是一個Go語言編寫的程序。你可以創建一個新的Go文件來編寫你的自定義輸入插件。

示例：創建一個簡單的自定義輸入插件

1. 創建一個新的Go文件：

   sudo vi /etc/filebeat/custom_input.go
   

2. 編寫自定義輸入插件的代碼： 以下是一個簡單的示例，展示如何創建一個自定義輸入插件，該插件會讀取指定目錄下的所有文件并將其發送到Elasticsearch。

   package main
   
   import (
       "bufio"
       "fmt"
       "log"
       "os"
       "path/filepath"
   
       "github.com/elastic/beats/v7/filebeat"
       "github.com/elastic/beats/v7/filebeat/input"
       "github.com/elastic/beats/v7/filebeat/publisher"
       "github.com/elastic/beats/v7/libbeat/common"
       "github.com/elastic/beats/v7/libbeat/logp"
   )
   
   const (
       Name = "custom_input"
   )
   
   type CustomInput struct {
       config input.Config
   }
   
   func New(b *common.BaseConfig) (input.Input, error) {
       var config CustomInput
       err := b.Unpack(&config)
       if err != nil {
           return nil, err
       }
       return &config, nil
   }
   
   func (c *CustomInput) Run(b publisher.EventPublisher) error {
       logp.Info("Starting custom input plugin")
   
       // 指定要監視的目錄
       dir := "/path/to/your/directory"
   
       files, err := os.Open(dir)
       if err != nil {
           return err
       }
       defer files.Close()
   
       scanner := bufio.NewScanner(files)
       for scanner.Scan() {
           line := scanner.Text()
           event := common.MapStr{
               "message": line,
           }
           if err := b.PublishEvent(event); err != nil {
               logp.Err("Failed to publish event: %v", err)
           }
       }
   
       if err := scanner.Err(); err != nil {
           return err
       }
   
       logp.Info("Custom input plugin stopped")
       return nil
   }
   
   func init() {
       input.Register(Name, New)
   }
   

3. 編譯自定義輸入插件： 使用go build命令編譯你的自定義輸入插件。

   go build -o /usr/share/filebeat/input/custom_input.so /etc/filebeat/custom_input.go
   

3. 配置Filebeat使用自定義輸入插件

編輯Filebeat的配置文件（通常是/etc/filebeat/filebeat.yml），添加你的自定義輸入插件。

filebeat.inputs:
- type: custom_input
  enabled: true

4. 重啟Filebeat

最后，重啟Filebeat服務以應用新的配置。

sudo systemctl restart filebeat

5. 驗證自定義輸入插件

你可以通過查看Filebeat的日志文件（通常是/var/log/filebeat/filebeat）來驗證自定義輸入插件是否正常工作。

sudo tail -f /var/log/filebeat/filebeat

通過以上步驟，你就可以在CentOS上成功自定義Filebeat的輸入插件了。