from fluent import sender
from fluent import event
sender.setup("tag")
event.Event("label", data)
Es gab viele Artikel, die so machten. Ich fühlte mich unwohl, also habe ich beim Betrachten der Implementierung globale Variablen verwendet! (Verwenden Sie eine globale Variable namens _global_sender in der Setup-Methode-> event init, um global_sender.emit_with_name aufzurufen und die aktuelle Zeit an den Zeitstempel zu übergeben.)
damit
from fluent import sender
import time
send = sender.FluentSender("tag", host="localhost", port=24224)
send.emit_with_time("label", int(time.time()), data)
Es ist sicher
Recommended Posts