Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import boto3
- import psycopg2
- import os
- ssm = boto3.client('ssm',region_name='eu-central-1')
- db_password_parameter = ssm.get_parameter(Name=f"/ENV/PROJECT/main/db_master_password", WithDecryption=True)
- db_url_parameter = ssm.get_parameter(Name=f"/ENV/PROJECT/main/db_url", WithDecryption=True)
- db_password = db_password_parameter['Parameter']['Value']
- db_url = db_url_parameter['Parameter']['Value']
- conn = psycopg2.connect(dbname="postgres", user="USER", password=db_password, host=db_url)
- cur = conn.cursor()
- cur.execute("SELECT datname FROM pg_database;")
- print(cur.fetchall())
- conn.set_isolation_level(0)
- try:
- cur.execute("drop DATABASE PROJECT;")
- except:
- print('problem create')
- try:
- cur.execute("CREATE DATABASE PROJECT;")
- except:
- print('problem drop')
Add Comment
Please, Sign In to add comment