gistfile1.txt

#!/usr/bin/env python
from logentries import LogentriesHandler
import pymysql
import os
import logging
from ManageCluster import ManageAuroraCluster as mc




def handler(event, context):
    hostsandentries = {}
    mysqluser     = os.environ['MYSQLUSER']
    mysqlpassword = os.environ['MYSQLPASSWORD']
    log = logging.getLogger('logentries')
    log.setLevel(logging.INFO)
    log.addHandler(LogentriesHandler(os.environ['LOGENTRIES']))
    prodclusters = mc.getClustersByTag(mc.getClusters(), "realm", os.environ['REALM'])
    prodnodes = []
    for cluster in prodclusters:
        nodes = mc.getClusterNodes(cluster)
        for node in nodes:
            prodnodes.append(mc.getInstanceAddress(node))
    lognodes = []
    for node in prodnodes:
        db = pymysql.connect(node, user=mysqluser, passwd=mysqlpassword, db='mysql', connect_timeout=5)
        cursor = db.cursor()
        cursor.execute("SELECT COUNT(*) FROM slow_log")
        for row in cursor.fetchone():
            if row > 0:
                hostsandentries[node]=row
                cursor.callproc('mysql.rds_rotate_slow_log')
                cursor.execute("SELECT * FROM slow_log_backup")
                for row in cursor.fetchall():
                    resultstring = "\n  Start time: %s \n  User and host: %s\n  Query Time:%s\n  Lock time:%s\n  Rows sent:%s\n  Rows examined: %s\n  Database: %s\n  Last insert id: %s\n  Insert id: %s\n  Server id:%s\n  SQL text: %s\n  Thread id: %s" % (row[0], row[1], row[2], row[3], row[4], row[5], row[6], row[7], row[8], row[9], row[10], row[11])
                    log.info(resultstring)
    return hostsandentries