updated to run once an hour
This commit is contained in:
+6
-5
@@ -6,11 +6,12 @@ from dotenv import load_dotenv
|
|||||||
import logging
|
import logging
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
import time
|
import time
|
||||||
|
import os
|
||||||
|
|
||||||
def update():
|
def update():
|
||||||
topic = 'Odense'
|
topic = 'Odense'
|
||||||
# scrape latest data
|
# scrape latest data
|
||||||
username_list, timestamp_list, content_list = scrape(topic, limit=100, headless=False)
|
username_list, timestamp_list, content_list = scrape(topic, limit=10, headless=False)
|
||||||
# send data to database
|
# send data to database
|
||||||
insert_list(username_list, timestamp_list, content_list)
|
insert_list(username_list, timestamp_list, content_list)
|
||||||
|
|
||||||
@@ -20,18 +21,18 @@ if __name__ == '__main__':
|
|||||||
setup_logging()
|
setup_logging()
|
||||||
logging.info('finished setup')
|
logging.info('finished setup')
|
||||||
# main loop
|
# main loop
|
||||||
trigger_second = datetime.now().second
|
trigger_minute = datetime.now().minute
|
||||||
while True:
|
while True:
|
||||||
try:
|
try:
|
||||||
now = datetime.now()
|
now = datetime.now()
|
||||||
if now.second == trigger_second:
|
if now.minute == trigger_minute:
|
||||||
try:
|
try:
|
||||||
update
|
update()
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logging.warning(e)
|
logging.warning(e)
|
||||||
else:
|
else:
|
||||||
logging.info('finished cycle')
|
logging.info('finished cycle')
|
||||||
time.sleep(1)
|
time.sleep(60)
|
||||||
time.sleep(0.1)
|
time.sleep(0.1)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logging.critical(e)
|
logging.critical(e)
|
||||||
|
|||||||
Reference in New Issue
Block a user