def create_message(payload, event_status, environment):
    """
    Parameters
    ----------
    payload: dict
        Status -- str in {New Data Loaded, Daily Data Updated}
        New Records -- int, number of new records added since previous run
        Updated Records -- int, number of updated records from this new run
    
    event_status: str in {Success, Failure} based on source lambda invocation

    environment: str in {production, testing}

    Returns
    ------
    message: str, message that is published to SNS topic

    subject: str, Subject line for SNS topic email subscribers
    """
    
    if event_status == 'Success':
        message = f"Environment: {environment}\n{payload['Status']}\nNumber of New Records: {payload['New Records']}\nNumber of Updated Records: {payload['Updated Records']}"
        subject = "COVID-19 ETL Process Successful, Data Updated"
    else:
        message = "An error occured in the COVID-19 ETL Process"
        subject = "COVID-19 ETL Process Unsuccessful"

    return message, subject