Lightweight and beneficial Dependency Injection plugin for apscheduler
Project description
Implementation of dependency injection for apscheduler
Motivation:
apscheduler-di
solves the problem sinceapscheduler
doesn't support Dependency Injection natively, and it's real problem for developers to pass on complicated objects to jobs without corruptions
Features:
- Supports type hints (PEP 561)
- Extend
apscheduler
and provide handy aliases for events(such ason_startup
,on_shutdown
and etc) - Provide an opportunity to implement Dependency Inversion SOLID principle
"Under the hood" apscheduler-di
just
implements Decorator pattern and wraps up the
work of native BaseScheduler
using rodi lib
Quick example:
import os
from typing import Dict
from apscheduler.jobstores.redis import RedisJobStore
from apscheduler.schedulers.blocking import BlockingScheduler
from apscheduler_di import ContextSchedulerDecorator
# pip install redis
job_stores: Dict[str, RedisJobStore] = {
"default": RedisJobStore(
jobs_key="dispatched_trips_jobs", run_times_key="dispatched_trips_running"
)
}
class Tack:
def tack(self):
print("Tack!")
def tick(tack: Tack, some_argument: int):
print(tack)
def main():
scheduler = ContextSchedulerDecorator(BlockingScheduler(jobstores=job_stores))
scheduler.ctx.add_instance(Tack(), Tack)
scheduler.add_executor('processpool')
scheduler.add_job(tick, 'interval', seconds=3, kwargs={"some_argument": 5})
print('Press Ctrl+{0} to exit'.format('Break' if os.name == 'nt' else 'C'))
try:
scheduler.start()
except (KeyboardInterrupt, SystemExit):
pass
if __name__ == '__main__':
main()
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
apscheduler_di-0.1.0.tar.gz
(8.8 kB
view hashes)
Built Distribution
Close
Hashes for apscheduler_di-0.1.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | aaeda49f4f9c5a4cdd3dcb9498e3431eecfedce50e05ccf77861cca70bfb44bc |
|
MD5 | fd9e6437253946b3921ddc5ef8c5485a |
|
BLAKE2b-256 | 037bd39f91d965b4c18bc0baab9d202f9e3dbbb827ab33e5750fb650cd4e842b |