in lib/glue_scripts/etl_raw_to_conformed.py [0:0]
def create_database():
"""
Function to create catalog database if does not exists
@return:
"""
response = None
glue_client = boto3.client('glue')
database_name = args['target_databasename']
try:
# global response
response = glue_client.get_database(
Name=database_name
)
print(response)
except botocore.exceptions.ClientError as error:
if error.response['Error']['Code'] == 'EntityNotFoundException':
print('The requested database: {0} was not found.'.format(database_name))
else:
print('Error Message: {}'.format(error.response['Error']['Message']))
if response is None:
print('I am going to create a database')
response = glue_client.create_database(
DatabaseInput={
'Name': database_name
}
)
print('create_database_response: ', response)