- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我是 APScheduler 的新手,并在在更大范围内实现之前对其进行了测试。
我已经创建了下面的代码,但是当我将 add_job 与 trigger='date'
一起使用时,我的函数从未被调用过。 .如果我使用 trigger='interval'
,然后一切正常。
我也试过玩 run_date
参数,没有运气。
知道什么可能是错的吗?
Apscheduler 版本为 3.0.3
提前谢谢了 :)
def my_listener(event):
if event.exception:
print('The job crashed :(')
else:
print('The job worked :)')
def test():
print("{} ok ".format(datetime.now()))
def myFunc(content, img):
print("{} - content={}|image{}".format(datetime.now(), content, img))
myfile = open("scheduler.log", "a")
myfile.write("{} - content={}|image{}".format(datetime.now(), content, img))
myfile.close()
def main():
jobstores = \
{
'default': SQLAlchemyJobStore(url="postgresql+psycopg2://{}:{}@{}:{}/{}".format(db_user, db_password, db_host, db_port, db_database))
}
executors = \
{
'default': ThreadPoolExecutor(20),
'processpool': ProcessPoolExecutor(5)
}
job_defaults = \
{
'coalesce': False,
'max_instances': 3
}
scheduler = BackgroundScheduler(jobstores=jobstores, executors=executors, job_defaults=job_defaults, timezone=utc)
scheduler.start()
CURR_DATE = datetime.strptime(datetime.strftime(datetime.now(), '%Y%m%d%H%M'), '%Y%m%d%H%M')
JOB_DATE = CURR_DATE + timedelta(minutes=1)
uid=uuid.uuid4()
newjob = scheduler.add_job(myFunc,
trigger='date',
args=['content data', 'image data'],
kwargs=None,
id=str(uid),
name='test' + str(uid),
misfire_grace_time=5,
coalesce=False,
max_instances=1,
next_run_time= JOB_DATE,
jobstore='default',
executor='default',
replace_existing=True)
print("Added - {}".format(newjob))
scheduler.add_listener(my_listener, events.EVENT_JOB_EXECUTED | events.EVENT_JOB_ERROR)
scheduler.print_jobs()
while True:
sys.stdout.write('{}\n'.format(datetime.now())); sys.stdout.flush()
sleep(1)
if __name__ == "__main__":
main()
最佳答案
问题是你正在使用
next_run_time= JOB_DATE,
而不是 run_date=JOB_DATE,
另一个选项是声明您的触发器并将其作为参数传递以添加如下作业:
trigger = DateTrigger(run_date=start_date)
newjob = scheduler.add_job(myFunc,
trigger=trigger,
args=['content data', 'image data'],
kwargs=None,
id=str(uid),
name='test' + str(uid),
misfire_grace_time=5,
coalesce=False,
max_instances=1,
jobstore='default',
executor='default',
replace_existing=True)
CURR_DATE = datetime.strptime(datetime.strftime(datetime.now(), '%Y%m%d%H%M'), '%Y%m%d%H%M')
JOB_DATE = CURR_DATE + timedelta(minutes=1) #this is unaware
import pytz
import datetime
job_date = datetime.datetime.now(pytz.UTC) + datetime.timedelta(minutes=1)
关于APScheduler - 作业未执行,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32784942/
我有一些经常运行或持续一段时间的重复性工作。 似乎 Scheduler().get_jobs() 只会返回当前未运行的计划作业列表,因此我无法确定具有特定 id 的作业是否不存在或实际正在运行。 在这
我不知道为什么会收到此错误:ImportError: No module named 'apscheduler'。 我尝试安装旧版本:sudo pip uninstall apscheduler 然后
我有一个正在运行的 Django 项目及其数据库和模型表。现在,我想使用 Django 数据库连接集成 APScheduler 并将 APScheduler 作业保存在与其他表相同的数据库中。 我已阅
我是 APScheduler 的新手,并在在更大范围内实现之前对其进行了测试。 我已经创建了下面的代码,但是当我将 add_job 与 trigger='date' 一起使用时,我的函数从未被调用过。
我有一个使用 uwsgi(有 10 个 worker )+ ngnix 运行的 django 应用程序。我正在使用 apscheduler 进行调度。每当我安排一项工作时,它都会被多次执行。从这些答案
调度程序在生产中运行良好,然后突然关闭。显然,DB 可能已经离线了一段时间(网络应用程序从未错过任何一个节拍,因此它是短暂的)。 日志报告... [2019-11-25 07:59:14,907: I
我正在使用 APScheduler(3.5.3) 来运行三个不同的作业。我需要在完成第一份工作后立即触发第二份工作。另外我不知道第一份工作的完成时间。我将触发器类型设置为 cron 并计划每 2 小时
我们正在运行 Azure Kubernetes 集群(DEV、TST、PRD 上每个阶段一个),我们需要定期运行多个 Python 脚本,这就是我们使用 APScheduler (3.6.0) 的目的
目前,我正在使用 APScheduler 每 10 分钟自动执行一次脚本。它在 print("[+] Success! Bot Starting!") 之后停止执行,它不会输出错误。我建议我的 Sch
我在程序中使用 APScheduler 在特定日期时间安排作业。但是,我正在处理与本地时间不同时区的日期时间。所以我传递给 APScheduler 的日期时间始终是一个时区感知的日期时间... sch
我们需要在当前作业执行时动态调度多个作业。 大概的场景是: 应该有一个调度程序来每天检查应用程序表(假设在世界标准时间上午 6 点)。查找今天的日期时间为resume_dttime的用户为该用户动态安
我尝试了APS的MongoJobStore example。示例代码为: import logging import os import sys from datetime import dateti
我在脚本中使用模块APScheduler,我使用BlockingScheduler。我有一些定期的工作。如果此作业引发一个异常,无论我在try中期望它还是让它传播,我的线程都会这样做不返回。然后我达到
我希望每天早上 6 点启动我的主要任务。但出于测试目的,我将间隔设置为 5 秒。问题是它似乎永远不会开火。我在 maintask 方法中有一个从未到达的断点,并且没有任何内容打印到控制台。我假设它没有
我通过 apscheduler 安排了作业。到目前为止,我有 3 份工作,但很快就会有更多。我正在寻找一种方法来扩展我的代码。 目前,每个作业都是它自己的.py文件,在该文件中,我将脚本变成了一个以r
我在 django 中运行了 apscheduler,它似乎可以正常工作……好吧。在我的项目 init.py 中,我初始化了调度程序: scheduler = Scheduler(daemon=Tru
我正在尝试为 Github 上的一个项目做出贡献,以收集财务信息 数据。 代码.. # time_keeper.py from apscheduler.scheduler import
[Python 3.5.2, APScheduler 3.3.1] APScheduler 启动了一些线程,我想知道为什么。 这是我正在执行的代码(在 PyCharm 中,我还可以在其中绘制线程图):
我当前正在尝试设置调度程序(使用 apscheduler),但在添加作业时失败: from apscheduler.schedulers.blocking import BlockingSchedul
我正在 redis 中添加作业,完成作业后我添加了一个事件处理程序。在事件处理程序中,我返回值,根据该值我从作业库中删除作业 ID。它被成功删除,但立即抛出异常。 代码 from datetime i
我是一名优秀的程序员,十分优秀!