context_5.py 556 B

12345678910111213141516171819202122232425
  1. import os
  2. import contextlib
  3. # import mysql.connector
  4. @contextlib.contextmanager
  5. def get_mysql_conn(db):
  6. """
  7. Context manager to automatically close DB connection.
  8. We retrieve credenrials from Enviroment variables
  9. """
  10. conn = mysql.connector.connect(host = os.environ.get('MYSQL_HOST'),
  11. user=os.environ.get('MYSQL_USER'), password=os.environ.get('MYSQL_PWD'),
  12. database=db)
  13. try:
  14. yield conn
  15. finally:
  16. conn.close()
  17. def main():
  18. pass
  19. if __name__ == '__main__':
  20. main()