我会给你我的具体例子,但这是一个一般性的python问题。
我有一个apscheduler作业对象的列表,我正在尝试找出从我的apscheduler作业列表中获取apscheduler作业属性列表的最有效的方法,'kwargs‘。
我知道我可以遍历整个列表并创建一个新的kwarg列表,但我想知道在python中是否有更有效/更干净的方法来做到这一点,因为我是新手。谢谢!
from apscheduler.scheduler import Scheduler
schedule = Scheduler()
jobs = schedule.get_jobs() #jobs is a lis
我正在尝试在APScheduler中运行多个作业,然后在稍后删除它们。但是,运行下面的代码会出现此错误,"apscheduler.schedulers.SchedulerAlreadyRunningError:排定程序已在运行。“
from flask import Flask
from apscheduler.schedulers.background import BackgroundScheduler
import time
sched = BackgroundScheduler(daemon=True)
def settingJobs(number):
global
在我使用高级Python Scheduler保存一些作业后,我正在尝试弄清楚sqlite数据库的模式是什么样子。我需要它,因为我想在UI中显示作业。我试着写一个简单的脚本来保存作业:
from pytz import utc
from apscheduler.schedulers.background import BackgroundScheduler
from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore
from apscheduler.executors.pool import ThreadPoolExecut
我想在我的web服务器上运行一个后台作业来做一些数据库维护。我正在考虑使用APScheduler来完成这个任务。
我计划在一个单独的进程中运行下面的代码到我的主web服务器。我真的不想把代码绑定到我的web服务器上。
问:在类似cron的调度器的末尾使用While True pass是否被认为是错误的做法?该怎么做?(time.sleep()?)
from apscheduler.scheduler import Scheduler
@sched.interval_schedule(days=1)
def tick():
# do a clean up job
while Tru
我想在晚上运行python脚本,所以我在考虑使用APScheduler。我将在第二天凌晨1点开始运行它,它将每晚运行一次
我的调度程序脚本如下所示(scheduler.py):
from apscheduler.scheduler import Scheduler
from datetime import datetime, timedelta, time, date
def myScript():
print "ok"
if __name__ == '__main__':
sched = Scheduler()
startDate
APScheduler (3.3.1) py2.7
我使用这段代码来完成我的工作,当我使用内存作为作业存储时,它可以很好地工作,但是我有太多的作业,而且我在服务器中的内存是有限的,所以我将SQLAlchemyJobStore更改为作业存储,但是我得到了查找错误。如何解决这个问题。
代码:
def script(indicator, strategy_name, real_time=False):
# Solve No handlers could be found for logger “apscheduler.scheduler
import logging
logg
我正在尝试学习如何使用Python的ap调度程序包,但是定期地,它会引发以下错误:
No handlers could be found for logger "apscheduler.scheduler"
此消息似乎与计划作业中的错误相关联,例如,使用jobTester作为计划作业,下面的代码(在jobTester中使用未定义变量(nameStr0) )提供了上述错误消息:
from apscheduler.scheduler import Scheduler
from apscheduler.jobstores.shelve_store import ShelveJobSt
这是我的test.py from datetime import datetime, timedelta
import sys
import os
from apscheduler.schedulers.blocking import BlockingScheduler
from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore
from apscheduler.jobstores.redis import RedisJobStore
jobstores = {
#'default': S
我尝试将一个对象作为参数传递给一个作业函数。这很好,但在我的例子中,我想要更改它的一个值,并在触发作业时使用更新后的值。下面是我的示例代码
import time
import sqlalchemy
from apscheduler.schedulers.background import BackgroundScheduler
from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore
class MyClass:
def __init__(self, *args, **kwargs):
self
下面所示的示例来自于in 。它演示了如何配置调度程序。但是我不明白配置到底在做什么。
问题
jobstores有两个键,一个使用MongoDB,另一个是SQLite。那么调度程序将使用哪一个呢?
executors也有两个键,一个使用ThreadPoolExecutor,另一个使用ProcessPoolExecutor。它会用哪一个?什么是并行(例如,所有计划的作业) ?
from pytz import utc
from apscheduler.schedulers.background import BackgroundScheduler
from apscheduler.jobstor
我知道使用APScheduler的通常方法是“pythonsetup.py安装”。但是我想将它直接嵌入到我的程序中,所以用户在使用我的程序时不需要安装它。
class BaseScheduler(six.with_metaclass(ABCMeta)):
_trigger_plugins = dict((ep.name, ep) for ep in iter_entry_points('apscheduler.triggers'))
# print(_trigger_plugins, 'ddd')
_trigger_classes = {}
_executor