def get_sql_statement()

in assets/functions/redshift/consumption/app.py [0:0]

• 7 lines of code
• 4 McCabe index (conditional complexity)

def get_sql_statement(requested_aggregation):
    if requested_aggregation == "weekly":
        return """
                select meter_id, year, week_of_year, sum(reading_value) 
                    from daily 
                    where meter_id=%s AND year=%s 
                    group by week_of_year, year, meter_id 
                    order by week_of_year
                """
    elif requested_aggregation == "monthly":
        return """select meter_id, year, month, sum(reading_value) 
                        from daily 
                        where meter_id=%s AND year=%s 
                        group by year, month, meter_id 
                        order by month
            """
    else:
        # make daily the default, or raise an exception
        return "select meter_id, date_str, sum(reading_value) from daily where meter_id=%s AND year=%s group by date_str, meter_id"