input先をpythonとした場合の手順を確認します。

[root@node01 ~]# python -V
Python 3.5.0

pythonは今日時点の最新バージョンを利用しています。

[root@node01 Python-3.5.0]# vi /etc/td-agent/td-agent.conf
・
・
・
<source>
        type forward
        port 24225
</source>
<match fluentd.test.**>
        type stdout
</match>

設定ファイル(td-agent.conf)を編集して24225番ポートで待ち受けるようにします。

[root@node01 Python-3.5.0]# service td-agent restart
Shutting down td-agent:                                    [  OK  ]
Starting td-agent:                                         [  OK  ]
[root@node01 Python-3.5.0]# service td-agent status
td-agent (pid  10000) を実行中...

設定ファイルの編集後、サービスを再起動します。

[root@node01 Python-3.5.0]# pip install fluent-logger
Collecting fluent-logger
  Downloading fluent-logger-0.4.0.tar.gz
Collecting msgpack-python (from fluent-logger)
  Downloading msgpack-python-0.4.6.tar.gz (116kB)
    100% |????????????????????????????????| 118kB 425kB/s
Installing collected packages: msgpack-python, fluent-logger
  Running setup.py install for msgpack-python
  Running setup.py install for fluent-logger
Successfully installed fluent-logger-0.4.0 msgpack-python-0.4.6

python用fluentプラグインをpipコマンドを利用してインストールします。

[root@node01 ~]# vi test.py
from fluent import sender
from fluent import event
sender.setup('fluentd.test', host='localhost', port=24225)
event.Event('follow', {
        'from': 'userA',
        'to':   'userB'
})

fluent-loggerを利用してfluentdにログをフォワードするpythonプログラムを作成します。

[root@node01 ~]# python test.py
[root@node01 ~]# less /var/log/td-agent/td-agent.log
・
・
・
2015-10-28 00:35:49 +0900 fluentd.test.follow: {"to":"userB","from":"userA"}

実行し、ログが出力されたことを確認しました。