exec_filter Output Plugin (out_ecec_filter)は要するにフィルタ処理を任意のプログラムを使ってかませられる。例えば次の処理に不要なレコードを落したり、エラーとしてどこかに保存したり。ここでPythonプログラムを使ってみる。 設定 次の通りにしてみた。 <match hoge> type exec_filter command /path/to/python -m myapp.fluent_stream_filter time_key time in_format json out_format msgpack buffer_type file buffer_path /path/to/buffer buffer_chunk_limit 8m buffer_queue_limit 64 flush_interval 10s tag fuga </ma