celery 相关问题

Celery是Python的分布式任务队列框架,用于异步和并行执行。

用于任务划分的多线程芹菜工作者

我目前正在构建一个基于某些输入并运行某些扫描的应用程序。我遇到的问题是某些扫描正在创建瓶颈,我想知道是否存在...

回答 1 投票 1

Django celery beat attributeError:'NoneType'对象没有属性'localize'

根据本教程,我试图让我的Django项目运行定期任务。使用以下命令运行celery beat时:celery -A proj beat -l info -S django我得到以下信息...

回答 1 投票 1

无法通过Airflow Celery worker进行Redis身份验证

我正在尝试使用Redis后端运行Airflow Celery worker,但是无法使该worker和redis之间的连接正常工作。配置如下所示:broker_url = redis://:

回答 1 投票 0

如何使用transaction.on_commit编写Celery组或链

我正在使用django 3.0.2,python 3.6.6,celery 4.3.0和redis服务器4.0.9。我想创建一些链和成组的任务,这些模型在保存模型后运行(transaction.on_commit)。我可以...

回答 1 投票 0

我们如何在Django中创建异步API?

我想创建一个第三方聊天机器人API,该API是异步的,并在暂停10秒后回复“确定”。导入时间def wait():time.sleep(10)返回“确定”#views.py def api(request):...

回答 3 投票 0

如何从Django启动远程芹菜工作者

我正在尝试将芹菜与Django结合使用。因此,我遇到了autodiscover_tasks(),但我不确定如何使用它们。芹菜工人获得其他应用程序添加的任务(...

回答 1 投票 0

在Django中使用Celery Task创建对象(在ViewSet类中)

你好,我遇到了一个我自己无法解决的问题。我试图在create内调用函数create_with_celery,但没有成功。如何使用适当的参数调用create.delay? ...

回答 2 投票 0

如何检查处理芹菜任务的队列

我目前正在将芹菜用于定期任务。我是芹菜新手。我有两个工作人员在两个不同的队列中运行。一种用于慢速后台作业,另一种用于用户在...

回答 1 投票 1

Celery关闭人员,然后重试任务

我需要在celery任务中实现以下逻辑:如果满足某些条件,请关闭当前工作程序并重试该任务。在示例任务上进行了测试:@ app.task(bind = True,max_retries = 1)def ...

回答 1 投票 0

celery-beat KeyError:'scheduler'

我正在为我的Flask应用程序使用celery beat和docker运行定期的celery任务。但是,当我运行容器时,出现以下错误:删除损坏的计划文件'celerybeat -...

回答 1 投票 1

Celery Worker在docker容器中运行时未选择任务

我正面临这个问题,当我在docker容器中运行我的芹菜工人时,它没有选择任务。我正在使用Flask和芹菜。这是我在没有docker celery @ ...的情况下运行它的日志

回答 1 投票 0

Heroku-Redis内存>'maxmemory',在hobby:dev中有20MB的文件,应该为25MB

[因此,我试图在我的Heroku网站上使用芹菜上传使用Redis的文件。我正在尝试上传大小为20MB的.exe类型文件。 Heroku在他们的爱好中说:dev部分,...

回答 1 投票 1

Celery-异常重新引发信息

[对于芹菜,如果我定义以下任务:@ app.task(bind = True)def Cmd(self):self.log.info(f“ Running cmd”)with open(f'/ tmp / nopermission', 'w')作为文件:...我开始做芹菜...

回答 1 投票 0

每分钟的定期任务芹菜

芹菜任务每分钟停止,但是从我开始芹菜的时间开始倒计时。我可以创建一个周期性的任务,该任务将在每分钟的时间(例如在时钟上)执行,而不是...

回答 1 投票 0

Celery预取乘数设置无效

我有一系列运行多个工作程序的服务器。这些是长期运行的任务,需要10分钟到36个小时不等。因此,如果可能的话,我想避免预取,并且要...

回答 1 投票 2

Python中的Celery conf

我已经尝试了很多事情,并且搜索了许多问题,但是我的问题仍然没有解决。我正在使用docker-compose,python celery和rabbitmq,而没有任何其他flask或django框架。我尝试过...

回答 1 投票 0

Celery-TypeError:字节类型的对象不可JSON序列化

因此,我尝试寻找一些答案,例如(在这里,在这里和这里),但是解决方案没有任何意义。我正在发送字节到芹菜。并且由于某种原因,它告诉我在我处于...

回答 1 投票 -1

将大文件传递给Celery进行处理无效

我想将文件保存到AWS S3,并且我正在使用Celery,因为我不想等到函数完成文件写入之后。问题是,当我将其发送到Celery函数时,可以看到它是...

回答 2 投票 1

为什么Celery定期任务仅触发一次功能

我构建了一个小的Web抓取函数,以从Web上获取一些数据并将其填充到我的数据库中,效果很好。现在,我想使用Celery每20秒定期触发一次此功能...

回答 1 投票 0

使用django,芹菜和redis的一项一项任务

我使用django,celery和redis异步启动任务。 #task.py @shared_task def my_task():#任务1的返回值是否为True#test1.py my_task.delay()中的某处#很少出现...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.