Send to logstash

elk_logger.py

# send a sample message to logstash

import socket
import json
import sys
import pdb

HOST = 'localhost'
PORT = 5000


def log_msg(message=''):
    """ Logs a message (python dict)
        Example: message = {'@message': 'python test message', '@tags': ['python', 'test']}
    """

    try:
        sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    except socket.error, message:
        sys.stderr.write("[ERROR] %s\n" % message[1])
        sys.exit(1)

    try:
        sock.connect((HOST, PORT))
    except socket.error, message:
        sys.stderr.write("[ERROR] %s\n" % message[1])
        sys.exit(2)

    sock.send(json.dumps(message))
    sock.close()
    #sys.exit(0)
    return "Logged Message"


if __name__ == '__main__':
    pass