fluentdのexec_filter Output PluginでPythonプログラムを使う - Qiita

# coding=utf-8 """ fluentdのout_exec_filterで呼ばれるコード 標準入力から1行ずつ処理を行ない、結果を標準出力に吐く """ import json import logging import logging.config import sys import traceback import msgpack logging.config.fileConfig('/path/to/logging.conf') logger = logging.getLogger('fluent-exec') logger.propagate = False def main(): stdin = sys.stdin output(convert(validate(parse(readline(stdin))))) def readline(stdin): for li