tools/athena/loadtoathena.py
def create_athena_table(params: dict, field_info: dict) -> None:
    """
    Creates the table if it doesn't exist in Athena
    """

    logger.info("creating table: `%s`.`%s`",
                params["db_name"], params["table_name"])
    query_exec_context = {
        "Database": params["db_name"],
        "Catalog": params["catalog_name"],
    }

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

    Creates the table if it doesn't exist in Athena
    
Creates the table if it doesn't exist in Athena
Creates the table if it doesn ' t exist in Athena
def create_athena_table(params: dict, field_info: dict) -> None:
    logger.info("creating table: `%s`.`%s`",
                params["db_name"], params["table_name"])
    query_exec_context = {
        "Database": params["db_name"],
        "Catalog": params["catalog_name"],
    }
    execute_query(
        params["dryrun"],
        params["out_bucket_region"],
        construct_query(params, field_info),
        params["rslt_config"],
        query_exec_context,
    )
def create_athena_table ( params : dict , field_info : dict ) -> None : logger . info ( "creating table: `%s`.`%s`" , params [ "db_name" ] , params [ "table_name" ] ) query_exec_context = { "Database" : params [ "db_name" ] , "Catalog" : params [ "catalog_name" ] , } execute_query ( params [ "dryrun" ] , params [ "out_bucket_region" ] , construct_query ( params , field_info ) , params [ "rslt_config" ] , query_exec_context , )
Creates the table if it doesn't exist in Athena
Creates the table if it doesn ' t exist in Athena
"""
    Creates the table if it doesn't exist in Athena
    """
params
dict
field_info
dict