NameError: 全局名称 'create_engine' 未定义 [尝试创建 SQLAlchemyJobStore 时]

Question

我正在尝试添加一个 SQLAlchemyJobStore 的工作存储（并将其设置为 默认 工作存储），然后在上面存储一些任务。我正在使用 mysql 数据库，里面有一个名为 jobstore 的数据库。

我有一个程序，试图打开一个连接到正在运行的 mysql 数据库的 SQLAlchemyJobStore 工作存储：

# sqlalchemy.py 
from sqlalchemy import *
from apscheduler.jobstores.sqlalchemy_store import SQLAlchemyJobStore
from apscheduler.scheduler import Scheduler
from datetime import datetime, timedelta
import time

def alarm(time):
    print('Alarm! This alarm was scheduled at %s.' % time)

_aps_config = {'standalone': 'True'}
_dbURL = 'mysql://root:<root-password>@localhost/jobstore'

if __name__ == '__main__':

    scheduler = Scheduler(_aps_config)
    scheduler.add_jobstore(SQLAlchemyJobStore(url=_dbURL), 'default')

    alarm_time = datetime.now() + timedelta(seconds=10)
    scheduler.add_date_job(alarm, alarm_time, name='alarm1', args=[datetime.now()])
    print 'alarms added: ', alarm_time

    alarm_time = datetime.now() + timedelta(seconds=15)
    scheduler.add_date_job(alarm, alarm_time, name='alarm2', args=[datetime.now()])
    print 'alarms added: ', alarm_time

    alarm_time = datetime.now() + timedelta(seconds=20)
    scheduler.add_date_job(alarm, alarm_time, name='alarm3', args=[datetime.now()])
    print 'alarms added: ', alarm_time

    try:
        scheduler.start()
    except (KeyboardInterrupt, SystemExit):
        scheduler.shutdown()
        pass

当我尝试运行上面的代码时，我看到以下内容：

NameError: global name 'create_engine' is not defined

$ python sqlalchemy.py
Traceback (most recent call last):
  File "sqlalchemy.py", line 19, in <module>
    scheduler.add_jobstore(SQLAlchemyJobStore(url=_dbURL), 'default')
  File "/usr/lib/python2.7/site-packages/APScheduler-2.1.0-py2.7.egg/apscheduler/jobstores/sqlalchemy_store.py", line 29, in __init__
    self.engine = create_engine(url)
NameError: global name 'create_engine' is not defined
$ 

我看到 "/usr/lib/python2.7/site-packages/APScheduler-2.1.0-py2.7.egg/apscheduler/jobstores/sqlalchemy_store.py"，里面的 __init__ 正在尝试 create_engine，但失败了。

 20 class SQLAlchemyJobStore(JobStore):
 21     def __init__(self, url=None, engine=None, tablename='apscheduler_jobs',
 22                  metadata=None, pickle_protocol=pickle.HIGHEST_PROTOCOL):
 23         self.jobs = []
 24         self.pickle_protocol = pickle_protocol
 25 
 26         if engine:
 27             self.engine = engine
 28         elif url:
 29             self.engine = create_engine(url)

这里到底出了什么问题？！换句话说，我该如何使用 APScheduler 创建一个 SQLAlchemyJobStore 并成功地在上面存储任务呢？任何示例或代码片段都会很有帮助！

Answer 1

你的代码看起来没有问题。我试着运行了一下，结果成功了，输出如下：

python jobstore.py
alarms added:  2013-02-07 10:31:10.234000
alarms added:  2013-02-07 10:31:15.240000
alarms added:  2013-02-07 10:31:20.240000

我唯一做的改动是把 _dbURL = 'sqlite:///:memory:' 更新为使用 sqlite 引擎。

请检查一下你是否安装了 sqlalchemy，并且你的脚本能在 PYTHONPATH 中找到它。可以在 Python 控制台运行以下代码，或者更好的是，把它加到你脚本的开头，看看输出结果。

import sqlalchemy
print sqlalchemy.__version__ 

更新
我重新看了一下你的帖子，意识到我的测试代码还有一个不同之处 - 我创建了一个不同名字的文件：jobstore.py。

我尝试把文件重命名为 sqlalchemy.py，结果得到了同样的错误：

Traceback (most recent call last):
  File "C:/stackoverflow/so/sqlalchemy.py", line 22, in <module>
    scheduler.add_jobstore(SQLAlchemyJobStore(url=_dbURL), 'default')
  File "C:\Progs\Python27\lib\site-packages\apscheduler\jobstores\sqlalchemy_store.py", line 29, in __init__
    self.engine = create_engine(url)
NameError: global name 'create_engine' is not defined

Process finished with exit code 1

问题的根本原因是你的 Python 脚本名字和 sqlalchemy 模块的名字是一样的，所以 Python 优先加载你的脚本，导致无法访问 sqlalchemy 的代码。

试着把脚本的名字改成其他的，不要用 sqlalchemy.py 这个名字 - 如果你已经安装了 sqlalchemy 模块，这样做会有帮助。