Spaces:
Sleeping
Sleeping
Update scheduler.py
Browse files- scheduler.py +14 -0
scheduler.py
CHANGED
|
@@ -1 +1,15 @@
|
|
| 1 |
# Scheduler to auto-run data fetch every 24 hrs
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1 |
# Scheduler to auto-run data fetch every 24 hrs
|
| 2 |
+
from apscheduler.schedulers.background import BackgroundScheduler
|
| 3 |
+
from trends_fetcher import fetch_world_trends
|
| 4 |
+
from db import insert_trends
|
| 5 |
+
|
| 6 |
+
def scheduled_job():
|
| 7 |
+
data = fetch_world_trends()
|
| 8 |
+
insert_trends(data)
|
| 9 |
+
print("[Scheduler] Fetched and inserted new trends")
|
| 10 |
+
|
| 11 |
+
|
| 12 |
+
def schedule_daily_run():
|
| 13 |
+
scheduler = BackgroundScheduler()
|
| 14 |
+
scheduler.add_job(scheduled_job, 'interval', hours=24)
|
| 15 |
+
scheduler.start()
|