celery-task

    0热度

    1回答

    使用蟒蛇没有Django的芹菜定期任务

    你好，我是芹菜和蟒蛇的新手。我正在使用rabbitmq-server创建一个简单的任务。但我不知道如何实现使用芹菜在python节拍的定期任务。我搜索，但每一个地方，我与Django的定期任务。 我用这个代码tasks.py： 芹菜芹菜进口从 时间导入的strftime app = Celery('tasks',broker='pyamqp://[email protected]//') @a
    python-2.7 celery-task celerybeat 2016-12-28

    0热度

    1回答

    芹菜send_task和异常时重试

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

    -2热度

    1回答

    如何在Celery中创建条件子任务链？

    我正在创建一个应用程序，该应用程序将创建一个要执行的任务链，但链会根据用户对该片添加的愿望执行任务。 例如，如果用户想要start_boo链可能是： def start_boo(): chain = start_foo.s() | start_bar.s() | start_baz.s() chain() 但是，如果foo和baz已经开始了，我们不希望这样做;而是宁愿是这样
    python-3.x celery celery-task 2016-08-23

    0热度

    1回答

    在HTTP请求中使用Celery任务ID安全吗？

    我开始在基于Flask的Web应用程序中使用Celery来在服务器端运行异步任务。 一些资源得到一个“/动作”子资源以该用户/客户端可以发送包括JSON体指定动作的POST，例如： curl -H "Content-Type: application/json" -X POST \ -d '{"doPostprocessing": { "update": true}}}' \
    celery celery-task 2016-08-25

    -1热度

    1回答

    仅在一台机器上运行芹菜周期性任务

    我正在使用芹菜的django项目。我在名为app1和app2的项目中有三个两个大模块。我为两台独立的机器上运行的应用程序创建了两个芹菜应用程序。在app1和app2中有不同的任务，我想运行差异机器，它工作正常。但我的问题是我有一些periodic_tasks。我为他们定义了一个名为periodic_tasks的队列。我想在单独的第三台机器上运行这些定期任务。或者在第三台机器上，我只想运行周期性任务
    celery celery-task celerybeat celeryd 2016-10-17

    10热度

    3回答

    如何将芹菜作业的参数输入到要查询的数据库中;使用mysql

    我使用MySql作为芹菜的后端结果。我也想将程序参数存储在数据库中。 例如： add.apply_async(args=[num1, num2, user] 在这种情况下，我想存储在数据库用户的说法，让我可以在以后查询。 目前，我返回提供的存储在数据库中的参数。 def add(num1, num2, user): return [num1+num2, user] 但是，当任务处
    python mysql celery celery-task 2016-07-13

    1热度

    1回答

    芹菜任务无法从项目内导入模块的ImportError

    我想指出，只有在运行芹菜工时才会出现以下错误。 与在终端下面的命令： celery -A MarketPlaceTasks worker --loglevel=info Traceback (most recent call last): File "/usr/lib/python2.7/dist-packages/celery/app/trace.py", line 218, in
    python python-2.7 enums celery celery-task 2016-09-14

    0热度

    1回答

    工作人员无法在烧瓶芹菜任务中获取新数据插入到

    我有三台服务器运行我的程序，每台服务器有八台芹菜工人从redis获取任务。也就是说每个服务器的芹菜任务可以由另一个服务器执行。 在每个服务器： 提交更改和呼叫任务 ... try: db.session.commit() except Exception as e: current_app.logger.error(str(e)) db.se
    python flask celery celery-task celeryd 2016-11-04

    0热度

    1回答

    使用芹菜节拍在多个时间点（使用不同参数）调度任务

    我试图实现的内容 编写一个调度程序，它使用数据库在不同的时间安排类似的任务。 ，因为我是用芹菜节拍相同，下面的代码片段会给一个想法 try: reader = MongoReader() except: raise try: tasks = reader.get_scheduled_tasks() except: raise celerybeat_s
    python-3.x celery scheduler celery-task celerybeat 2016-11-09

    1热度

    1回答

    芹菜 - 散装队列任务

    我已经一些排队的芹菜任务大量（1000），例如起见代码让我们说这就是： for x in xrange(2000): example_task.delay(x) 是否有排队的更好/更有效的方法大量的任务一次？他们都有不同的论点。
    python celery celery-task 2016-11-18
最新问题