Initial commit
This commit is contained in:
34
birb_scheduler/config.py
Normal file
34
birb_scheduler/config.py
Normal file
@ -0,0 +1,34 @@
|
||||
import os
|
||||
import sys
|
||||
from dataclasses import dataclass
|
||||
from typing import List
|
||||
|
||||
|
||||
@dataclass
|
||||
class SiteDescription:
|
||||
name: str
|
||||
baseurl: str
|
||||
|
||||
|
||||
def parse_site_list(raw_site_list: str) -> List[SiteDescription]:
|
||||
parsed_sites = []
|
||||
for pair in raw_site_list.split(' '):
|
||||
name, baseurl = pair.split(';', 1)
|
||||
parsed_sites.append(
|
||||
SiteDescription(
|
||||
name=name,
|
||||
baseurl=baseurl
|
||||
)
|
||||
)
|
||||
return parsed_sites
|
||||
|
||||
|
||||
class Config:
|
||||
INTERVAL = int(os.environ.get("INTERVAL", 30))
|
||||
SITE_LIST = parse_site_list(os.environ.get("SITES"))
|
||||
|
||||
SENTRY_DSN = os.environ.get("SENTRY_DSN")
|
||||
|
||||
RELEASE_ID = os.environ.get("RELEASE_ID", "test")
|
||||
RELEASEMODE = os.environ.get("RELEASEMODE", "dev")
|
||||
DEBUG = ('--debug' in sys.argv) or bool(os.environ.get("DEBUG", "").upper() in ['YES', 'TRUE', '1'])
|
45
birb_scheduler/main.py
Normal file
45
birb_scheduler/main.py
Normal file
@ -0,0 +1,45 @@
|
||||
#!/usr/bin/env pyton3
|
||||
import logging
|
||||
import sys
|
||||
|
||||
import sentry_sdk
|
||||
from sentry_sdk.integrations.logging import LoggingIntegration
|
||||
|
||||
from config import Config
|
||||
from apscheduler.schedulers.blocking import BlockingScheduler
|
||||
|
||||
|
||||
def run():
|
||||
logging.info("Csirip")
|
||||
|
||||
|
||||
def main():
|
||||
sentry_logging = LoggingIntegration(
|
||||
level=logging.INFO,
|
||||
event_level=logging.ERROR
|
||||
)
|
||||
|
||||
if Config.SENTRY_DSN:
|
||||
sentry_sdk.init(
|
||||
dsn=Config.SENTRY_DSN,
|
||||
integrations=[sentry_logging],
|
||||
traces_sample_rate=0.0,
|
||||
send_default_pii=True,
|
||||
release=Config.RELEASE_ID,
|
||||
environment=Config.RELEASEMODE,
|
||||
_experiments={"auto_enabling_integrations": True}
|
||||
)
|
||||
|
||||
logging.basicConfig(
|
||||
stream=sys.stdout,
|
||||
format="%(asctime)s - %(name)s [%(levelname)s]: %(message)s",
|
||||
level=logging.DEBUG if Config.DEBUG else logging.INFO
|
||||
)
|
||||
|
||||
scheduler = BlockingScheduler()
|
||||
scheduler.add_job(run, trigger='interval', seconds=Config.INTERVAL)
|
||||
scheduler.start()
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
main()
|
Reference in New Issue
Block a user