如何使用 apscheduler 为机器人安排异步函数

Question

我想使用 apscheduler 安排一个异步功能，就像

我向机器人添加作业一样，并且不知何故我在重新启动机器人后停止运行机器人，它应该继续该功能。

就像我每 3 小时安排一次异步函数，我的机器人在中间停止，然后我重新启动机器人（重新启动时我们将正常执行 schedular.start()）。我想让异步函数再次继续，而无需再次添加。

我尝试了这个，但它不起作用

from apscheduler.executors.asyncio import AsyncIOExecutor
from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore
from apscheduler.schedulers.asyncio import AsyncIOScheduler
from pytz import utc

import datetime

jobstores = {
    'default': SQLAlchemyJobStore(url=database_url),
}

executors = {
    'default': AsyncIOExecutor(),
}

job_defaults = {
    'coalesce': False,
    'max_instances': 1
} 

scheduler = AsyncIOScheduler(jobstores=jobstores,
                             executors=executors,
                             job_defaults=job_defaults,
                             timezone=utc)

async def myfunc():
    print("result")

trigger_time = datetime.datetime.utcnow() + datetime.timedelta(hours=3)
scheduler.add_job(myfunc, 'interval',id=55454,run_date=trigger_time)
scheduler.start()
 

Answer 1

认为你所拥有的基本上是正确的，除了你如何安排它之外。您正在为作业的间隔提供日期时间。尝试类似的方法，

scheduler.add_job(myfunc, 'interval', hours=3)

请参阅此处以了解有关该方法的更多信息： https:// /apscheduler.readthedocs.io/en/3.x/modules/triggers/interval.html

还有 'calendarinterval' 如果您需要，它可能会很有用使用日期： https://apscheduler.readthedocs.io/en/ master/modules/triggers/calendarinterval.html

最后，如果 id=55454 是函数的参数，则需要以列表形式提供，例如
scheduler.add_job(myfunc, 'interval', hours=3, args=[55454])
https://apscheduler.readthedocs.io/en/latest/modules/schedulers/base.html#apscheduler.schedulers.base.BaseScheduler.add_job