1回答
我有下面的芹菜配置 broker=os.environ.get('CELERY_BROKER_URL', 'redis://'),def process_task(data):我在像process_task.delay(data)这样的API端点内部调用进程任务有时它在处理任务，有时不是。
有人
浏览 7提问于2019-11-07得票数 0
1回答
两个请求之间的Django处理栏
、、、、
我有一个计算密集型的应用，它需要投入和处理大约10-15个公式的输入，包括NPV，IRR类计算。我正在使用django中的模板标记实现计算。因此，我正在寻找一个处理栏(在Django中我无法获得一个好的教程)或优化这些计算的方法。
谢谢各位！这意味着很多！如果您有任何解决方案，请帮助！
浏览 6提问于2022-01-07得票数 0
1回答
因此，我有一个Django中间件调用芹菜任务。此任务查询GeoIP2数据库以确定给定的IP地址并执行一些附加处理。在简化形式中，芹菜任务如下所示：def dump_json_logs(self, data):
location问题是，这个芹菜任务可能每秒被调用数千次，这将导致每次处理任务时都</em
浏览 9提问于2020-04-30得票数 0
回答已采纳
我希望Django成为生产者；向远程RabbitMQ框和另一个侦听RabbitMQ队列中的任务的芹菜盒生成消息。所以总共会有三个盒子。Django，RabbitMQ和芹菜。到目前为止，从芹菜文档中，我已经成功地在另一台机器上成功地运行了Django和芹菜以及兔子MQ。Django只在视图中调用该任务：并将消息发送到RabbitMQ。RabbitMQ将其发送回任务所在的同一台机器(因为Django和芹菜共享相同的框)，<
浏览 0提问于2014-04-09得票数 0
回答已采纳
1回答
我有一个导入成本很高的模块(它需要下载一个~20MB的索引文件)，它是由芹菜工人使用的。不幸的是，我不知道如何让模块只导入一次，并且只由芹菜工人导入。shared_task: import expensive_module在这个版本中，web服务器从不导入模块(这很好)，但每次调用在此场景中，为什么每次celery worker运行此函数时都会重新导入模块？我如何重新组织这段代码，让芹菜工人只导入昂贵的模块，并且只
浏览 2提问于2015-08-11得票数 1
Problem：client.insert_rows_json吞吐量不是很好，每次请求都需要0.5到1.5秒，这对我的应用程序性能非常不利。解决方案：使用芹菜任务异步运行client.insert_rows_json方法。我可以写一个简单的任务：def stream_bq_row(table_id, log):
client.insert_rows_json(table_id每天使用芹菜10K任务是否合理？
浏览 8提问于2022-06-22得票数 0
2回答
姜戈芹菜
、、、
我正在构建一个应用程序，我每天都在尝试运行一些任务。所以我看到了一些关于using celery的答案、博客和教程，所以我喜欢用芹菜做背景工作的想法。但我有一些关于芹菜的问题 :-
正如中提到的，在设置了一个芹菜任务之后，我必须运行一个像celery -A proj worker -l INFO这样的命令，它将处理所有的任务，然后它将运行这些任务，所以我的问题是我应该每次运行命令，还是可以先执行这个命令，然后才能启动服务器？如果我<e
浏览 1提问于2021-10-10得票数 0
我有一个Django项目，我正在尝试使用Celery提交任务以进行后台处理( )。Celery与Django集成得很好，我已经能够提交我的自定义任务并返回结果。在开始处理任务之前，我需要调用一个加载大量内存的昂贵函数，而且我不能每次都调用这个函数。谢谢
浏览 0提问于2010-01-25得票数 22
回答已采纳
我有一个芹菜shared_task，计划在一定的时间间隔运行。每次运行此任务时，都需要首先从Django DB检索数据，以便完成计算。这个任务可能发送也可能不会发送给单独机器上的芹菜工人，因此在芹菜任务中，我不能对本地芹菜数据库进行任何查询。到目前为止，我已经尝试使用信号来完成它，因为我知道在任务发布到消息队列之前就已经执行了带有包装器@before_task_publish的函数。但是，我不知道如何才能将数据实际用
浏览 17提问于2022-03-23得票数 0
回答已采纳
1回答
许多流行的任务队列(如Google、TaskQueue、芹菜)都具有ETA/倒计时功能，允许在xxx秒后将任务放到队列中。我们的系统每秒钟有600-2000个任务，其中大约10%需要ETA.它是一个分布式系统，性能至关重要。我试图追踪芹菜的来源，但找不到处理ETA的
浏览 4提问于2016-10-02得票数 1
回答已采纳
手头的任务：23 EMAIL {....... } 2013-02-01 UNPROCESSED
使用一个脚本来获取N个记录进行处理，然后对它们进行处理，然后更新已处理记录的状态。如何使用芹菜实现相同的功能，我想使用相同的功能来标记任务<
浏览 3提问于2013-03-29得票数 8
回答已采纳
我正在使用芹菜来满足我的项目需求。目前，我已经创建了一个队列'HighPriorityQueue‘和默认队列，也就是说，将有一个单一的worker和两个队列。我的疑问是，芹菜将如何处理这些队列？celery会并行处理队列吗？或者，我可以这样做吗?如果某个任务在'HighPriorityQueu
浏览 0提问于2013-03-04得票数 3
1)我目前正在开发一个web应用程序，该应用程序公开一个REST，并使用Django和芹菜来处理请求并解决它们。为了解决请求，必须向amqp队列提交一组芹菜任务，以便在工人(位于其他机器上)上执行这些任务。每项任务都是非常密集的CPU，需要很长时间才能完成。我已经配置了芹菜也使用amqp作为结果后端，我使用RabbitMQ作为芹菜的经纪人。
每个任务都返回一个结果，需要随后存储在DB中，而不是由工作
浏览 1提问于2013-02-06得票数 7
回答已采纳
TL;DR
有没有办法判断我们的芹菜工人是不是要关机了？换句话说，我可以检查是否有一个SIGTERM挂起吗？我有一项任务需要重新安排时间，但是如果有关机等待以避免延迟关闭，我想避免重新安排自己的时间。我最初使用的是一种非常细致的芹菜作息时间来启动任务，但是如果我只做了少量的工作，比如完成10秒钟，那么我想立即重新启动任务几次，以避免等待下一个芹菜节拍到来的50秒，因为新的工作很可能会在这段时间内出现所有这些都是为了最小化正在处理的工作项的延迟。我想避免
浏览 0提问于2016-05-11得票数 6
回答已采纳
1回答
我正在尝试使用芹菜3.1从自定义管理命令运行一个任务。要在命令行上获得异步任务处理，需要向管理命令中添加什么？
浏览 0提问于2015-12-16得票数 1
回答已采纳
1回答
我有一个设置与多个服务器运行我的酒瓶应用程序和芹菜工人。Flask路由处理本地的文件上载，并将芹菜任务排队以将该文件上传到CDN。如何确保芹菜任务运行在处理Flask路由的同一个节点上？
浏览 2提问于2015-08-28得票数 2
我使用Redis broker和数据库结果后端( Postgres DB )运行Django芹菜，这与我在主应用程序中使用的相同。在这种情况下，即使DB返回并且主Django站点正常响应，也没有芹菜任务再次成功。在进行任何处理之前，我需要重新启动celeryd进程。所有芹菜任务都报告了相同的错误：SSL connection hasbe
浏览 2提问于2013-08-14得票数 3
回答已采纳
我需要从用户发送带有定时任务的电子邮件class crontabMail(models.Model):
to=models.CharField(max_length=60
浏览 0提问于2019-04-26得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
