import socket import threading import json class Sock(threading.Thread): def __init__(self): super(Sock, self).__init__() self.running = False def run(self): self.INFOBEAMER_ADDR = ('127.0.0.1', 4444) self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1) self.running = True def send(self,obj): data = str.encode("eba/data:%s\n" % json.dumps(obj)) self.sock.sendto(data, self.INFOBEAMER_ADDR)