Advertisement
Guest User

RQ1

a guest
Jan 19th, 2018
78
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 1.36 KB | None | 0 0
  1. import sys
  2. import logging
  3. import rds_config
  4. import pymysql
  5. #rds settings
  6. rds_host  = rds_config.db_endpoint
  7. name = rds_config.db_username
  8. password = rds_config.db_password
  9. db_name = rds_config.db_name
  10. port = 3306
  11.  
  12. logger = logging.getLogger()
  13. logger.setLevel(logging.INFO)
  14.  
  15. try:
  16.     logger.info("muestra esto")
  17.     conn = pymysql.connect(rds_host, user=name, passwd=password, db=db_name, connect_timeout=120)
  18. except Exception as inst:
  19.     logger.error("ERROR : ")
  20.     logger.error(inst)
  21.     sys.exit()
  22.  
  23. logger.info("SUCCESS: Connection to RDS mysql instance succeeded")
  24.  
  25. def handler(event, context):
  26.     item_count = 0
  27.     sql = """
  28.        SELECT
  29.            COUNT(sq.Usuario) CantidadUsuarios, sq.Cantidad as CantidadPreguntas
  30.        FROM (
  31.            SELECT COUNT(Id) as Cantidad, OwnerUserId as Usuario FROM Posts
  32.            WHERE PostTypeId = 1
  33.            GROUP BY OwnerUserId
  34.            ORDER BY COUNT(*) DESC
  35.        ) sq
  36.        WHERE sq.Cantidad > 0
  37.        GROUP BY sq.Cantidad
  38.        HAVING COUNT(sq.Usuario) > 0
  39.        """
  40.     salida = "(Cantidad usuarios - Cantidad preguntas)"
  41.     logger.info("Cantidad usuarios, Cantidad preguntas")
  42.     with conn.cursor() as cur:
  43.         cur.execute(sql)  
  44.         conn.commit()
  45.         for row in cur:
  46.             salida+=" "+str(row)
  47.             logger.info(row)
  48.     return salida
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement