6

私はSQLAlchemyJobStoreジョブストアを追加して（そしてそれをdefaultジョブストアに）、そこにいくつかのジョブを保存しようとしています。mysql。という名前のデータベースを持つを実行していますjobstore。

実行中のデータベースにSQLAlchemyJobStoreジョブストアを開こうとする次のプログラムがあります。mysql

# 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)

ここで何が問題になっていますか？！言い換えれば、どのようにSQLAlchemyJobStore使用を作成APSchedulerし、それらにジョブを正常に保存するのですか？どんな例/コードスニペットも大いに役立ちます！

4

1 に答える 1

4

コードに問題はないようです。私はそれを実行しようとしました、そしてそれは次の出力で首尾よく完了します：

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__

更新 私はあなたの投稿を読み直し、私のテストコードにはもう1つの違いがあることに気づきました-私は別の名前でファイルを作成しました：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モジュールがインストールされている場合に役立ちます。

于 2013-02-07T15:37:25.833 に答える