Flask_APScheduler冲突的作业错误？

问题描述：

不确定如何在数据库上存储作业。每当我跑我的瓶的应用程序运行的第一次，然后当我关闭服务器并重新启动应用程序，我得到的错误：Flask_APScheduler冲突的作业错误？

sqlalchemy.exc.IntegrityError: (sqlite3.IntegrityError) UNIQUE constraint failed: apscheduler_jobs.id [SQL: 'INSERT INTO apscheduler_jobs (id, next_run_time, job_state) VALUES (?, ?, ?)'] [parameters: ('job1', 1505488120.453826, <memory at 0x00000200DB4A6DC8>)] 

During handling of the above exception, another exception occurred: 

Traceback (most recent call last): 
    File "run.py", line 4, in <module> 
    scheduler.start() 
    File "C:\Anaconda3\envs\g2x_flask\lib\site-packages\flask_apscheduler\scheduler.py", line 82, in start 
    self._scheduler.start() 
    File "C:\Anaconda3\envs\g2x_flask\lib\site-packages\apscheduler\schedulers\background.py", line 33, in start 
    BaseScheduler.start(self, *args, **kwargs) 
    File "C:\Anaconda3\envs\g2x_flask\lib\site-packages\apscheduler\schedulers\base.py", line 154, in start 
    self._real_add_job(job, jobstore_alias, replace_existing) 
    File "C:\Anaconda3\envs\g2x_flask\lib\site-packages\apscheduler\schedulers\base.py", line 851, in _real_add_job 
    store.add_job(job) 
    File "C:\Anaconda3\envs\g2x_flask\lib\site-packages\apscheduler\jobstores\sqlalchemy.py", line 94, in add_job 
    raise ConflictingIdError(job.id) 
apscheduler.jobstores.base.ConflictingIdError: 'Job identifier (job1) conflicts with an existing job'

我app\__intel__.py文件看起来像：

from flask import Flask 
from flask_apscheduler import APScheduler 
from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore 

from .models import db 


app = Flask(__name__) 
app.config.from_object('config.BaseConfig') 
db.init_app(app) 


class APSConfig(object): 
    JOBS = [ 
     { 
      'id': 'job1', 
      'func': 'intel_app.jobs:job1', 
      'args': (1, 2), 
      'trigger': 'interval', 
      'seconds': 10 
     } 
    ] 

    SCHEDULER_JOBSTORES = { 
     'default': SQLAlchemyJobStore(url=app.config['SQLALCHEMY_DATABASE_URI']) 
    } 

    SCHEDULER_EXECUTORS = { 
     'default': {'type': 'threadpool', 'max_workers': 20} 
    } 

    SCHEDULER_JOB_DEFAULTS = { 
     'coalesce': False, 
     'max_instances': 3 
    } 

    SCHEDULER_API_ENABLED = True 


app.config.from_object(APSConfig()) 

scheduler = APScheduler() 
scheduler.init_app(app)

它看起来像每次应用程序启动时，它都会尝试使用相同的jobid重新创建作业，但是，我不确定如何才能让它只创建一次作业，然后如果作业在数据库中使用它。

编辑：我的最终目标是要起床，从一个网站提取数据的作业，然后在数据库中存储的数据。所以，我想将这项工作设置为cron工作并将其部署到heroku上。

答

你正在因为作业ID“JOB1”在作业存储（数据库）已经存在，你不能有不同的工作相同的工作ID的错误。作业ID应该是唯一的。您可以将ID分配为“无”，并且计划程序将自动为其分配一个ID。新的作业ID将使用32位字母数字。您也可以生成自己的uuid并将其分配给作业ID。

答

如果您使用的是数据存储，您应在作业参数设置replace_existing到True，这样在重新启动时APScheduler将取代现有的作业。下面是与SQLAlchemyJobStore工作的例子cron作业：

'id': 'daily_email', 
    'func': send_daily_email, 
    'replace_existing': True, 
    'trigger': 'cron', 
    'misfire_grace_time': 600, 
    'max_instances': 1, 
    'hour': 22, # every day at 22:05 
    'minute': 5,

Flask_APScheduler冲突的作业错误？

相关推荐