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 = "mysqlforlambdatest.cqg8l2snjl9h.us-east-1.rds.amazonaws.com"
- name = rds_config.db_username
- password = rds_config.db_password
- db_name = rds_config.db_name
- logger = logging.getLogger()
- logging.basicConfig()
- logger = logging.getLogger('logger')
- logger.warning('The system may break down')
- logger.setLevel(logging.INFO)
- try:
- conn = pymysql.connect(rds_host, user=name, passwd=password, db=db_name, connect_timeout=5)
- except:
- logger.error("ERROR: Unexpected error: Could not connect to MySql instance.")
- sys.exit()
- logger.info("SUCCESS: Connection to RDS mysql instance succeeded")
- def handler(event, context):
- """
- This function fetches content from mysql RDS instance
- """
- item_count = 0
- with conn.cursor() as cur:
- cur.execute("create table Employee3 ( EmpID int NOT NULL, Name varchar(255) NOT NULL, PRIMARY KEY (EmpID))")
- cur.execute('insert into Employee3 (EmpID, Name) values(1, "Joe")')
- cur.execute('insert into Employee3 (EmpID, Name) values(2, "Bob")')
- cur.execute('insert into Employee3 (EmpID, Name) values(3, "Mary")')
- conn.commit()
- cur.execute("select * from Employee3")
- for row in cur:
- item_count += 1
- logger.info(row)
- #print(row)
- conn.commit()
- return "Added %d items from RDS MySQL table" %(item_count)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement