tcp_rvice_syslog-ng.py

tcp server listen syslog-ng port

import os
import sys
import SocketServer
import threading

class ThreadedEchoRequestHandler(SocketServer.StreamRequestHandler):

    def handle(self):
        self.data = self.rfile.readline().strip()
        print self.data
        return


class ThreadedEchoServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
    pass

if __name__ == "__main__":
    host,port="0.0.0.0",5144
    HOST,PORT = host,port
    server = ThreadedEchoServer((host,port), ThreadedEchoRequestHandler) 
    #server = SocketServer.TCPServer((HOST, PORT), ThreadedEchoRequestHandler)
    server.serve_forever()