Fluentdで自作プラグインを作ってLabelを変更したい

Question

Fluentdで以下のように動作するモノを作成したいです。

---

ログをtailで読み込み
↓
copy　→→→　原本をOnline上にバックアップ（外部プラグイン利用）
↓
中身を解析・整形して種類分け…★
↓
種類ごとにDBなどに振り分けて保存（外部プラグイン利用）

★の部分は自作のFilterプラグインを作成しています。

---

自作のプラグインで内容に応じてlabelを付け替えてあげ、
後ろに控えたlabelディレクティブのなかでプラグインを用いて各所に保存すれば行けそうだと思い以下のようなconfを組みました。

<source>
  @type tail
  path /var/log/mylog
  pos_file /var/log/td-agent/mylog.pos
  tag mylog
  format none
</source>

<match mylog>
  @type copy
  <store>
    #外部バックアップ用プラグイン
    @type online_bk
  </store>

  <store>
    @type relabel
    @label edit
  </store>
</match>

<label edit>
  <filter>
    #種類分割・整形用自作プラグイン
	#labelにtype_a type_bとつける
    @type myplugin
  </filter>
</label>

<label type_a>
  <match>
    @type bk_a
  </match>
</label>

<label type_b>
  <match>
    @type bk_b
  </match>
</label>

上記のような構造で動きそうでしょうか。

また、自作プラグイン(ruby)でlabelを付け替える方法がわかりません。
付け替えることは可能でしょうか。
可能な場合、どのようなコードを組めばlabelを付け替えられるでしょうか。

何かアイディアなどが有れば合わせていただけますと幸いです。

Answer 1

filter プラグインでラベルを書き換えるのはおすすめしません。
一応、できなくはありませんが、新しいイベントを作って emit しないといけないので filter にする意味がなくなります。

output プラグインだとたぶん以下のようにすれば動きます。
ただし、出力先の <label> は設定ファイルに全て列挙してある必要があります。

class OutSuperRelabel < Fluent::Plugin::Output
  def process(tag, es)
    es.each do |time, record|
      label = find_label_from_record(record)
      event_router = event_emitter_router(label)
      event_router.emit(tag, time, record)
    end
  end

  def find_label_from_record(record)
    # ラベルを見つけるためのコード
  end
end

最終的にfilterプラグインでレコードを加工してoutputプラグインでレコードの内容を見て好きなラベルに飛ばす、という感じになると思います。