您的位置:首页 > 其它

celery 修改任务后 需要重启celery

2017-12-21 11:51 113 查看
celery 修改任务后,需要重启,不然不生效:

@task()
def Task_A(message):
now = datetime.datetime.now()
return message+str(now)+'scan'

node2:/celery/djtest#python manage.py celeryd -l info
/usr/local/python27/lib/python2.7/site-packages/celery/platforms.py:812: RuntimeWarning: You are running the worker with superuser privileges, which is
absolutely not recommended!

Please specify a different user using the -u option.

User information: uid=0 euid=0 gid=0 egid=0

uid=uid, euid=euid, gid=gid, egid=egid,

-------------- celery@node2 v3.1.25 (Cipater)
---- **** -----
--- * ***  * -- Linux-2.6.32-431.el6.x86_64-x86_64-with-centos-6.5-Final
-- * - **** ---
- ** ---------- [config]
- ** ---------- .> app:         portal:0x2478490
- ** ---------- .> transport:   redis://127.0.0.1:6379/0
- ** ---------- .> results:     redis://127.0.0.1:6379/0
- *** --- * --- .> concurrency: 1 (prefork)
-- ******* ----
--- ***** ----- [queues]
-------------- .> celery           exchange=celery(direct) key=celery

[tasks]
. djtest.celery.debug_task
. portal.tasks.Task_A

[2017-12-05 21:15:56,820: INFO/MainProcess] Connected to redis://127.0.0.1:6379/0
[2017-12-05 21:15:56,830: INFO/MainProcess] mingle: searching for neighbors
[2017-12-05 21:15:57,837: INFO/MainProcess] mingle: all alone
[2017-12-05 21:15:57,852: WARNING/MainProcess] /usr/local/python27/lib/python2.7/site-packages/celery/fixups/django.py:265: UserWarning: Using settings.DEBUG leads to a memory leak, never use this setting in production environments!
warnings.warn('Using settings.DEBUG leads to a memory leak, never '
[2017-12-05 21:15:57,852: WARNING/MainProcess] celery@node2 ready.
[2017-12-05 21:16:00,006: INFO/MainProcess] Received task: portal.tasks.Task_A[685cbe67-3efd-46db-ba53-199b9caa075a]
[2017-12-05 21:16:00,011: INFO/MainProcess] Task portal.tasks.Task_A[685cbe67-3efd-46db-ba53-199b9caa075a] succeeded in 0.00437201800014s: u'aaa2017-12-05 21:16:00.007551scan'

[2017-12-05 21:18:00,005: INFO/MainProcess] Received task: portal.tasks.Task_A[48b46f83-1fdf-4b89-bd54-1117b8a1736a]
[2017-12-05 21:18:00,008: INFO/MainProcess] Task portal.tasks.Task_A[48b46f83-1fdf-4b89-bd54-1117b8a1736a] succeeded in 0.00170183199953s: u'aaa2017-12-05 21:18:00.006713scan'
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: 
相关文章推荐