From 4fff22e17cb915f637e96a51ddd8f7fd569eed07 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Alex=20Gr=C3=B6nholm?= Date: Wed, 7 Sep 2022 17:19:09 +0300 Subject: Fixed examples not using shared data stores/event brokers --- examples/web/asgi_fastapi.py | 2 +- examples/web/asgi_starlette.py | 2 +- examples/web/wsgi_flask.py | 2 +- examples/web/wsgi_noframework.py | 6 ++++-- 4 files changed, 7 insertions(+), 5 deletions(-) (limited to 'examples') diff --git a/examples/web/asgi_fastapi.py b/examples/web/asgi_fastapi.py index ffa79cb..4a3872d 100644 --- a/examples/web/asgi_fastapi.py +++ b/examples/web/asgi_fastapi.py @@ -58,7 +58,7 @@ async def root(request: Request) -> Response: engine = create_async_engine("postgresql+asyncpg://postgres:secret@localhost/testdb") data_store = AsyncSQLAlchemyDataStore(engine) event_broker = AsyncpgEventBroker.from_async_sqla_engine(engine) -scheduler = AsyncScheduler() +scheduler = AsyncScheduler(data_store, event_broker) middleware = [Middleware(SchedulerMiddleware, scheduler=scheduler)] app = FastAPI(middleware=middleware) app.add_api_route("/", root) diff --git a/examples/web/asgi_starlette.py b/examples/web/asgi_starlette.py index 4288bfb..aaac3ac 100644 --- a/examples/web/asgi_starlette.py +++ b/examples/web/asgi_starlette.py @@ -59,7 +59,7 @@ async def root(request: Request) -> Response: engine = create_async_engine("postgresql+asyncpg://postgres:secret@localhost/testdb") data_store = AsyncSQLAlchemyDataStore(engine) event_broker = AsyncpgEventBroker.from_async_sqla_engine(engine) -scheduler = AsyncScheduler() +scheduler = AsyncScheduler(data_store, event_broker) routes = [Route("/", root)] middleware = [Middleware(SchedulerMiddleware, scheduler=scheduler)] app = Starlette(routes=routes, middleware=middleware) diff --git a/examples/web/wsgi_flask.py b/examples/web/wsgi_flask.py index cc74c7b..0574d25 100644 --- a/examples/web/wsgi_flask.py +++ b/examples/web/wsgi_flask.py @@ -1,7 +1,7 @@ """ Example demonstrating use with WSGI (raw WSGI application, no framework). -Requires the "postgresql" service to be running. +Requires the "postgresql" and "redis" services to be running. To install prerequisites: pip install sqlalchemy psycopg2 flask uwsgi To run: uwsgi -T --http :8000 --wsgi-file wsgi_flask.py diff --git a/examples/web/wsgi_noframework.py b/examples/web/wsgi_noframework.py index c143f3f..22ebb21 100644 --- a/examples/web/wsgi_noframework.py +++ b/examples/web/wsgi_noframework.py @@ -1,7 +1,7 @@ """ Example demonstrating use with WSGI (raw WSGI application, no framework). -Requires the "postgresql" service to be running. +Requires the "postgresql" and "redis" services to be running. To install prerequisites: pip install sqlalchemy psycopg2 uwsgi To run: uwsgi -T --http :8000 --wsgi-file wsgi_noframework.py @@ -16,6 +16,7 @@ from datetime import datetime from sqlalchemy.future import create_engine from apscheduler.datastores.sqlalchemy import SQLAlchemyDataStore +from apscheduler.eventbrokers.redis import RedisEventBroker from apscheduler.schedulers.sync import Scheduler from apscheduler.triggers.interval import IntervalTrigger @@ -36,6 +37,7 @@ def application(environ, start_response): engine = create_engine("postgresql+psycopg2://postgres:secret@localhost/testdb") data_store = SQLAlchemyDataStore(engine) -scheduler = Scheduler(data_store) +event_broker = RedisEventBroker.from_url("redis://localhost") +scheduler = Scheduler(data_store, event_broker) scheduler.add_schedule(tick, IntervalTrigger(seconds=1), id="tick") scheduler.start_in_background() -- cgit v1.2.1