1回答
我有一个Flask应用程序，我正在使用Celery(v5.1.2)和SQLAlchemy来与我的工作人员一起运行后台任务。 这就是我如何创建我的芹菜工人。task_serializer='json', include=['my_blueprints.profile']) 它可以很好地初始化和运行我的任务当我尝试使用以下命令读取结果</e
浏览 43提问于2021-10-24得票数 1
回答已采纳
我正在通过after_insert活动启动芹菜任务。我还有别的选择吗？我想我可以以某种方式把这些芹菜任务收集起来，只发送到"after_commit“上，但感觉没有必要复杂。
浏览 2提问于2014-08-01得票数 0
回答已采纳
我试图在heroku上部署一个烧瓶应用程序，在芹菜中使用背景任务。我已经实现了，这样芹菜过程就不会绑定到烧瓶应用程序的任何一个实例。
这在本地工作，我还没有看到一个错误。但是，当部署到heroku时，总是会出现相同的结果:芹菜任务(我只使用一个)在第一次运行时就成功了，但是后续对该任务的任何芹菜调用都会在sqlalchemy.exc.DatabaseError: (psycopg2
浏览 3提问于2017-07-20得票数 3
回答已采纳
1回答
烧瓶-芹菜制作的点滴表
、、、、
我集成了芹菜，并将其结果后端配置为相同的postgresql数据库。在烧瓶应用程序中使用的其他表在代码中有类定义，并使用alembic (烧瓶-迁移)生成：
是否有一种方法可以重写/继承芹菜创建的表，以便通过迁移手动生成它们？也就是说，我创建了一个自定义任务表，它继承了芹菜任务表，然后执行迁移来
浏览 1提问于2020-12-30得票数 3
回答已采纳
有一个关于SQLAlchemy的章节，但是Django不使用SQLAlchemy。最近的芹菜/ Django版本是否可能只使用数据库来存储消息/结果？
浏览 3提问于2022-10-08得票数 0
我使用的是SQLAlchemy模型(从sqlalchemy.ext.declarative.declarative_base派生)和烧瓶-SQLAlchemy。当我尝试执行任何芹菜任务时(只是空的)def empty_task():在普通烧瓶视图中def viewat 0x7f6d67e37b50> is not bound to a Session; attribu
浏览 0提问于2015-05-20得票数 1
回答已采纳
1回答
我对芹菜使用Flask-SQLAlchemy。如果Celery任务花费了很长时间，那么这两个任务就不能很好地配合使用，因为当提交任务完成时，MySQL连接将超时并“消失”。是否可以对SQLAlchemy对象进行更改，尝试提交，并在失败时打开一个新会话，将对象附加到新会话，然后提交它们？如果是这样的话，是怎么做的？什么样的SQLAlchemy函数可以做到这一点？或者，现在提交失败了，因为会话消失了，是
浏览 19提问于2020-02-19得票数 0
回答已采纳
根据我的理解，Flask-SQLAlchemy在Flask请求开始时连接到数据库，并在完成后断开此会话。但是如果这个请求需要很长时间呢？例如，我的应用程序接受一个POST请求，该请求启动一个需要写入数据库的长时间运行的Celery任务。MySQL服务器在一段时间后“消失”，使得在任务结束时写回数据库的操作不起作用。我在网上阅读了设置options["pool_pre_ping"] = True来缓解这样的问题(使用子类化SQLAlchemy解决方法找
浏览 95提问于2020-01-13得票数 0
回答已采纳
1回答
我有一个网络应用程序，我试图使用芹菜从数据库加载后台任务。我目前正在按要求加载数据库，但希望每隔一小时加载一次任务，并让它们在后台工作。我用的是烧瓶，编码用的是python.I，我也在运行红灯。到目前为止，我已经用芹菜让工人去处理任务，让拍子把任务隔一段时间发送给工人。但是，我希望从工作人员检索结果、数据或查询，如果结果尚未准备好，则应该加载工作人员的前一个结果。我<e
浏览 5提问于2016-09-07得票数 9
回答已采纳
1回答
如何在芹菜延迟任务中使用sqlalchemy模型？
看起来芹菜有这个选项，但是我找不到一个如何使用它的例子。
浏览 2提问于2013-02-26得票数 1
回答已采纳
根据的说法，SQLAlchemy broker与“多个”工作者有问题，可能会多次执行任务。我还没有找到关于这方面的更准确的信息。数据库的选择重要吗？
浏览 1提问于2012-11-29得票数 3
1回答
目前，我使用Django和芹菜执行任务。可以很容易地在芹菜中使用Django的ORM，而对代理使用SQS。我的问题是，如果不使用Django ORM访问我的MySQL数据库，并且仍然访问SQS，我如何单独继续使用芹菜？我只想访问数据来处理任务(获取用户等等)。我读了下面的内容：
但这更多的是为了让SQLAlchemy或Django成为经纪人--我不想这么做。我只想访问这些数据。
浏览 2提问于2014-03-25得票数 1
回答已采纳
在此之前，我使用来集成芹菜和Flask。虽然它有很多问题，比如隐藏了一些强大的芹菜功能，但它允许我使用Flask应用程序的完整上下文，特别是Flask-SQLAlchemy。在我的后台任务中，我正在处理数据，并使用SQLAlchemy对象关系映射来存储数据。Flask-Celery的维护者已经放弃了对该插件的支持。插件在任务中对Flask实例进行了酸洗，这样我就可以完全访问SQLAlchemy了。
我正尝试在我的ta
浏览 2提问于2012-08-21得票数 49
回答已采纳
1回答
用芹菜调用API
、、、、
我让所有单独的组件都能很好地工作(可以上传文件、读取文件、调用API、可以写到db等等)，但我不确定使用芹菜分派任务的总体架构。创建N个芹菜任务，并将对象id作为参数和有效载荷传递让芹菜的重试特性在失败的情况下再次调用API。选项B:创建1个芹菜任务，
浏览 0提问于2015-04-26得票数 8
1回答
我的Docker应用程序以Flask作为后端，芹菜作为异步任务管理器运行。然后，将任务结果转储到Postgres拥有的SQLalchemy数据库中。 depends_on: - rediscelery_1| Neither SQLALCHEMY_DATABASE_URInor
浏览 2提问于2019-04-19得票数 4
回答已采纳
我有一个长时间运行的任务，它更新一些SQLAlchemy对象。在任务开始时打开会话，在此过程中进行更新，并在结束时提交事务。问题是任务运行了很长时间，所以在提交之前，连接就已经关闭了(超时，“消失”，不管你想怎么叫它)。这将导致提交失败，整个任务也会失败。有没有其他推荐的模式？Celery任务是否应
浏览 43提问于2020-02-11得票数 0
回答已采纳
1回答
我需要建立一个系统来处理两种类型的任务。一种类型可以自己创建更多任务，也可以创建另一种类型的任务。将有很少的工人(2-3)和只有一个主机。最重要的要求是系统应该很好地处理重新启动:即在重新启动时，正在进行的任务应该从头开始，而工作人员应该在重新启动之前收集排队的任务。从芹菜的角度看，它似乎适合这个用例。然而，我有几个问题：2)在这种情况下，最
浏览 0提问于2015-04-20得票数 15
回答已采纳
摘要:我想在芹菜任务中使用sqlalchemy会话，而不需要包含该会话的全局变量。我在一个有芹菜任务的项目中使用SQLAlchemy，而且我有class DBTask(Task):
def after_return(sel
浏览 0提问于2015-08-13得票数 15
回答已采纳
1回答
1)芹菜链。这里是一个简单的链，第一个任务执行，将其返回值传递给链中的下一个任务，依此类推。chain
>>> res = chain(add.s(2, 2), add.s(4), add.s(8))()16这对我来说很重要，因为我的<em
浏览 1提问于2016-11-19得票数 1
回答已采纳
1回答
芹菜撤销留下僵尸
、、、
我们用芹菜，兔子和蟒蛇来读取视频流。在芹菜任务(共享任务)中，我们调用ffmpeg-python，它在内部使用子进程运行ffmpeg。每当我们在芹菜中撤销任务()时，ffmpeg进程就变成了失效/僵尸。随着时间的推移，他们开始积累和耗尽我们的pids。有没有办法优雅地退出芹菜任务及其子过程？
浏览 8提问于2020-10-14得票数 0
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
