# -*- coding: utf-8 -*- import sys import json import pdb from fluent import sender from datetime import datetime # vars send_tag = 'okuritai.tagdesu' label = '' extz = '+00:00' # logger init logger = sender.FluentSender(send_tag, host='localhost', port=24224) #logger = sender.FluentSender(send_tag, host='unix:///path/to/td-agent.sock') def parse(line): dt, tag, message = line.split("\t") dt = dat