send_message_to_logstash.py

import socket
import json
import sys

HOST = '0.0.0.0'
PORT = 9201

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

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

msg = {'@message': 'python test message', '@tags': ['test']}

sock.send(json.dumps(msg) + '\n')

sock.close()
sys.exit(0)