标签:celery

  • Celery REST API - python

    时间:2020-8-30

    有没有办法将Celery用于以下用途: 使用Form参数将对外部U​​RL的HTTP调用排队(HTTP Post to网址)外部URL将响应HTTP响应,200、404、400等,如果响应采用错误非200 ish响应的形式,将重试重试一定次数,并将根据需要退出使用REST API将Task / Job / Work队列添加到Celery,将URL传递给cal […]

  • 气流-Python文件不在同一DAG文件夹中 - python

    时间:2020-8-29

    我正在尝试使用Airflow执行一个简单的任务python。 from __future__ import print_function from airflow.operators.python_operator import PythonOperator from airflow.models import DAG from datetime impor […]

  • 如何将Celery与asyncio结合? - python

    时间:2020-8-25

    如何创建使芹菜任务看起来像asyncio.Task的包装器?还是有更好的方法将Celery与asyncio集成? @ asksol,Celery的创建者said this:: 使用Celery作为异步I / O框架之上的分布式层是很常见的(提示:将CPU绑定的任务路由到prefork worker意味着它们不会阻塞事件循环)。 但是我找不到任何专门针对asy […]

  • Celery与RabbitMQ:AttributeError:'DisabledBackend'对象没有属性'_get_task_meta_for' - python

    时间:2020-8-24

    我正在运行First Steps with Celery Tutorial。 我们定义以下任务: from celery import Celery app = Celery('tasks', broker='amqp://[email protected]//') @app.task def add(x, y): ret […]

  • AttributeError:“Flask”对象没有属性“user_options” - python

    时间:2020-8-19

    我正在尝试通过以下文档设置此基本示例: http://flask.pocoo.org/docs/patterns/celery/ 但是到目前为止,我仍然收到以下错误: AttributeError:“Flask”对象没有属性“user_options” 我正在使用芹菜3.1.15。 from celery import Celery def make_cel […]

  • 如何使用PyCharm在本地调试Celery Worker? - python

    时间:2020-8-18

    我有一个带有virtualenv的现有Django项目。激活venv之后,我可以仅使用celery命令运行Celery。这适用于Windows,OS X和Linux。 我想在Windows上尝试PyCharm,并且能够使其运行Django服务器(使用项目的venv),但是我也想运行Celery,因此也可以对其进行调试。 我找不到设置PyCharm的简单明了的 […]

  • 如何停止芹菜工作者进程 - python

    时间:2020-8-16

    我在Ubuntu EC2节点上有一个Django项目,我一直在使用Celery设置异步项目。 我正在关注this和文档。 我已经可以使用以下命令在命令行上执行基本任务: (env1)[email protected]:~/projects/tp$ celery --app=myproject.celery:app worker --loglevel […]

  • 如何在每个任务都有单独队列的情况下运行芹菜节拍? - python

    时间:2020-8-10

    我有一个包含多个celery beat任务的Django项目,当我有多个具有独立队列的celery beat任务时,我有一个问题,因此我有可能一次运行所有这些任务吗,运行这些任务的最佳实践是什么? from __future__ import absolute_import, unicode_literals import os from celery im […]

  • 创建芹菜任务的不同方法之间的区别 - python

    时间:2020-8-7

    通过查看创建芹菜任务的不同方法,我感到非常困惑。从表面上看,它们都是一样的,所以,有人可以解释一下两者之间的区别是什么。 1。 from myproject.tasks import app @app.task def foo(): pass 2。 from celery import task @task def foo(): pass 3。 from c […]

  • 如何启动Flask + Celery应用程序? - python

    时间:2020-7-30

    我正在使用Flask和Celery构建Web服务器。我最初使用两个终端启动它们。这很烦人,因为它减慢了调试速度(启动启动,停止停止等),并且意味着我有两个日志流。然后,我切换到使用multiprocessing模块从Flask中启动Celery。这不是最佳选择,因为multiprocessing不能与Flask的重新加载功能一起使用,但是很好,因为我的所有日 […]