Compare commits
2 Commits
f5ccbde002
...
bb9d75a26d
| Author | SHA1 | Date | |
|---|---|---|---|
| bb9d75a26d | |||
|
|
89379eca72 |
1110
openapi.json
1110
openapi.json
File diff suppressed because it is too large
Load Diff
@ -19,3 +19,13 @@ dependencies = [
|
||||
"opentelemetry-exporter-otlp>=1.27.0",
|
||||
"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
1
src/__init__.py
Normal file
@ -0,0 +1 @@
|
||||
"""Schiphol flight data producer."""
|
||||
@ -1,4 +1,4 @@
|
||||
from settings import SchipholApiSettings, KafkaSettings
|
||||
from src.settings import SchipholApiSettings, KafkaSettings
|
||||
from requests_ratelimiter import LimiterSession
|
||||
from kstreams import create_engine
|
||||
from kstreams.backends.kafka import Kafka
|
||||
@ -91,6 +91,10 @@ async def shutdown(loop):
|
||||
logger.info("Shutdown")
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
def main():
|
||||
logging.basicConfig(level=logging.INFO)
|
||||
aiorun.run(start(), stop_on_unhandled_errors=True, shutdown_callback=shutdown)
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
main()
|
||||
Loading…
Reference in New Issue
Block a user