from fluent import sender
from fluent import event
sender.setup("tag")
event.Event("label", data)
みたいにやってる記事が多かった。
違和感があったので実際に実装見てみるとグローバル変数使ってる!
(setupメソッドでglobal_senderというグローバル変数を利用 -> Eventのinitで_global_sender.emit_with_nameをよびtimestampに現在の時間を渡している)
というわけで
from fluent import sender
import time
send = sender.FluentSender("tag", host="localhost", port=24224)
send.emit_with_time("label", int(time.time()), data)
だと安心