Compare commits

...

2 Commits

Author SHA1 Message Date
bb9d75a26d Merge pull request 'OPT project structure' (#2) from opt/project_structure into main
All checks were successful
SonarQube Scan / sonarqube (push) Successful in 49s
Reviewed-on: #2
2025-12-29 16:57:33 +01:00
Peter
89379eca72 OPT project structure
All checks were successful
SonarQube Scan / sonarqube (pull_request) Successful in 48s
2025-12-29 16:48:38 +01:00
8 changed files with 17 additions and 1112 deletions

File diff suppressed because it is too large Load Diff

View File

@ -19,3 +19,13 @@ dependencies = [
"opentelemetry-exporter-otlp>=1.27.0", "opentelemetry-exporter-otlp>=1.27.0",
"opentelemetry-instrumentation-requests>=0.48b0", "opentelemetry-instrumentation-requests>=0.48b0",
] ]
[project.scripts]
schiphol = "src.main:main"
[build-system]
requires = ["setuptools>=61.0"]
build-backend = "setuptools.build_meta"
[tool.setuptools]
packages = ["src"]

1
src/__init__.py Normal file
View File

@ -0,0 +1 @@
"""Schiphol flight data producer."""

View File

@ -1,4 +1,4 @@
from settings import SchipholApiSettings, KafkaSettings from src.settings import SchipholApiSettings, KafkaSettings
from requests_ratelimiter import LimiterSession from requests_ratelimiter import LimiterSession
from kstreams import create_engine from kstreams import create_engine
from kstreams.backends.kafka import Kafka from kstreams.backends.kafka import Kafka
@ -91,6 +91,10 @@ async def shutdown(loop):
logger.info("Shutdown") logger.info("Shutdown")
if __name__ == "__main__": def main():
logging.basicConfig(level=logging.INFO) logging.basicConfig(level=logging.INFO)
aiorun.run(start(), stop_on_unhandled_errors=True, shutdown_callback=shutdown) aiorun.run(start(), stop_on_unhandled_errors=True, shutdown_callback=shutdown)
if __name__ == "__main__":
main()