+def estimate_swimmer_count(date):
+ return date.day
+
+
+def select_swimmerdata(begin, end):
+ def report_times(begin, end):
+ d = begin
+ while d < end:
+ for t in [10, 15]:
+ a = datetime.datetime.combine(d.date(), datetime.time(t))
+ if a >= d:
+ yield a
+ d += datetime.timedelta(days=1)
+ SwimmerData = collections.namedtuple('SwimmerData', ['datetime', 'count'])
+ for d in report_times(begin, end):
+ count = estimate_swimmer_count(d)
+ yield SwimmerData(d, count)
+
+
+def swimmerdata_to_xy(swimmerdata):
+ swimmerdata = list(swimmerdata)
+ x = np.array([d.datetime for d in swimmerdata])
+ y = np.array([d.count for d in swimmerdata])
+ return x, y
+
+