async_cron
async_cron copied to clipboard
crontab for python,with asyncio
async_cron
this repo is influenced by schedule.
we supply a async scheduler and async function support
you can easily integrate this lib to you async program,with no blocking
Install
pip install async-cron
Usage examples
import asyncio
from async_cron.job import CronJob
from async_cron.schedule import Scheduler
async def test(*args, **kwargs):
print(args, kwargs)
def tt(*args, **kwargs):
print(args, kwargs)
msh = Scheduler(locale="zh_CN")
myjob = CronJob(name='test', run_total=3).every(
5).second.go(test, (1, 2, 3), name=123)
job2 = CronJob(name='exact', tolerance=100).at(
"2019-01-15 16:12").go(tt, (5), age=99)
job3 = CronJob(name='very_hour').every().hour.at(
":44").go(tt, (5), age=99)
job3 = CronJob(name='hour').every().hour.at(
":00").go(tt, (5), age=99)
job4 = CronJob(name='minute').every(1).minute.go(tt, (5), age=99)
job5 = CronJob(name='weekday').weekday(2).at("11:18").go(tt, (5), age=99)
job6 = CronJob(name='monthday').monthday(16).at("11:22").go(tt, (5), age=99)
job7 = CronJob(name='monthday').every(5).monthday(
16).at("11:22").go(tt, (5), age=99)
msh.add_job(myjob)
msh.add_job(job2)
msh.add_job(job3)
msh.add_job(job4)
msh.add_job(job5)
msh.add_job(job6)
msh.add_job(job7)
# jobload is only a special job,who gen jobs from config
# below means, this job load will check every 1 second for cron updates
# if any updates found,new job will be add to scheduler
# you dont have the direct way to delete jobs
# but you can modify the crons total_times to 0 or 1 to delete it
# by default,FileJobLoader use MultiThread,you can use MultiProcess by add
# thread=False
f_cron = FileJobLoader(name='f_cron', file_path='t_cron', log_path='.',thread=False)
fjob = CronJob(name='fjob', run_total=1).every(
1).second.go(f_cron.run, msh)
msh.add_job(fjob)
loop = asyncio.get_event_loop()
try:
loop.run_until_complete(msh.start())
except KeyboardInterrupt:
print('exit')
cron file useage:
parameter separate by blank.in item separate by comma
cron | name | job | env | run_times |
---|---|---|---|---|
*/1,*,*,*,* |
test | /bin/python,tt.py | aa=123,bb=345 | 10 |
example as follow:
common cron
*/1,*,*,*,*
test /bin/python,tt.py aa=123,bb=345 1
delete cron
*/1,*,*,*,*
test /bin/python,tt.py aa=123,bb=345 0
cron only support:
*
,10
,*/10
format. which fulfills mostly screen
License
The async_cron is offered under MIT license.