标签：celery
-
Celery REST API - python
有没有办法将Celery用于以下用途： 使用Form参数将对外部URL的HTTP调用排队（HTTP Post to网址）外部URL将响应HTTP响应，200、404、400等，如果响应采用错误非200 ish响应的形式，将重试重试一定次数，并将根据需要退出使用REST API将Task / Job / Work队列添加到Celery，将URL传递给cal […]
-
气流-Python文件不在同一DAG文件夹中 - python
我正在尝试使用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
如何创建使芹菜任务看起来像asyncio.Task的包装器？还是有更好的方法将Celery与asyncio集成？ @ asksol，Celery的创建者said this:: 使用Celery作为异步I / O框架之上的分布式层是很常见的(提示:将CPU绑定的任务路由到prefork worker意味着它们不会阻塞事件循环)。 但是我找不到任何专门针对asy […]
-
Celery与RabbitMQ:AttributeError:'DisabledBackend'对象没有属性'_get_task_meta_for' - python
我正在运行First Steps with Celery Tutorial。 我们定义以下任务: from celery import Celery app = Celery('tasks', broker='amqp://guest@localhost//') @app.task def add(x, y): ret […]
-
AttributeError:“Flask”对象没有属性“user_options” - python
我正在尝试通过以下文档设置此基本示例: 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
我有一个带有virtualenv的现有Django项目。激活venv之后，我可以仅使用celery命令运行Celery。这适用于Windows，OS X和Linux。 我想在Windows上尝试PyCharm，并且能够使其运行Django服务器(使用项目的venv)，但是我也想运行Celery，因此也可以对其进行调试。 我找不到设置PyCharm的简单明了的 […]
-
如何停止芹菜工作者进程 - python
我在Ubuntu EC2节点上有一个Django项目，我一直在使用Celery设置异步项目。 我正在关注this和文档。 我已经可以使用以下命令在命令行上执行基本任务: (env1)ubuntu@ip-172-31-22-65:~/projects/tp$ celery --app=myproject.celery:app worker --loglevel […]
-
如何在每个任务都有单独队列的情况下运行芹菜节拍？ - python
我有一个包含多个celery beat任务的Django项目，当我有多个具有独立队列的celery beat任务时，我有一个问题，因此我有可能一次运行所有这些任务吗，运行这些任务的最佳实践是什么？ from __future__ import absolute_import, unicode_literals import os from celery im […]
-
创建芹菜任务的不同方法之间的区别 - python
通过查看创建芹菜任务的不同方法，我感到非常困惑。从表面上看，它们都是一样的，所以，有人可以解释一下两者之间的区别是什么。 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
我正在使用Flask和Celery构建Web服务器。我最初使用两个终端启动它们。这很烦人，因为它减慢了调试速度（启动启动，停止停止等），并且意味着我有两个日志流。然后，我切换到使用multiprocessing模块从Flask中启动Celery。这不是最佳选择，因为multiprocessing不能与Flask的重新加载功能一起使用，但是很好，因为我的所有日 […]