cloud_functions_sync.py

def sync(event, context):
    """Sync PostgreSQL metadata with Google Data Catalog
    """

    try:
        # Log out the message that triggered the function
        logging.info('This Function was triggered by messageId {} published at {}'.
                     format(context.event_id, context.timestamp))

        logging.info('Starting sync logic.')
        datacatalog_cli.PostgreSQL2DatacatalogCli().run(_get_connector_run_args())
        logging.info('Sync execution done.')
        return 'ok', 200
    except PermissionError as err:
        logging.error('Error executing sync: %s', str(err))
        return 'authentication denied', 401
    except UserWarning as warn:
        logging.error('Error executing sync: %s', str(warn))
        return str(warn), 400
    except Exception as err:
        logging.error('Error executing sync: %s', str(err))
        return 'failed to sync', 500