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-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
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 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()
|
||||||
Loading…
Reference in New Issue
Block a user