1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
|
from __future__ import absolute_import, unicode_literals
import os
import sys
import types
from celery.app.defaults import strtobool
from celery.utils import import_from_cwd
DEFAULT_APPS = ('django.contrib.auth',
'django.contrib.contenttypes',
'django.contrib.sessions',
'django.contrib.admin',
'django.contrib.admindocs',
'djcelery')
DEFAULTS = {'ROOT_URLCONF': 'djcelery.monproj.urls',
'DATABASE_ENGINE': 'sqlite3',
'DATABASE_NAME': 'djcelerymon.db',
'DATABASES': {'default': {
'ENGINE': 'django.db.backends.sqlite3',
'NAME': 'djcelerymon.db'}},
'BROKER_URL': 'amqp://',
'SITE_ID': 1,
'INSTALLED_APPS': DEFAULT_APPS,
'DEBUG': strtobool(os.environ.get('DJCELERYMON_DEBUG', '0'))}
def default_settings(name='__default_settings__'):
c = type(name, (types.ModuleType, ), DEFAULTS)(name)
c.__dict__.update({'__file__': __file__})
sys.modules[name] = c
return name
def configure():
from celery import current_app
from celery.loaders.default import DEFAULT_CONFIG_MODULE
from django.conf import settings
app = current_app
conf = {}
if not settings.configured:
if 'loader' in app.__dict__ and app.loader.configured:
conf = current_app.loader.conf
else:
os.environ.pop('CELERY_LOADER', None)
settings_module = os.environ.get('CELERY_CONFIG_MODULE',
DEFAULT_CONFIG_MODULE)
try:
import_from_cwd(settings_module)
except ImportError:
settings_module = default_settings()
settings.configure(SETTINGS_MODULE=settings_module,
**dict(DEFAULTS, **conf))
def run_monitor(argv):
from .management.commands import djcelerymon
djcelerymon.Command().run_from_argv([argv[0], 'djcelerymon'] + argv[1:])
def main(argv=sys.argv):
from django.core import management
os.environ['CELERY_LOADER'] = 'default'
configure()
management.call_command('syncdb')
run_monitor(argv)
if __name__ == '__main__':
main()
|
