django-celery

    10热度

    1回答

    我试图按照教程安装django芹菜。安装后,我需要运行迁移进行必要的表,但似乎是错误: Traceback (most recent call last): File "manage.py", line 10, in <module> execute_from_command_line(sys.argv) File "/home/guilherme/.virtuale

    8热度

    1回答

    我遵循the Celery Django教程和我在示例中看到的任务(add, mul)完美地为我工作。当我做res = add.delay(1,2); res.get()时,我得到正确的答案。 但是当我尝试执行另一个我的任务res = sayhello.delay('trex')时,我得到*** NotRegistered: u'pipeline.tasks.sayhello'。 如果我做res

    9热度

    2回答

    我跑在CentOS使用Django 10,RabbitMQ的,和芹菜4站点的Cron计划定期任务7. 我芹菜殴打和芹菜工人实例由主管控制和我正在使用django celery数据库调度程序。 我已经使用Django-admin中的cronsheduler安排了cron样式任务。 当我开始芹菜拍子和工人实例时,作业按预期启动。 但是,如果在Django-admin中更改计划时间,则除非重新启动芹菜节

    0热度

    1回答

    我最近将Celery安装升级到4.0。经过几天的升级过程摔跤后,我终于开始工作......有点。有些任务会返回,但最终的任务不会。 我有一个类,SFF,是发生在和解析文件: # Constructor with I/O file def __init__(self, file): # File data that's gonna get used a lot sffDesc

    1热度

    1回答

    使用virtualenv为我的开发服务器和生产服务器使用相同的服务器。 我的问题是芹菜不知道什么项目运行任务英寸我不希望生产任务运行在我的开发服务器上,反之亦然。 我曾尝试使用不同券商ADRESS,但它不能正常工作:生产 主管脚本: [program:production-celery] command=/home/user/.virtualenvs/production.site.com/bi

    1热度

    1回答

    嘲笑非测试方法我有一个测试类,就像下面这样: @mock.patch('myapp.apps.mytask1.views.image_processing.apply_async') class SortAPITestCase(APITestCase): def hit_scan("""some args"""): scan_uri = 'some url'

    1热度

    1回答

    我有一些任务应该返回结果,一些任务不。 我想强制任何不应返回结果而不在结果后端写入任何内容(例如None)的任务。我如何在Celery中实现这一点? 例如,它是我的任务: @app.task def taskWithResult(): # ...code... return res @app.task def taskWithNoResult(): # ...

    0热度

    2回答

    我正在运行Redis,Celery 4.0和Django 1.10,但在从sh​​ell运行任务'test'时收到[Errrno 61]连接拒绝错误。这是我的项目结构: myproj │ ├── app1    ├── __init__.py ├── tasks.py myproj ├── __init__.py ├── urls.py ├─

    0热度

    1回答

    我想retry(official doc)引发异常时的任务。芹菜允许通过使用形式self.retry(...) 现在,我不知道如何用户self因为我有一个没有任何类的功能。 我的代码是这样的 .. imports ... app = Celery('elasticcelery') @app.task(name='rm_doc') def rm_doc(schema_id, id):

    -1热度

    1回答

    我正在运行一个芹菜服务器,它有5,6个任务定期运行。连续执行5,6天后,芹菜的记忆力过大。 芹菜文档很混乱。我正在使用以下设置。 # celeryconfig.py import os os.environ['DJANGO_SETTINGS_MODULE'] = 'xxx.settings' # default RabbitMQ broker BROKER_URL = "amqp://gu