celery 相关问题

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

我有一个非常简单的实现。 /lib/queue/__init__.py从celery导入芹菜从os导入环境REDIS_URI = environ.get（'REDIS_URI'）app = Celery（'tasks'，broker = f'redis：/ ...

python docker celery

回答 1 投票 0

在Celery任务中使用GeoIP进行地理定位的正确方法

所以，我有一个调用Celery任务的Django中间件。此任务查询GeoIP2数据库以对给定IP地址进行地理定位并执行一些其他处理。简化形式是芹菜...

python django celery geoip

回答 1 投票 0

Celery + SQS两次接收相同的任务，同时具有相同的任务ID

在flask应用程序中使用带有SQS的芹菜，但是芹菜同时接收到两次具有相同任务ID的相同任务，像这样运行工人，芹菜工人-A app.jobs.run -l info --pidfile = / var / run /芹菜/ ...

flask celery amazon-sqs celery-task

回答 1 投票 6

Celery：如何以可靠且可测试的方式获取队列大小

我很想寻找一种可靠且可测试的方法来获取给定的Celery队列中包含的任务数，这使我失去了头脑。我已经阅读了这2个关于SO的讨论：Django Celery获取任务计数（...

python unit-testing redis celery

回答 2 投票 0

Heroku（Django）上的redis_url的字符串，而不是urlparse.ParseResult

非常感谢有经验的人将redis配置为heroku上的芹菜经纪人django项目的后端的经验。我的任务调度在本地主机上运行良好，但是我发现...

django heroku redis celery

回答 3 投票 1

celery .delay为该任务冻结，但为其他任务运行

我正在尝试使用芹菜发送通知。 @shared_task（name ='send_notifis'）def send_notifs（device_ids，title，message）：从药丸_reminder.models导入UserNotifications，UserDevice ...

django celery celery-task

回答 1 投票 0

如何在Django中启动和停止芹菜拍子和工人？

我每30秒从API中获取一些数据，并定期插入mongoDB。因此，我使用芹菜在后台对其进行处理。 celery.py如下：@ app.on_after_configure.connect def ...

python django celery periodic-task

回答 1 投票 0

芹菜一次调用多任务

我正在使用celery来实现异步任务，但是我有大量的异步任务，因此必须多次调用task_func.delay（），我的代码如下：注册的任务：@ app.task（）def task1 ... ...

celery celery-task

回答 1 投票 0

如何杀死芹菜中正在运行的任务？

我正在python中使用Celery。我有以下任务：@ app.task def data（）：而1：响应= request.get（url，timeout = 300）.json（）db.colloectionName.insert_many（response）...

python task celery

回答 2 投票 0

Celery：损坏的状态有效负载。可能的原因？装饰__call __（）方法的原因？

我正在尝试诊断此问题，但是如果有人看到过类似的东西，我想把这个问题扔出去。本质上，我看到的是AsyncResult（task_id），返回状态为...

python celery iasyncresult

回答 1 投票 0

组中的Celery运行任务链

我正在尝试将Celery作为任务管理来运行，并且在组中运行多个任务时遇到了麻烦。组中的所有任务完成后，我想收集结果。工作流程有效...

python celery celery-task

回答 1 投票 2

Celery从数据库运行签名（AttributeError：对象没有属性'oid'-> opts ['reply_to'] = self.app.oid）

python-3.x celery

回答 1 投票 1

如何监视各个芹菜任务的内存使用情况？

我想知道celery任务的最大内存使用情况，但是从文档中，没有一个celery监视工具提供内存使用功能。如何知道一个任务有多少内存...

celery python-multiprocessing celery-task celeryd

回答 1 投票 1

芹菜工作者节点到底是什么？

是运行Celery的实际处理器还是其他进程？在花中，我可以看到一个工人池中有多个流程吗？两者之间有什么区别？

celery

回答 2 投票 3

如何使用Python Celery在不同的服务器上执行任务？

假设我有三个服务器A，B和C。服务器C将具有celery任务代码，我需要从服务器A和B中执行它们。从celery文档中，我看到有一个task.py .. 。

python celery

回答 1 投票 0

[每位孩子最大任务数]在Celery中到底是什么意思？

文档为：使用此选项，您可以配置工作人员在被新流程取代之前可以执行的最大任务数。在什么情况下可以用新流程替换工人？...

python-3.x celery

回答 1 投票 0

Celery检查任务在执行之前在队列中等待了多长时间

是否可以在不通过触发它的方法传递时间参数的情况下签入任务函数，让我说我有@task（name =“ example.task.task1”）def task1（arg1，arg2）：＃我想要到...

celery django-celery

回答 1 投票 0

减少芹菜任务记录

我们使用Celery在我们的Python Django应用程序中管理任务。我们还将Django structlog用于Celery打印的日志消息。我们通过Logstash将这些消息摄取到ElasticSearch，并注意到...

elasticsearch celery elastic-stack django-celery

回答 1 投票 0

如何在Docker上运行的Apache Superset中配置Celery Worker进行电子邮件报告？

python python-3.x docker celery apache-superset

回答 1 投票 0

如何在芹菜中使用“ -b”

每个人。我对celery的参数“ -b”有问题，我在celery文档中找到了它：-b，--broker celery命令行选项，但是当我这样使用时似乎没有生效，...

celery

回答 1 投票 0

celery 相关问题

最新问题