parse-postgresql-logs.py

"""Simple script to read stdin postgresql csv logs and output the SQL statements

To use, do something like this:

  tail -f /path/to/your/postgres.log | python -u parse-postgresql-logs.py

"""
import csv
import sys

from functools import partial


try:
    import sqlparse
    formatter = partial(sqlparse.format, reindent=True)
except ImportError:
    formatter = lambda l: l


reader = csv.reader(iter(sys.stdin.readline, ''))
for row in reader:
    try:
        print formatter(row[13])
    except IndexError:
        print row
    print