django-celery

    3热度

    3回答

    芹菜为每个失败的任务发送邮件

    我在我的django应用程序中使用芹菜，并且我设置了芹菜花来监控芹菜的任务。我已经设置了在注册/提交/ FP等事件时将电子邮件发送给用户的任务。现在Flower给了我一个很好的任务细节和状态。现在，对于每一次失败的任务，我都想要一封电子邮件发送到我的帐户，以便我没有每天检查花朵是否有失败的任务。 我确实在我的settings.py文件 CELERY_SEND_TASK_ERROR_EMAILS =
    python django django-celery celery-task 2016-04-11

    0热度

    1回答

    如何循环和创建多个Django的芹菜任务

    我有3名员工，我试图创建多个芹菜任务是这样的： for e in employees: res1 = escalate.apply_async((e.id), countdown=3) print res1.id 这应该创建3个任务，但它仅创建1 每个ID打印出： dc553662-283e-46e5-b811-7c1f5ed08d2d be7043bc-02a1-4641
    django celery django-celery 2016-04-21

    1热度

    1回答

    django获取当前django用户的所有正在运行/挂起的芹菜任务

    是否有任何pythonic方式来获取当前登录的django用户的所有正在运行/挂起的芹菜任务？伪代码为我正在尝试： @celery.task def process_task(user, task_to_do): #get all running or pending(queued) task for current user user_tasks = user.
    celery django-celery 2016-04-22

    0热度

    1回答

    带定时器的Django芹菜应用程序

    我遇到了django芹菜应用程序的问题。假设我有两个相关模型 - 交易和账户。我通过API推送交易。我想要实现的是计算指定帐户的余额。 我有一个计算余额的芹菜任务。问题是我需要为每个帐户设置一个计时器，设置为例如。 60秒。当交易到达同一账户时，计时器再次设置为60。我想这样做，因为我不想多次运行相同的任务。当指定账户的交易不会达到60秒时，应执行任务。 任何建筑建议如何实现？事实上，我只是不知道
    django celery django-celery 2016-04-22

    0热度

    2回答

    重启芹菜是否会导致重复任务？

    我有一个电子邮件任务在从现在开始的10天内有一个eta（）。但是，我发现有些人每次收到5-6个重复的电子邮件。我之前遇到过这个问题，并且BROKER_TRANSPORT_OPTIONS设置得太低。现在我有这个在我的设置文件中： BROKER_TRANSPORT_OPTIONS = {'visibility_timeout': 2592000} #30 days 所以这应该不成问题了。我只是想知
    python django redis celery django-celery 2016-03-08

    1热度

    1回答

    Django芹菜任务重复：无法锁定DB？

    我的django应用程序允许用户向对方发送消息，并将一些最近的消息汇集在一起​​，并使用芹菜和redis在电子邮件中发送它们。 用户每次发送消息时，我想补充一个信息到数据库，然后触发一个异步任务，从最后60秒内汇集用户的信息并将它们作为电子邮件。 tasks.pushMessagePool.apply_async(args = (fromUser,), countdown = 60) 如果用户
    django redis celery django-celery 2016-03-10

    2热度

    3回答

    在没有更多任务需要运行后，我该如何让芹菜死亡？

    我有一个内存密集型的芹菜任务，我希望它可以在一个昂贵的AWS服务器上运行，该服务器大多数时间都处于关闭状态。 芹菜节拍将每天安排一次任务，但它也可以通过网络应用程序（== django）手动安排。 调度任务是发送消息到兔子队列的问题。 然后我想发出一个命令，使用AWS api打开我的昂贵的服务器，并让它启动工作， 等到他们死后没有更多的任务，并关闭（并节省一些钱，因为服务器关闭）。 我知道如何编写
    django amazon-web-services celery django-celery 2016-05-11

    3热度

    1回答

    如何分离Django和芹菜？

    在我的芹菜任务中，我有一个使用在GPU上运行的python模块（theano）的任务，该模块只能同时由一个线程导入。但开始的网站，我要跑： python manage.py runserver celery -A celery_try worker -l info 所以该模块将由两个芹菜和Django的网站，这是冲突进口。有没有办法将Django和Celery分开，以便模块只导入一次？
    python django celery django-celery 2016-05-13

    0热度

    1回答

    向Celery发送任务时创建一个用户给我一个错误：用户匹配查询不存在

    我已经设置了DRF（Django Rest Framework）的休息API。其中一项API功能包括创建用户帐户（a.k.a.注册）。 一旦用户被“创建”，我发送一个任务给芹菜发送确认邮件。 但是，当任务由芹菜工人执行，发生错误： DoesNotExist: User matching query does not exist. 任务需要一个用户ID，仅此而已。然后我尝试拨打数据库。正是在这个时候
    python django django-rest-framework django-celery 2016-05-14

    5热度

    1回答

    芹菜/ Django - 如何以编程方式查看工人状态

    我刚刚安装了芹菜，我想创建一个简单的状态页面，显示当前的工人数量及其状态。 这可能吗？从网络搜索我发现最好的是celery.current_app.control.inspect() 但据我所知，它没有提到关于工人的任何事情。 （如果有问题，我使用Kombu和SQS作为后端）
    django celery django-celery amazon-sqs 2016-03-28
最新问题