celery

    0热度

    1回答

    在监督员上运行Ubuntu上的芹菜任务

    我有一个使用mod_wsgi守护进程测试Django站点，并且已经设置了一个简单的Celery任务来通过电子邮件发送一个联系表，并安装了主管。 我知道Django代码是正确的。 我遇到的问题是，当我提交表单时，我只收到一条消息 - 第一条。联系表单的后续完成完全不会发送任何消息。 在我的服务器上，我有另一个测试站点，运行配置好的监控任务，使用Django服务器（即不使用mod_wsgi）。我的两个
    django celery supervisord 2017-10-10

    0热度

    1回答

    我怎么能有RabbitMQ的运行只在第一条消息发送一次？

    我真正的新兔子，我不知道如何寻找与此相关的问题或什么是执行这个 我有一个当用户到达一个页面被调用任务的最佳方式的具体条款。我只想让那个页面在当天运行一次。如果有更多人访问该页面，则该任务不会被执行，因为它已经完成了。如果没有人前往该页面，那么该任务永远不会运行。 有人能请您指点一个方向，以什么我应该寻找？
    rabbitmq celery 2017-10-10

    1热度

    1回答

    我可以更改给定芹菜任务的ETA参数吗？

    我有我运行使用集合O芹菜任务： my_task.apply_async(args, eta=some_eta) 但有时由于某些情况，我需要改变这些任务的ETA。 我可以使用inspect和scheduled方法获得任务的ID，我想知道是否有方法来更改知道任务ID的ETA参数，或者我应该撤销此任务并启动另一个任务？
    python celery 2017-10-10

    0热度

    1回答

    芹菜任务不会重试

    我有没有被重新运行失败的任务包含以下内容的简单test_celery.py文件： from celery import Celery import time app = Celery( 'test_celery', broker='amqp://', backend='amqp' ) @app.task(retries=4) def my_fail():
    python celery 2017-10-10

    0热度

    1回答

    如何从芹菜任务发出事件

    基本上，我试图在一个单独的线程在服务器端生成事件。我有一个celery.task应该发出事件，但其代码从未执行。 import json import time from celery import Celery from flask import Flask from flask import jsonify from flask import render_template f
    python flask celery flask-socketio 2017-10-10

    0热度

    1回答

    芹菜总是渴望跑任务vs异步

    当我加载我的页面时，我的兔子得到的消息，但从来没有消耗。当CELERY_ALWAYS_EAGER = True时，我的任务已耗尽，但我的页面始终在等待完成任务时加载，因此在heroku上创建了一个timeout，并且出现错误。 我在这里参加圈子。芹菜的全部目的是异步，它为什么这样做？我是否缺少一些其他配置？ BROKER_URL=['amqp://[email protected]//','amq
    celery 2017-10-11

    -1热度

    2回答

    Python每20秒运行一次cron作业

    我总是使用芹菜周期性任务来运行cron，但是这次芹菜的crontab无法完成我的cronjob。我需要一个cron，只有星期二从20:50到21:10每20秒运行。似乎无法实现这个
    python cron celery 2017-10-11

    1热度

    1回答

    达芙妮不听Websocket

    我有一个使用websockets进行客户端 - 服务器通信的django-channels + celery编写的webapp。在测试运行daphne，芹菜工作人员和redis在我的主机上之后，我决定用docker-compose封装所有东西，以便拥有可部署的系统。 这是问题出现的地方。在学习，调整和调试我的docler-compose.yaml之后，我设法让它工作，但仍然无法让websocket
    python django websocket celery daphne 2017-10-11

    1热度

    1回答

    当用户的Flask会话结束时，如何从redis后端删除所有Celery结果？

    这是一个高层次的问题，因为我可能只是有一个设计不佳的Flask应用程序，但我目前已经构建了一个应用程序，在用户提交表单后，一个芹菜工作人员将输入格式化为一个sql查询并执行该查询。 现在我已经设置了一个Redis后端来保留结果，所以当任务完成时，我可以通过从Redis获取结果来显示结果。但是，我不希望这些结果永远在Redis中持续存在，但我确实希望它们在应用程序中坚持整个用户会话，以便他们可以在会
    python flask redis celery 2017-10-13

    0热度

    1回答

    在Flask中成功提交后执行celery任务？

    将相对长时间运行的任务委托给另一台服务器上的芹菜工作人员，这些工作人员正在单独运行。 但是，结果被添加回关系数据库（根据task_descr.id作为关键字更新表，见下文），工作人员使用ignore_result。 任务从瓶的应用要求： task = app.celery.send_task('tasks.mytask', [task_descr.id, attachments]) 的问题是，
    flask transactions celery race-condition 2017-10-13
最新问题