Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Celery 任务分析
正如我所看到的top公用事业celery进程消耗大量CPU时间 所以我想介绍一下它 我可以在开发人员机器上手动执行此操作 如下所示 python m cProfile o test date Y m d T prof manage py c
python
profiling
Celery
djangocelery
使用 Flask 和 SQLAlchemy 在 Celery 任务中未更新数据库
我正在使用 Flask 和 SQLAlchemy 编写 Web 应用程序 我的程序需要在后台处理一些内容 然后将这些内容标记为在数据库中已处理 使用标准 Flask Celery 示例 http flask pocoo org docs 0
python
Flask
sqlalchemy
Celery
SQLAlchemy 与 celery 的会话问题
我已经为我们的网络应用程序安排了一些使用 celerybeat 重复执行的任务 该应用程序本身是使用金字塔网络框架构建的 使用 zopetransaction 扩展来管理会话 在 celery 中 我将该应用程序用作库 我正在使用函数重新定
sqlalchemy
Celery
pyramid
InterfaceError:连接已关闭(使用 django + celery + Scrapy)
当我在 Celery 任务中使用 Scrapy 解析函数 有时可能需要 10 分钟 时 我得到了这个信息 我用 姜戈 1 6 5 django celery 3 1 16 芹菜 3 1 16 psycopg2 2 5 5 我也使用了psyc
python
django
Scrapy
Celery
Celery 设计帮助:如何防止并发执行任务
我对 Celery AMQP 相当陌生 正在尝试提出一个任务 队列 工作人员设计来满足以下要求 我有多种类型的 每用户 任务 例如 TaskA TaskB TaskC 这些 每用户 任务中的每一个都为系统中的一个特定用户读取 写入数据 因此
python
rabbitmq
Celery
AMQP
使用 Celery 时出现错误消息“无法找到记录器“多处理”的处理程序”
RabbitMQ http en wikipedia org wiki RabbitMQ现在似乎工作正常 然而 当我尝试 python m celery bin celeryd loglevel INFO 常规的celeryd不起作用 我收
python
logging
rabbitmq
Celery
如何在 Apache Airflow 中混合使用 Celery Executor 和 Kubernetes Executor?
我有多个使用 Celery Executor 的 dag 但我希望使用 Kubernetes Executor 运行一个特定的 dag 我无法推断出一种良好且可靠的方法来实现这一目标 我有一个airflow cfg我在其中声明了Celery
python
python3x
Kubernetes
Celery
airflow
无法在 Windows 10 上启动 Celery Worker,并出现“PicklingError”
我有一个简单的测试代码 可以在 Linux 上成功运行 但它无法在我的 Windows 10 x64 计算机上运行 当我尝试启动 celery Worker 时 它抱怨无法恢复的错误 PicklingError 芹菜版本 3 1 20 在我
python
python27
Celery
如何使用 Celery 和 Django 将任务路由到不同的队列
我正在使用以下堆栈 Python 3 6 芹菜 v4 2 1 经纪人 RabbitMQ v3 6 0 姜戈 v2 0 4 根据芹菜的文档 http docs celeryproject org en latest userguide rou
django
python3x
Celery
python36
djangocelery
无法从 celery 信号连接到 celery 任务?
我正在尝试连接task2 from task success signal from celery signals import task success from celery import Celery app Celery app t
python
Celery
weakreferences
djcelery
创建一个等待信号的 Celery 任务?
是否可以创建只等待信号的 Celery 任务 我有这样的场景 远程机器 A 上的一个 virtualenv 中的 Scrapyd 远程计算机 A 上另一个 virtualenv 中具有 Celery 工作节点的 Django 项目 与 Ce
Celery
Celery - 在一台服务器上运行不同的工作人员
我有两种任务 Type1 一些高优先级的小任务 Type2 大量优先级较低的繁重任务 最初 我使用默认路由进行了简单配置 没有使用路由键 这还不够 有时所有工作人员都忙于类型 2 任务 因此任务 1 被延迟 我添加了路由键 CELERY D
django
Celery
使用 Mandrill send_at 或 Celery countdown/eta 延迟发送电子邮件
我通常会发送交易电子邮件来响应我网站上的某些操作 其中一些我会延迟几个小时发送 实际对电子邮件进行排队的函数是一个 Celery 任务函数 调用方式为 delay 最终使用 Mandrill 进行 API 调用djrill https dj
python
django
Celery
delayedjob
mandrill
在 Celery 中,我如何运行一个任务,然后让该任务运行另一个任务,并保持下去?
tasks py from celery task import Task class Randomer Task def run self kwargs run Randomer again return random randrange
python
django
datastructures
Asynchronous
Celery
如何向用户提供有关 Celery 任务执行状态的持续通知?
我以这种方式将我的项目与芹菜集成在一起 在里面views py收到用户请求后 def upload request if POST request method save the file task parse delay continue
python
django
Asynchronous
djangoviews
Celery
celerybeat 和 sqlalchemy + 金字塔应用程序出现“ResourceClosedError:事务已关闭”错误
我有一个名为的金字塔应用程序mainsite 该站点以相当异步的方式工作 主要是通过从视图启动线程来执行后端操作 它使用 sqlalchemy 连接到 mysql 并使用 ZopeTransactionExtension 进行会话管理 到目
sqlalchemy
Celery
pyramid
celery任务eta已关闭,使用rabbitmq
我使用教程中的默认设置和在 ubuntu 上运行的rabbitmq 使 Celery 任务正常进行 当我毫不延迟地安排任务时 一切都很好 但是当我给他们一个预计时间时 他们会被安排在未来 就好像我的时钟在某个地方关闭了一样 下面是一些请求任
python
rabbitmq
Celery
djangocelery
Django Celery 和多个数据库(Celery、Django 和 RabbitMQ)
是否可以设置与 Django Celery 一起使用的不同数据库 我有一个配置了多个数据库的项目 并且不希望 Django Celery 使用默认数据库 如果我仍然可以使用 django celery 管理页面并读取存储在这个不同数据库中的
django
rabbitmq
Celery
djangocelery
运行连接到 Django 测试数据库的 Celery Worker
背景 我正在开发一个项目 该项目使用 Celery 来安排将在未来某个时间运行的任务 这些任务推动最终状态机的状态向前发展 这是一个例子 未来的提醒计划在 2 天内发送给用户 当该计划任务运行时 会发送一封电子邮件 并且 FSM 会前进到下
python
django
Multithreading
Testing
Celery
celery 中 @task 装饰器之后的装饰器
我正在尝试在 celery task 装饰器之后应用装饰器 类似的东西 send email task def any function print inside the function 我可以让它按照文档中建议的方式工作 即将装饰器放在
python
Celery
decorator
djangocelery
1
2
3
4
5
6
...15
»