mirror of
https://github.com/fhswf/aki_prj23_transparenzregister.git
synced 2025-04-22 16:12:55 +02:00
commit
dd511af3a5
@ -71,6 +71,8 @@ PYTHON_SQLITE_PATH=PathToSQLite3.db # An overwrite path to an sqllite db
|
||||
PYTHON_DASH_LOGIN_USERNAME=some-login-to-webgui
|
||||
PYTHON_DASH_LOGIN_PW=some-pw-to-login-to-webgui
|
||||
|
||||
PYTHON_INGEST_SCHEDULE=12 # Every x hours
|
||||
|
||||
CR=ghcr.io/fhswf/aki_prj23_transparenzregister
|
||||
TAG=latest
|
||||
|
||||
|
@ -12,6 +12,7 @@ services:
|
||||
PYTHON_MONGO_HOST: ${PYTHON_MONGO_HOST:-mongodb}
|
||||
PYTHON_MONGO_PORT: ${PYTHON_MONGO_PORT:-27017}
|
||||
PYTHON_MONGO_DATABASE: ${PYTHON_MONGO_DATABASE:-transparenzregister}
|
||||
PYTHON_INGEST_SCHEDULE: ${PYTHON_INGEST_SCHEDULE:-4}
|
||||
deploy:
|
||||
replicas: 1
|
||||
restart: on-failure:3
|
||||
@ -23,7 +24,6 @@ services:
|
||||
MONGO_INITDB_ROOT_USERNAME: ${PYTHON_MONGO_USERNAME:-root}
|
||||
MONGO_INITDB_ROOT_PASSWORD: ${PYTHON_MONGO_PASSWORD:?error}
|
||||
MONGO_INITDB_DATABASE: ${PYTHON_MONGO_DATABASE:-transparenzregister}
|
||||
TEST_ENV_VAR: Hello_World
|
||||
ports:
|
||||
- ${MONGO_EXTERNAL_PORT:-27018}:27017
|
||||
|
||||
|
@ -16,6 +16,7 @@ services:
|
||||
PYTHON_MONGO_HOST: ${PYTHON_MONGO_HOST:-mongodb}
|
||||
PYTHON_MONGO_PORT: ${PYTHON_MONGO_PORT:-27017}
|
||||
PYTHON_MONGO_DATABASE: ${PYTHON_MONGO_DATABASE:-transparenzregister}
|
||||
PYTHON_INGEST_SCHEDULE: ${PYTHON_INGEST_SCHEDULE:-4}
|
||||
|
||||
mongodb:
|
||||
image: mongo:4.4.6
|
||||
|
@ -1,5 +1,6 @@
|
||||
"""Scheduled news article extraction and transfer to MongoDB."""
|
||||
import argparse
|
||||
import os
|
||||
import sys
|
||||
import time
|
||||
|
||||
@ -45,7 +46,10 @@ def fetch_news_cli() -> None: # pragma: no cover
|
||||
configer_logger(namespace=parsed)
|
||||
config_provider = get_config_provider(parsed.config)
|
||||
|
||||
every(12).hours.do(schedule, config_provider)
|
||||
schedule = int(os.getenv("PYTHON_INGEST_SCHEDULE", "6"))
|
||||
|
||||
logger.info(f"Scheduled job will run every {schedule} hours")
|
||||
every(schedule).hours.do(schedule, config_provider)
|
||||
|
||||
while True:
|
||||
run_pending()
|
||||
|
Loading…
x
Reference in New Issue
Block a user