Ich habe ein Problem mit meinem Programm: Es wird beim Systemstart (Runlevel 2, Raspberry pi) gesstartet und soll Daten an Logstash schicken. Ich habe 2 Funktionen: Logstash_send_int und logstash_send_ups. (Daten einer USV) Beide Funktionen machen im Prinzip das selbe:
Code: Alles auswählen
def logstash_send_int(self, key, value): #Wert (Zahl) an Logstash senden
protocol = socket.SOCK_STREAM #TCP als Standart
if Logstash_PROTOCOL == "udp":
protocol = socket.SOCK_DGRAM #Protokoll nach upd ändern
s = socket.socket(socket.AF_INET, protocol)
s.connect((Logstash_IP, int(Logstash_PORT))) #Verbinden
s.send("{ \"" + key + "\": " + str(value) + "}\n")
s.close()
def logstash_send_ups(self, nr, values): #json-string mit den USV-Daten senden
protocol = socket.SOCK_STREAM #TCP als Standart
if Logstash_PROTOCOL == "udp":
protocol = socket.SOCK_DGRAM
s = socket.socket(socket.AF_INET, protocol)
s.connect((Logstash_IP, int(Logstash_PORT)))
ret = "{\"ups" + str(nr) + "\": {"
ret += ".."
s.send(ret) #senden
s.close()
Kann mit jemand weiterhelfen??
Finn