我使用Django 1.6,RabbitMQ 3.5.6,celery 3.1.19.
有一个周期性任务,每30秒运行一次,并使用给定eta参数创建200个任务.在我运行芹菜工作者之后,慢慢地在RabbitMQ中创建了队列,我看到大约1200个计划任务等待被解雇.然后,我重新启动芹菜工作者,所有等待的1200个计划任务都从RabbitMQ中删除.
我如何创建任务:
my_task.apply_async((arg1, arg2), eta=my_object.time_in_future)
我像这样运行工人:
python manage.py celery worker -Q my_tasks_1 -A my_app -l
CELERY_ACKS_LATE被设置为True在Django设置.我找不到任何可能的原因.
我应该使用不同的配置/标志/参数运行worker吗？任何的想法？
我用Ubuntu Precise创建了一个VM实例.然后我安装了大量的库并设置了我的环境.我将使用具有略微不同配置的另一台服务器,因此我想复制或克隆当前实例.
我认为当我编辑实例时出现的克隆按钮将执行我想要的操作但是在克隆我的实例并进入服务器后,我没有看到任何库安装或者其他什么.
有没有办法像我在亚马逊那样完全创建服务器(实例)的新副本？