Process data

def process_data(data, interval, from_date, to_date, week_day=0, fill_zero=False, order=None):
    # FIXME: Currently influxdb group by time and fill zero not correct.
    # @see: https://github.com/influxdb/influxdb/issues/1229
    # @see: https://github.com/influxdb/influxdb/issues/1190
    import bisect
    from dateutil import rrule
    from collections import Counter
    from datetime import datetime

    from_date = from_date.replace(tzinfo=None)
    to_date = to_date.replace(tzinfo=None)

    if interval == 'day':
        grid = list(rrule.rrule(rrule.DAILY, dtstart=from_date, until=to_date))
    elif interval == 'week':
        grid = list(rrule.rrule(rrule.WEEKLY, dtstart=from_date, until=to_date, byweekday=week_day))
    elif interval == 'month':
        month_day = 1 if from_date.day == 1 else -1
        grid = list(rrule.rrule(rrule.MONTHLY, dtstart=from_date, until=to_date, bymonthday=month_day))
    else:
        return []

    if to_date not in grid:
        grid = grid + [to_date]

    cnt = Counter()
    for d in data:
        idx = bisect.bisect(grid, datetime.fromtimestamp(d[0]))
        idx = idx-1 if idx > 0 else 0
        # print d[0], datetime.fromtimestamp(d[0]), idx, grid[idx]
        cnt[grid[idx]] += 1
        # cnt[grid[idx]] += d[1]
    rs = dict(cnt)
    if fill_zero:
        for d in grid[:-1]:
            if d not in rs:
                rs[d] = 0
    rs = rs.items()
    if order == 'asc':
        rs = sorted(rs, key=lambda x: x[0])
    elif order == 'desc':
        rs = sorted(rs, key=lambda x: x[0], reverse=True)
    return rs