tools/athena/loadtoathena.py
def create_athena_view(params: dict, field_info: dict, formulas: dict) -> None:
    """
    Creates the view in Athena if it doesn't exists
    """

    logger.info('creating view: "%s"."%s"',
                params["db_name"], params["view_name"])
    query_exec_context = {
        "Database": params["db_name"],
        "Catalog": params["catalog_name"],
    }

    execute_query(
        params["dryrun"],
        params["out_bucket_region"],
        construct_aggregated_query(params, field_info, formulas),
        params["rslt_config"],
        query_exec_context,
    )

    Creates the view in Athena if it doesn't exists
    
Creates the view in Athena if it doesn't exists
Creates the view in Athena if it doesn ' t exists
def create_athena_view(params: dict, field_info: dict, formulas: dict) -> None:
    logger.info('creating view: "%s"."%s"',
                params["db_name"], params["view_name"])
    query_exec_context = {
        "Database": params["db_name"],
        "Catalog": params["catalog_name"],
    }
    execute_query(
        params["dryrun"],
        params["out_bucket_region"],
        construct_aggregated_query(params, field_info, formulas),
        params["rslt_config"],
        query_exec_context,
    )
def create_athena_view ( params : dict , field_info : dict , formulas : dict ) -> None : logger . info ( 'creating view: "%s"."%s"' , params [ "db_name" ] , params [ "view_name" ] ) query_exec_context = { "Database" : params [ "db_name" ] , "Catalog" : params [ "catalog_name" ] , } execute_query ( params [ "dryrun" ] , params [ "out_bucket_region" ] , construct_aggregated_query ( params , field_info , formulas ) , params [ "rslt_config" ] , query_exec_context , )
Creates the view in Athena if it doesn't exists
Creates the view in Athena if it doesn ' t exists
"""
    Creates the view in Athena if it doesn't exists
    """
params
dict
field_info
dict
formulas
dict