jinseopim

import cx_Oracle
import pandas

connection = cx_Oracle.connect('username/pwd@host:port/dbname')

def read_query(connection, query):
    cursor = connection.cursor()
    try:
        cursor.execute( query )
        names = [ x[0] for x in cursor.description]

jinseopim

#http://pastebin.com/xGt6vv9R from yardenbar
output {
    if [type] == "postfix" {
        elasticsearch {
            host     => [ "ES_HOSTNAME" ]
            protocol => "transport"
            cluster  => "elasticsearch"
            index    => "postfix-%{+YYYY.MM.dd}"
            manage_template => true
            template_overwrite => true