Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import sys
- import logging
- import rds_config
- import pymysql
- #rds settings
- rds_host = rds_config.db_endpoint
- name = rds_config.db_username
- password = rds_config.db_password
- db_name = rds_config.db_name
- port = 3306
- logger = logging.getLogger()
- logger.setLevel(logging.INFO)
- try:
- logger.info("muestra esto")
- conn = pymysql.connect(rds_host, user=name, passwd=password, db=db_name, connect_timeout=120)
- except Exception as inst:
- logger.error("ERROR : ")
- logger.error(inst)
- sys.exit()
- logger.info("SUCCESS: Connection to RDS mysql instance succeeded")
- def handler(event, context):
- item_count = 0
- sql = """
- SELECT
- COUNT(sq.Usuario) CantidadUsuarios, sq.Cantidad as CantidadPreguntas
- FROM (
- SELECT COUNT(Id) as Cantidad, OwnerUserId as Usuario FROM Posts
- WHERE PostTypeId = 1
- GROUP BY OwnerUserId
- ORDER BY COUNT(*) DESC
- ) sq
- WHERE sq.Cantidad > 0
- GROUP BY sq.Cantidad
- HAVING COUNT(sq.Usuario) > 0
- """
- salida = "(Cantidad usuarios - Cantidad preguntas)"
- logger.info("Cantidad usuarios, Cantidad preguntas")
- with conn.cursor() as cur:
- cur.execute(sql)
- conn.commit()
- for row in cur:
- salida+=" "+str(row)
- logger.info(row)
- return salida
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement