aboutsummaryrefslogtreecommitdiff
path: root/data_collector.py
blob: 485d8af81fb052f1ec82b7f2fe23b62d3c25255c (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
#!/usr/bin/env python

from time import sleep
from datetime import datetime, timedelta, UTC
from components.database import subscriptions
from components.subscriptions.main import Subscription

while True:
    for sub_dict in subscriptions.find():
        sub = Subscription(**sub_dict)
        if datetime.now(tz=UTC) - sub.last_fetch > timedelta(seconds=sub.time_between_fetches):
            sub.fetch()
    sleep(60)