django로 샐러리 설정하기 [오류 발생]

Question

celery을 django으로 설정하고 3-tier project layout을 사용하려고합니다. 이미 syncdb 및 migration 명령을 실행했습니다. 하지만 저는 근로자를 시작할 때 약간의 실수를합니다. 누군가 나를 도울 수 있습니까? 고마워. >>> celery.py -

여기

- root/ 
    - src/ 
     - project/ 
      - __init__.py <<< celery imports added 
      - urls.py 
      - celery.py 
     - core/ 
      tasks.py 
     - manage.py 

명령은 내가

$ cd root 
    $ celery -A project --workdir=src/ worker -l info 

편집을 실행 내 프로젝트 레이아웃이다. 여기 내 INSTALLED_APP 설정입니다.

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 
         'project.settings.local') 

app = Celery('project', broker='django://') 
app.config_from_object('django.conf:settings') 
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) 

CELERYBEAT_SCHEDULE = { 
    'every-hour': { 
     'task': 'core.tasks.sync_currency_rates', 
     'schedule': crontab(minute='*/1') 
    }, 
} 

CELERY_TIMEZONE = 'UTC' 
CELERY_ALWAYS_EAGER = True 

그러면 다음 오류가 발생합니다.

-------------- celery@Kulbirs-Mac-mini.local v3.1.16 (Cipater) 
---- **** ----- 
--- * *** * -- Darwin-13.4.0-x86_64-i386-64bit 
-- * - **** --- 
- ** ---------- [config] 
- ** ---------- .> app:   actionsuite:0x10f929890 
- ** ---------- .> transport: django://localhost// 
- ** ---------- .> results:  disabled 
- *** --- * --- .> concurrency: 4 (prefork) 
-- ******* ---- 
--- ***** ----- [queues] 
-------------- .> celery   exchange=celery(direct) key=celery 


[tasks] 
    . core.tasks.sync_currency_rates 

[2014-10-07 18:52:17,662: INFO/MainProcess] Connected to django://localhost// 
[2014-10-07 18:52:17,678: ERROR/MainProcess] Unrecoverable error: OperationalError('no such table: djkombu_queue',) 
Traceback (most recent call last): 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/celery/worker/__init__.py", line 206, in start 
    self.blueprint.start(self) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/celery/bootsteps.py", line 123, in start 
    step.start(parent) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/celery/bootsteps.py", line 374, in start 
    return self.obj.start() 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/celery/worker/consumer.py", line 278, in start 
    blueprint.start(self) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/celery/bootsteps.py", line 123, in start 
    step.start(parent) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/celery/worker/consumer.py", line 608, in start 
    c.connection, on_decode_error=c.on_decode_error, 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/celery/app/amqp.py", line 375, in __init__ 
    **kw 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/kombu/messaging.py", line 359, in __init__ 
    self.revive(self.channel) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/kombu/messaging.py", line 371, in revive 
    self.declare() 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/kombu/messaging.py", line 381, in declare 
    queue.declare() 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/kombu/entity.py", line 505, in declare 
    self.queue_declare(nowait, passive=False) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/kombu/entity.py", line 531, in queue_declare 
    nowait=nowait) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/kombu/transport/virtual/__init__.py", line 446, in queue_declare 
    self._new_queue(queue, **kwargs) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/kombu/transport/django/__init__.py", line 36, in _new_queue 
    Queue.objects.get_or_create(name=queue) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/django/db/models/manager.py", line 92, in manager_method 
    return getattr(self.get_queryset(), name)(*args, **kwargs) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/django/db/models/query.py", line 422, in get_or_create 
    return self.get(**lookup), False 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/django/db/models/query.py", line 351, in get 
    num = len(clone) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/django/db/models/query.py", line 122, in __len__ 
    self._fetch_all() 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/django/db/models/query.py", line 966, in _fetch_all 
    self._result_cache = list(self.iterator()) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/django/db/models/query.py", line 265, in iterator 
    for row in compiler.results_iter(): 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/django/db/models/sql/compiler.py", line 700, in results_iter 
    for rows in self.execute_sql(MULTI): 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/django/db/models/sql/compiler.py", line 786, in execute_sql 
    cursor.execute(sql, params) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/django/db/backends/utils.py", line 81, in execute 
    return super(CursorDebugWrapper, self).execute(sql, params) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/django/db/backends/utils.py", line 65, in execute 
    return self.cursor.execute(sql, params) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/django/db/utils.py", line 94, in __exit__ 
    six.reraise(dj_exc_type, dj_exc_value, traceback) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/django/db/backends/utils.py", line 65, in execute 
    return self.cursor.execute(sql, params) 
    File "/Users/sandhu/Envs/allout/lib/python2.7/site-packages/django/db/backends/sqlite3/base.py", line 485, in execute 
    return Database.Cursor.execute(self, query, params) 
OperationalError: no such table: djkombu_queue 

편집 2 -> 내가 한 가지 더주의

. celery -A ... command을 실행하면 db.sqlite이 src(This is wrong)에 생성됩니다. syncdb 명령을 실행하면 루트에 db.sqlite 파일이 생성됩니다. 어느 쪽이 좋을까

Answer 1

샐러리 실행 파일은 root에서 SQLite 데이터베이스를 사용하고 Django는 project/settings/에서 다른 SQLite를 사용합니다. 절대 경로로 settings/local.py에서 SQLite는 DB의 경로를 수정 :

DATABASES = { 
    'default': { 
     'ENGINE': 'django.db.backends.sqlite3', 
     'NAME': os.path.join(os.path.dirname(__file__), "my_database.sq3"), 
    } 
}