Celery 任务总是 PENDING
我尝试在带有 redis 后端的 Windows 上运行 Celery 示例.代码如下: from celery import Celeryapp = Celery('risktools.distributed.celery_tasks',后端='redis://localhost',broker='redis://localhost')@app.task(ignore_result=False
..
celery相关内容
让芹菜等待任务完成
我希望 celery 等待特定任务完成，因此我在 celery 本身旁边安装了 celery-results-backend.但我不明白我必须如何编写任务调用才能等待，因为我目前收到以下错误: example_task() 缺少 1 个必需的位置参数:'user_pk' views.py: def 示例(请求):用户 = request.user如果 request.method == 'G
..
如何使用 Completed_count 跟踪 Celery 中的任务组完成情况?
我正在尝试使用“completed_count()"来跟踪 Celery 中一个组中剩余的任务数. 我的“客户"运行这个: 来自芹菜进口组从项目导入做单词列表=[]使用 open('word.txt') 作为 wordData:对于 wordData 中的行:wordList.append(line)readAll = group(do.s(i) for i in wordList)结果
..
未应用 Django Celery 更改
我的 django-celery 代码无法重新加载，我在看到一个据称已解决的错误后得出结论.谁能告诉我如何正确重启我的 Celery 服务器，或者问题是否仍然存在? 顺便说一下，在 Windows 10 上运行. 文件结构 |-- manage.py|-- nttracker\|-- celery.py|-- 任务.py|-- 设置.py 我还没有添加任何单独的配置文件. n
..
使用 django celery 在 redis 上丢失连接时仅执行部分任务
我有一个仅部分执行的 django celery 任务. 我启动了应用程序并且连接看起来不错: INFO/MainProcess] 连接到redis://elasticache.cache.amazonaws.com:6379/0 [2018-02-1723:27:24,314:INFO/MainProcess] 混合:搜索邻居[2018-02-17 23:27:25,339: INF
..
ModuleNotFoundError:Windows 上没有名为“grp"的模块
当我从 Celery 文档中查看 Celery 实现时， celery -A 任务 worker --loglevel=INFO 给出了来自文档的意外输出， 文件“d:\101_all_projects\celery-testing\venv\lib\site-packages\celery\platforms.py"，第 9 行，在导入 grp ModuleNotFoundError:
..
运行时警告:您正在以超级用户权限运行工作程序:绝对不推荐这样做
我在本地使用 django+celery+redis,celery==4.4.0 它工作正常，但是当我对它进行 dockerizing 时，出现上述错误. 我使用以下命令在本地和容器内运行 **CMDs**celery -A nrn worker -l 信息docker run -d -p 6379:6379 redis花 -A nrn --port=5555 非常感谢任何帮助 *
..
Celery 广播与 RabbitMQ 扇出
我最近一直在使用 Celery，但我不喜欢它.它的配置凌乱、过于复杂且文档不全. 我想使用 Celery 从单个生产者向多个消费者发送广播消息.令我困惑的是 Celery 术语与底层传输 RabbitMQ 术语之间的差异. 在 RabbitMQ 中，您可以有一个 fanout Exchange 和多个队列广播消息: 但是在 Celery 中，这些术语都搞砸了:在这里你可以有一个
..
为什么我的 Airflow 任务排队但没有运行?
我是气流的新手，正在尝试设置气流来运行 ETL 管道.我能够安装 气流 postgres 芹菜 rabbitmq 我能够测试运行教程 dag.当我尝试安排作业时，调度程序能够选取它并将我可以在 UI 上看到但任务没有运行的作业排队.有人可以帮我解决这个问题吗? 这是我的配置文件: [核心]airflow_home =/root/airflowdags_folder =/r
..
特定时间的Django Celery定期任务
我在项目中使用的是 celery == 4.1.1 .在我的 settings.py 中，我有以下内容: 从celery.schedules中的 导入crontabCELERY_BROKER_URL ="redis://127.0.0.1:6379/1"CELERY_TIMEZONE ='亚洲/加尔各答'CELERY_ACCEPT_CONTENT = ['application/json']C
..
Django导出功能和Celery任务
我想使用Celery来异步运行我的任务，但是我遇到了一些麻烦.我想通过导出方法创建一个数据文件. 上下文: 用户可以将搜索结果导出到.xlsx文件中.但是有2种情况: 搜索包含少于70.000行.这样，用户可以直接使用 HttpResponse 下载生成的输出文件. 搜索包含70.000多行.在这种情况下，文件为由于使用Celery任务，因此可以将其写入媒体文件夹.这样，即使请
..
Celery + Django在Elastic Beanstalk上导致错误:& lt; class' xmlrpclib.Fault'& gt;< Fault 6:' SHUTDOWN_STATE'>
我已经在AWS Elastic Beanstalk上部署了Django 2应用程序.我配置了Celery，以便在同一台计算机上执行异步任务.自从我添加Celery以来，每次我重新部署应用程序 eb部署myapp-env 时，都会出现以下错误: 错误:[实例:i-0bfa590abfb9c4878]命令在实例上失败.返回码:2输出:(TRUNCATED)...错误:已关闭错误:
..
我如何知道Django代码中芹菜后台处理是否成功.如果成功，我要呈现一个html页面
我无法执行此操作，因为Django代码中没有当前正在运行的后台进程的状态. 请求:我需要知道celery后台任务的状态并从那里渲染html页面 @ task_success.connectdef task_sent_handler3(sender = None，result = None，** kwargs):#有关任务的信息位于任务消息的标题中#使用任务协议版本2.#info =标头(
..
强制停止芹菜工作者作为系统服务运行
重新启动服务器时如何杀死工作程序，并获得与以下语句相同的效果: pkill -9 -f'芹菜工人' 来自芹菜文档: 如果工作人员在经过适当的时间后不会因陷入无限循环或类似原因而关闭，则可以使用KILL信号强制终止工作人员: 但是我是作为systemd服务启动的，并具有以下配置以使用以下systemd单元文件启动它: [单位]Description =芹菜服务之后= netw
..
Celery:确保工作人员不只运行一个用户的作业
我有4位芹菜工人，并发率为6. 我有用户提交不同数量的作业(从1到20). 如何确保每个用户的作业获得相同的处理时间，并且确保一个用户的作业不会填满队列，从而迫使其他用户的作业等待. 恐怕如果工人最终要完成第一个用户提交的所有工作，那么其他用户排队的工作必须等待第一个用户完成，这给您带来不便. 有没有一种方法可以使芹菜工作者意识到一个用户的工作阻止了另一个用户的工作.相反，
..
python芹菜-get()被延迟
我正在运行以下简单示例.使用一个工作人员提交20个工作，每个工作需要2秒: celery-一个celery_test worker --concurrency 10 -l INFO 这应该花费2 * 2 = 4秒.这对于工作人员处理数据是正确的.但是，获取数据会增加6秒的延迟. 有什么想法可以消除这种延迟吗? 有关脚本和输出，请参见以下内容: celery_call.py
..
Celery不将任务排队到远程服务器上的代理，而是将任务添加到本地主机
celery.py #设置"celery"程序的默认Django设置模块.os.environ.setdefault('DJANGO_SETTINGS_MODULE'，'project.settings')应用= Celery('项目'，经纪人='amqp://foo:bar @ remoteserver:5672'，后端='amqp')#app =芹菜('项目')#在这里使用字符串意味着工作人
..
使用动态routing_key启动工作程序?
我有一个队列，其中包含几种任务类型，并且我需要为特定任务运行worker.类似于:“芹菜工人--routing_key task.type1 --app = app" 队列配置: CELERY_QUEUES =(Queue列('myqueue'，routing_key ='task.#')，)CELERY_DEFAULT_EXCHANGE_TYPE ='主题' 使用pika任务很容易
..
即使未调用`app.autodiscover_tasks()`，Celery也会发现所有任务
我正在使用 Django == 2.0.5 和 celery == 4.0.2 .我的 proj/proj/celery.py 如下: 来自__future__的 导入absolute_import，unicode_literals导入操作系统从芹菜进口芹菜#为"celery"程序设置默认的Django设置模块.os.environ.setdefault('DJANGO_SETTINGS_MO
..
Ubuntu服务Upstart或SystemD，Django开发服务器即服务
我一直在研究Python&使用Ubuntu 16.01的Django框架已有一段时间.由于我将Django与Q系统(Celery)和其他一些Enhancement Apps一起使用.每次尝试运行所有应用程序时，都需要运行开发服务器"{python manage.py runserver}"，然后运行Celery Worker"{celery -A filename worker -l info}"
..