概要

fluentdのpluginを作成する際に、v0.14.13からfluent-plugin-generateコマンドが利用できるようになった。（ちなみにv0.14の次はv1.0になっている。）　今回は、このコマンドを利用して、pluginを作成して、ローカルでテストできる環境を作ってみた。

事前準備

gem最新化, bundler / fluentd / test-unitのインストールを実施する。(fluentdのテストコードはtest-unitを利用している)

$ gem update --system
$ gem install bundler
$ gem install fluentd
$ fluentd --version
fluentd 1.1.0
$ gem install test-unit

plugin作成

generate コマンド実行

このコマンドを実行すると、plugin用のプロジェクトフォルダを作成してくれる。めっちゃ便利。
試しに、下記ではfilterプラグインを作成するコマンドを実行。

$ fluent-plugin-generate filter hogehoge
License: Apache-2.0
	create Gemfile
	create README.md
	create Rakefile
	create fluent-plugin-onekeyparse.gemspec
	create lib/fluent/plugin/filter_hogehoge.rb
	create test/helper.rb
	create test/plugin/test_filter_hogehoge.rb
Initialized empty Git repository in /xxxx/fluent-plugin-hogehoge/.git/

動作確認

fluentd.conf作成
filterの@typeに今回作成するpluginのhogehogeを設定

<source>
  @type forward
</source>

<filter **>
  @type hogehoge
</filter>

<match **>
  @type stdout
</match>

fluentd起動

$ fluentd -c fluent.conf -p lib/fluent/plugin

ログ送信

$ echo '{"a":"foo","b":"bar"}' | fluent-cat raw.test

テスト

$ rake test
Finished in 0.004382 seconds.
・・・

---------------------------------------------------------------------------------------------------------------------------------------------
1 tests, 1 assertions, 1 failures, 0 errors, 0 pendings, 0 omissions, 0 notifications
0% passed
---------------------------------------------------------------------------------------------------------------------------------------------
228.21 tests/s, 228.21 assertions/s

//テストが失敗すればOK。 コードを実装してテストが通るようにする。

まとめ

自分でpluginを書くのはハードル高そうですが、このgeneratorがあれば、なんとなく作れそうな気になってきますよね。私もチャレンジしてみたいと思います。plugin周りについては、2016年のFluentd meetupで統一されてないplugin開発を整理するという話があり、実際に実現されて嬉しい限りです。
以下参考サイトです。