使用SQLAlchemy读取芹菜任务结果时出错
SQLAlchemy是一个Python的ORM（对象关系映射）工具，用于在Python中操作数据库。它提供了一种将关系型数据库中的表和记录映射为Python对象的方式，方便开发人员进行数据库操作。
在使用SQLAlchemy读取芹菜（Celery）任务结果时出错，可能是由于以下几个原因导致的：
- 连接错误：检查数据库连接是否正确设置，包括数据库地址、端口、用户名、密码等信息。确保数据库服务器正在运行，并且能够通过网络访问。
- 表或字段不存在：确认读取任务结果所需的表和字段是否存在于数据库中。如果不存在，可以使用SQLAlchemy提供的工具来创建相应的表结构。
- 数据库权限问题：检查数据库用户是否具有足够的权限来执行读取操作。确保数据库用户具有读取任务结果所需的权限。
- 数据库版本不兼容：确认所使用的数据库版本是否与SQLAlchemy兼容。有时，使用较新版本的SQLAlchemy可能不兼容较旧的数据库版本。
针对这个问题，腾讯云提供了一系列与数据库相关的云产品，包括云数据库SQL Server、云数据库MySQL、云数据库PostgreSQL等。你可以根据自己的需求选择适合的产品。
更多关于腾讯云数据库产品的信息，请参考以下链接：
同时，SQLAlchemy官方文档也是一个很好的学习资源，你可以在其中找到关于使用SQLAlchemy读取任务结果的更多细节和示例代码。
希望以上信息对你有帮助，如果你有其他问题，请随时提问。
相关·内容
我正在通过after_insert活动启动芹菜任务。
一些芹菜任务最终会更新db，因此需要新插入行的id。这是非常容易出错的，因为如果芹菜任务立即开始运行，那么sqlalchemy有时将无法完成对db的提交，而芹菜将找不到该行。
我还有别的选择吗？
我想我可以以某种方式把这些芹菜任务收集起来，只发送到"after_commit“上，但感觉没有必要复杂。
浏览 2提问于2014-08-01得票数 0
回答已采纳
我试图在heroku上部署一个烧瓶应用程序，在芹菜中使用背景任务。我已经实现了，这样芹菜过程就不会绑定到烧瓶应用程序的任何一个实例。
这在本地工作，我还没有看到一个错误。但是，当部署到heroku时，总是会出现相同的结果:芹菜任务(我只使用一个)在第一次运行时就成功了，但是后续对该任务的任何芹菜调用都会在sqlalchemy.exc.DatabaseError: (psycopg2.DatabaseError) SSL error: decryption failed or bad record mac中失败。如果我重新启动芹菜工人，循环就会继续。
有 显示相同的，但没有指定合适的解决方案。我
浏览 3提问于2017-07-20得票数 3
回答已采纳
我使用的是SQLAlchemy模型(从sqlalchemy.ext.declarative.declarative_base派生)和烧瓶-SQLAlchemy。
当我尝试执行任何芹菜任务时(只是空的)
@celery.task()
def empty_task():
pass
在普通烧瓶视图中
@blueprint.route(...)
def view():
image = Image(...)
db.session.add(image)
db.session.flush()
#this cause later error
empty_task()
浏览 0提问于2015-05-20得票数 1
回答已采纳
1回答
我目前有一个芹菜节拍任务，它会定期计算一些结果。在外部，我可能会有API调用(频率未知)来查询此结果。我在考虑使用"last run task“结果，这样当API进行查询时，celery可以简单地查询节拍任务的最后返回结果。
但是，我没有看到任何关于此行为的文档。我偶尔会看到链接到芹菜“任务结果存储”的帖子，但不幸的是，所有的链接都给了我一个404错误。
浏览 0提问于2019-02-27得票数 1
当芹菜试图清理后端时，我将面临以下例外。
最有可能的是，这是由于而发生的，可以通过使用pool_recycle参数并在以后重试任务来解决。但这不是我能控制的--我想芹菜需要为它提供支持？
现在我的问题是，什么是后端清理任务，以及这样一个失败的任务会如何影响我们的系统？
日志：
[2014-04-08 04:00:00,017: INFO/Beat] Scheduler: Sending due task celery.backend_cleanup (celery.backend_cleanup)
[2014-04-08 04:00:00,020: INFO/MainProcess] Rece
浏览 3提问于2014-04-08得票数 1
1回答
我有一个网络应用程序，我试图使用芹菜从数据库加载后台任务。我目前正在按要求加载数据库，但希望每隔一小时加载一次任务，并让它们在后台工作。我用的是烧瓶，编码用的是python.I，我也在运行红灯。
到目前为止，我已经用芹菜让工人去处理任务，让拍子把任务隔一段时间发送给工人。但是，我希望从工作人员检索结果、数据或查询，如果结果尚未准备好，则应该加载工作人员的前一个结果。
对怎么做有什么想法吗？
编辑
我使用sqlalchemy从数据库中检索结果，并在网页中呈现结果。我有我的主页，其中有所有的各种链接，这些链接都会导致不同的图形，我想要加载在后台，所以用户不必等待很长的加载时间。
浏览 5提问于2016-09-07得票数 9
回答已采纳
1回答
如何在芹菜延迟任务中使用sqlalchemy模型？
看起来芹菜有这个选项，但是我找不到一个如何使用它的例子。
@celery.task
def mytask(data):
# how to I get session here?
线程并没有帮到我。
浏览 2提问于2013-02-26得票数 1
回答已采纳
我有一个长时间运行的任务，它更新一些SQLAlchemy对象。在任务开始时打开会话，在此过程中进行更新，并在结束时提交事务。问题是任务运行了很长时间，所以在提交之前，连接就已经关闭了(超时，“消失”，不管你想怎么叫它)。这将导致提交失败，整个任务也会失败。
这似乎绝对是向数据库写入短任务或与芹菜无关的事情的正确方法。但如果任务耗时太长，这肯定是一个问题。
有没有其他推荐的模式？Celery任务是否应该甚至不使用SQLAlchemy对象，而是使用某种静态类，这些类的数据可以用于更新实际的SQLAlchemy对象，也许只有在任务结束时才能使用？这是我想出的唯一可能的解决方案。我想知道是否还有其他的
浏览 43提问于2020-02-11得票数 0
回答已采纳
2回答
我把芹菜分成以下几个部分
芹菜
芹菜工
芹菜守护进程
经纪人: Rabbimq或SQS
队列
结果后端
芹菜监测器(花卉)
我的理解
当我在django e执行芹菜任务时，g tasks.add(1,2)。然后芹菜把这个任务添加到队列中。我很困惑上面列出的是4还是5
WHen任务进入队列，然后worker获取该任务并从队列中删除
该任务的结果保存在结果后端。
我的困惑
芹菜守护进程和芹菜工人之间有什么区别？
是Rabbitmq在做队列的工作。这是否意味着任务保存在Rabitmq或SQS中？
花是做什么的。它是否监视工作人员、任
浏览 5提问于2016-04-26得票数 1
我有一个金字塔视图，用于将数据从大文件加载到数据库中。对于文件中的每一行，它都会做一些处理，然后创建一些模型实例并将它们添加到会话中。这可以正常工作，除非文件很大。对于大型文件，视图慢慢地吞噬了我所有的内存，直到所有的东西都有效地磨碎了。
因此，我的想法是用一个函数单独处理每一行，该函数创建一个会话，创建必要的模型实例并将它们添加到当前会话中，然后提交。
def commit_line(lTitles,lLine,oStartDate,oEndDate,iDS,dSettings):
from sqlalchemy.orm import (
scoped_ses
浏览 11提问于2014-01-29得票数 1
回答已采纳
我在这方面做了大量的研究，包括尝试像this这样的答案。芹菜似乎无法访问我的Flask应用程序的上下文。 我很清楚我的芹菜对象，什么将装饰我的任务，必须有权访问我的Flask应用程序的上下文。我相信它是应该的，因为我遵循this指南创建了我的芹菜对象。我不确定是不是因为我使用的是Flask-HTTPAuth，所以造成了混淆。 以下是我所拥有的一些内容。 def make_celery(app):
celery = Celery(app.import_name, backend=app.config["CELERY_RESULT_BACKEND"], broker=ap
浏览 54提问于2019-02-23得票数 3
回答已采纳
1回答
我在django应用程序中运行芹菜工人的任务，每个任务大约需要1-2秒才能执行。通常，这些执行都很好，但有时，特别是如果Django应用程序已经部署了一段时间，我开始看到这样的错误：
File "/usr/lib64/python3.6/site-packages/sqlalchemy/pool/base.py", line 428, in __init__
self.__connect(first_connect_check=True)
File "/usr/lib64/python3.6/site-packages/sqlalchemy/pool/bas
浏览 1提问于2019-04-16得票数 3
我最近切换到了Celery 3.0。在此之前，我使用来集成芹菜和Flask。虽然它有很多问题，比如隐藏了一些强大的芹菜功能，但它允许我使用Flask应用程序的完整上下文，特别是Flask-SQLAlchemy。
在我的后台任务中，我正在处理数据，并使用SQLAlchemy对象关系映射来存储数据。Flask-Celery的维护者已经放弃了对该插件的支持。插件在任务中对Flask实例进行了酸洗，这样我就可以完全访问SQLAlchemy了。
我正尝试在我的tasks.py文件中复制此行为，但没有成功。你有任何关于如何实现这一点的提示吗？
浏览 2提问于2012-08-21得票数 49
回答已采纳
摘要:我想在芹菜任务中使用sqlalchemy会话，而不需要包含该会话的全局变量。
我在一个有芹菜任务的项目中使用SQLAlchemy，而且我有
目前，我在芹菜应用程序设置(celery.py)中定义了一个全局变量'session‘，并有一个设置它的工人信号。
session = scoped_session(sessionmaker())
@celeryd_init.connect
def configure_workers(sender=None, conf=None, **kwargs):
# load the application configuration
浏览 0提问于2015-08-13得票数 15
回答已采纳
出于更好的可测试性和其他原因，最好将SQLAlchemy数据库会话配置为非全局的，如以下问题中所述：
(在中也有讨论)
现在，问题是，如何优雅地处理元数据？如果我的理解是正确的，元数据可以有一次，例如：
engine = create_engine(DB_URL, encoding='utf-8', pool_recycle=3600,
pool_size=10)
# db_session = get_session() # this is old global session
meta = MetaData()
meta.re
浏览 0提问于2018-09-30得票数 6
从的角度来看，这听起来似乎是不可能/不可取的。有一个关于SQLAlchemy的章节，但是Django不使用SQLAlchemy。
在较老的文档中，有。
最近的芹菜/ Django版本是否可能只使用数据库来存储消息/结果？
浏览 3提问于2022-10-08得票数 0
1回答
我使用节点-芹菜来实现芹菜和狂犬病。
就像芹菜一样，我们定义任务，然后推动它们。
我在tasks.py中定义的任务如下：
import os
import logging
from celery import Celery
import requests
backend = os.getenv('CELERY_BACKEND_URL', 'amqp')
celery = Celery('tasks', backend=backend)
celery.conf.update(
CELERY_RESULT_SERIALIZER='
浏览 5提问于2017-03-16得票数 1
1回答
我是Python和芹菜的新手--Redis，所以如果我的理解不正确，请纠正我。
我一直在调试一个代码库，它的结构类似-
TaskClass ->芹菜任务
HandlerClass1, HandlerClass2 -> --这些是扩展对象类的python类
应用程序创建TaskClass say dumyTask实例，dumyTask通过获取处理程序的签名创建芹菜子任务(我相信这些子任务是唯一的)，dumySubTask1, dumySubTask2。
我不明白的是什么？
1)芹菜如何管理dumySubTask1, dumySubTask2和dumyTask的结果？我的意思是，dum
浏览 2提问于2017-06-16得票数 0
2回答
我在django应用程序中有这些行。它们在正常情况下运行得很好，但当我将它们称为芹菜任务时，似乎什么都没有发生。我甚至找不到报告的错误。有没有人能建议我哪里会出错？
cmd = "/path/to/unzipped_s3cmd/s3cmd get s3://%s %s/"
subprocess.call(cmd % (s3path,localpath), shell=True)
我在django用户下运行芹菜任务。
浏览 0提问于2013-07-08得票数 1
1回答
TL:博士，我想在后端找到结果。
我有一个酒瓶/芹菜项目，我对芹菜很陌生。用户发送一批用于芹菜工作的任务。芹菜将结果保存到后端SQL数据库(由芹菜自动创建的表，名为celery_taskmeta)。
我想让用户看到他的批处理的状态，并从后端请求结果。
我的问题是，所有的结果都在一张桌子上。我有哪些选项可以将这个批处理，这样用户就可以区分批处理了？
我的想法：
我能为每一项任务添加一个lable吗？“Bob的批次编号12”然后查询celery_taskmeta的结果如何？
我能把每一批批次放在命名的后端表中吗?所以请芹菜将结果保存到一个名为task_12的表中。
与团体一起尝试
浏览 4提问于2020-12-16得票数 0
我使用Celery来运行网络爬虫来抓取一些数据，之后我需要将这些数据保存在数据库中的某个地方(例如SQLite)，但据我所知，我不能在Celery工作人员之间共享SQLAlchemy会话。如何解决这个问题？哪种方式是常见的？
目前，我正在尝试使用Redis作为数据的中间存储。
@celery.task
def run_spider(spider, task):
# setup worker
logger = logging.getLogger('Spider: %s' % spider.url)
spider.meta.update({'logg
浏览 3提问于2012-08-09得票数 2
回答已采纳
1回答
我们需要扩展芹菜，以避免有限的芹菜工人排起长队，而是在ACI中产生新的芹菜容器来分发这些任务。 为了实现这种扩展(在ACI中生成新的芹菜容器)，我们需要知道等待执行的任务的数量，并相应地在ACI上生成这些容器。 任何建议都将不胜感激。
浏览 11提问于2020-07-25得票数 0
2回答
我有一个芹菜任务，它接收来自SQS队列的消息并尝试运行它。如果失败，应该每10秒至少重试144次。我认为正在发生的事情是，它失败并重新进入队列，同时创建一个新的队列，将其复制到2。这2次再次失败，并遵循相同的模式创建2个新消息，总共变成4个消息。因此，如果我让它运行一段时间，队列就会阻塞。
我没有得到的是正确的方式，重新尝试它，而不重复。下面是重试的代码。请看是否有人能带我到这里来。
from celery import shared_task
from celery.exceptions import MaxRetriesExceededError
@shared_task
def se
浏览 8提问于2016-05-04得票数 4
1回答
我有一个不包括Django的项目，所以我不能使用djcelery。
但我发现了使用sqlalchemy的 of 。
就像djceley的DatabaseScheule一样好用。但唯一的问题是，它似乎没有发送在运行时添加的任务，然后重新启动芹菜节拍，之前添加的任务将被成功发送。
那么，可以在不重新启动芹菜节拍的情况下动态地添加/删除任务吗？
谢谢你的建议。为我糟糕的英语感到抱歉。
抱歉是我的错。在运行时添加的任务不会立即被捕获，您可以将DatabaseScheduler.sync_every值更改为更快的值。所以它在等待几分钟后就能工作了。
谢谢你的帮助。
浏览 2提问于2016-05-11得票数 2
1回答
我按照官方教程/文档的说法为Django项目安装了芹菜。当我在命令行发射芹菜的时候，我可以看到它接收到任务并执行它们。但是，一旦一切正常运行，我决定多跟着文档，去守护芹菜，让它一直运行。因此，我也尝试了在Ubuntu系统上使用/etc/default/celeryd脚本提供的celeryd init脚本。我相应地更改了值，并正确地启动了它，但是当它接收到一个任务时，日志会说：
ERROR/MainProcess] Received unregistered task of type 'likes.tasks.test'.
The message has been ignored
浏览 0提问于2012-08-13得票数 9
3回答
试图了解芹菜如何与来自的狂犬病to起作用
代码：
from celery import Celery
app=Celery('tasks',backend='amqp',broker='amqp://')
@app.task(ignore_result=True)
def print_hello():
print 'hello'
for i in xrange(2,222222):
print i
print_hello()
问题：
运行celery worker -A celery_te
浏览 8提问于2016-02-03得票数 0
回答已采纳
DJCelery没有在我的Django SQLite DB中存储任务结果。
我有一个已有的Django项目，我已经开始设置芹菜w/ RabbitMQ了。启动了我的RabbitMQ服务器。我能运行芹菜python manage.py celeryd --verbosity=2 --loglevel=DEBUG和赛勒提比python manage.py celerybeat --verbosity=2 --loglevel=DEBUG。一切都会启动w/ out错误，而我的定期示例任务也没有错误地运行。
我使用pip install django-celery来安装。我在已安装的应用程序中安装了dj
浏览 7提问于2016-07-06得票数 1
回答已采纳
1回答
我正在创建一个背景芹菜任务与水瓶-SQLAlchemy，以更新数据库记录的属性。我使用进行芹菜配置，这是我的代码的简化版本：
from flask import Flask
from celery import Celery
def make_celery(app):
celery = Celery(app.import_name, broker=app.config['CELERY_BROKER_URL'])
celery.conf.update(app.config)
TaskBase = celery.Task
class Context
浏览 1提问于2017-07-11得票数 4
回答已采纳
我有一个芹菜敲打刮刀，它定期运行，从特定的api中获取最新数据(每30分钟)。
今天(2019年12月14日)，我仍然可以看到芹菜花在5天前(2019年12月12日)完成的任务的结果。
这是浪费的内存，我想在我的ec2上收回
问题：
芹菜在一定的天数后会产生红色吗？
是否有芹菜选项将任务装饰器@task(name='task_name')中的最新任务结果保留在redis中？
是否有选项只保存最后一个X数量的任务结果在redis内存中？
浏览 1提问于2019-12-14得票数 1
回答已采纳
1回答
我正在更新我的芹菜工人从芹菜v3到芹菜v4，我所有的任务都是基于类的任务。，因为它是升级文档中指示的内容。
问题是在任务路由中，我有以下任务
class RegisterTask(Task):
routing_key = 'app_server.register'
def run(**params):
whatever ...
我正在运行两个芹菜工人，一个在默认队列上运行，另一个在注册队列上运行，如下所示：
# Default Worker
celery -A app_server worker --loglevel=info --concur
浏览 2提问于2019-02-24得票数 11
1回答
我试着在我现有的烧瓶项目中添加芹菜。添加之后，我在运行时得到了一个“在应用程序上下文之外工作”错误。看来芹菜工人缺乏我的应用背景。但在这种情况下，我不知道如何将应用上下文传递给芹菜工人。
下面是我当前的结构(我尝试遵循带有蓝图和api文档的工厂模式)：
-run.py
-app
-module1
-controller.py
-model.py
-service.py
-__init__.py
-config.py
对于init.py
# __init__.py
import os
from flask import Flask
f
浏览 0提问于2019-07-04得票数 3
回答已采纳
1回答
我需要建立一个系统来处理两种类型的任务。一种类型可以自己创建更多任务，也可以创建另一种类型的任务。将有很少的工人(2-3)和只有一个主机。最重要的要求是系统应该很好地处理重新启动:即在重新启动时，正在进行的任务应该从头开始，而工作人员应该在重新启动之前收集排队的任务。从芹菜的角度看，它似乎适合这个用例。然而，我有几个问题：
1)芹菜能否如所述处理整个系统的重新启动？(芹菜+工人+经纪人，一切重新启动，完全停电)。
2)在这种情况下，最好的经纪人是什么？我更喜欢SQLAlchemy + SQLite，因为它更“自我包含”，但是如果RabbitMQ是正确的选择，考虑到需要优雅地处理完全重新启动，那
浏览 0提问于2015-04-20得票数 15
回答已采纳
1回答
我们有一个大型应用程序，它使用django作为ORM，使用芹菜作为运行基础设施的任务。我们运行由事件(用户驱动的或自动的)触发的复杂管道，这些事件如下所示：
def pipeline_a:
# all lines are synchronous, so second line must happen after first is finished successfully
first_res = a1()
all_results = in_parallel.do(a2, a3, a4)
a5(first_res, all_results)
我们希望运行a1，a2，.在不同的机器上(每个任务可能
浏览 2提问于2020-09-08得票数 0
1)我目前正在开发一个web应用程序，该应用程序公开一个REST，并使用Django和芹菜来处理请求并解决它们。为了解决请求，必须向amqp队列提交一组芹菜任务，以便在工人(位于其他机器上)上执行这些任务。每项任务都是非常密集的CPU，需要很长时间才能完成。
我已经配置了芹菜也使用amqp作为结果后端，我使用RabbitMQ作为芹菜的经纪人。
每个任务都返回一个结果，需要随后存储在DB中，而不是由工作人员直接存储。只有“中心节点”--运行django的机器-- RabbitMQ队列中的芹菜和发布任务--才能访问这个存储DB，因此工作人员的结果必须以某种方式返回到这台机器上。
问题是我如何处理之
浏览 1提问于2013-02-06得票数 7
回答已采纳
4回答
芹菜忽视Config值
、、、
由于某种原因，芹菜似乎忽略了我的配置值。我在我的应用程序config.py中设置了以下值
BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
CELERY_RESULT_ENGINE_OPTIONS = {"pool_recycle": 7200, 'echo': True}
BROKER_TRANSPORT_OPTIONS = {'visibility_timeout': 3600}
浏览 0提问于2017-12-08得票数 3
回答已采纳
1回答
我试图找出一个最佳的方法来做这个网站，作为一个前端的Azure。假设用户希望创建一个VM：
1)用户提交作业
2)工作会立即提交给Azure，但需要大约3分钟才能得到结果。
3)我希望用户提交并继续他们的业务(即不等待)，并希望DOM在收到结果时自动更新。
我尝试过的事情：
1)用芹菜调度任务，->将结果保存到DB，-> JavaScript经常轮询DB并更新DOM
2) JavaScript运行AJAX，它与通过API与Azure对话的视图进行对话，以查看是否完成了任务。如果完成，将结果保存到DB并更新DOM
问题与
1)我真的不喜欢这种依赖另一种服务并增加更多复杂性的方法。主要
浏览 2提问于2018-03-22得票数 0
回答已采纳
1回答
烧瓶-芹菜制作的点滴表
、、、、
我有一个烧瓶应用程序，连接到一个PostgreSQL数据库。我集成了芹菜，并将其结果后端配置为相同的postgresql数据库。
在烧瓶应用程序中使用的其他表在代码中有类定义，并使用alembic (烧瓶-迁移)生成：
$ flask db migrate -m "add a table" (creates migration file)
$ flask db upgrade (applies changes in migration file to the db)
问题
我在代码中为表添加了一个新类，并运行了flask db migrate -m "add test
浏览 1提问于2020-12-30得票数 3
回答已采纳
2回答
处理数据管道中的复制滞后
、、、、
给定一个按顺序运行的任务管道。每个任务都使用来自数据库的数据，对其进行操作，并生成(写)到同一个数据库。
我们使用AWS RDS Aurora，为了分散负载，每个任务的“读取阶段”都在read副本中完成。在某些情况下，高负载，我们达到10-15秒的复制滞后。这意味着当新任务消耗数据时，它会出错/丢失数据点。
我们知道这不是设计这种管道的“正确”方式，它与成语“不通过共享记忆进行交流，而是通过交流来共享记忆”相矛盾。由于现在改变设计太费劲了，所以我们想出了另一种解决方案：
创建一个检查复制滞后值并将其公开给所有任务的服务。如果值大于x，则任务将返回RDS主节点读取。
这不是最佳办法，我希望听到绕
浏览 16提问于2022-08-21得票数 0
1回答
我正在使用Python、芹菜和RabbitMQ制作一个网络蜘蛛来计算页面上的链接数量。
一个数据库，比如MySQL，可以异步写入吗？是否可以在每次添加行后提交更改，或者是否需要对它们进行批处理(多重添加)，然后在特定数量的行/持续时间后提交？
我更喜欢使用SQLAlchemy和MySQL，除非有更推荐的组合用于Celery/RabbitMQ。我还看到了NoSQL (CouchDB?)推荐。
浏览 0提问于2011-10-05得票数 0
回答已采纳
我想在芹菜中创建定期任务，并在运行时定义计划。
如果你的项目是基于Django的，你可以使用djcelery的DatabaseScheduler类来动态创建周期性任务。
celery -A proj beat -S djcelery.schedulers.DatabaseScheduler
但是，djcelery.schedulers.DatabaseScheduler与Django的耦合非常紧密。
是否存在更通用的Database Scheduler？更好的是，有没有一个数据库调度器是为使用Pyramids + SQLAlchemy而设计的，这也是我的项目所基于的？
浏览 0提问于2015-10-22得票数 3
1回答
怎样才能有一个类似于的仪表板来监控芹菜的任务。从中，我看到SQS监控支持还没有实现。还有别的选择吗？
我在用姜戈配芹菜。
浏览 2提问于2020-03-21得票数 1
是否可能只将芹菜结果保存在特定参数上，例如失败的任务？
我一直在寻找，但唯一的办法，我可以管理的是回到芹菜的结果后端和解析数据以外的芹菜。
有更好的办法吗？
(注意:我使用mongodb作为芹菜结果后端。)
浏览 3提问于2020-08-12得票数 0
回答已采纳
1回答
异步数据获取和缓存处理
、、、
我计划部署一个动态站点，它需要定期在后台完成某些任务，比如说每一两个小时。我需要输出的数据严格取决于这些查询的结果。
现在的问题是，这些任务需要一定的时间，例如8-10分钟:因此，如果用户请求一个页面，因此某个视图被调用，而该任务仍在进行中，则一切都会出错。
所以，这里有一个问题:我需要实现什么来处理这个问题？我一直在搜索，并找到了关于芹菜的信息，但我不明白如何使用它来解决上面的问题，并可能实现一个缓存系统，在任务尚未完成时进行干预。
浏览 1提问于2011-09-13得票数 1
回答已采纳
我对烧瓶很陌生，而且还是python的初学者，而且我遇到了sqlalchemy的包问题。我用conda创建了一个名为flask_app_env的虚拟环境，正如我在终端输出中显示的那样，它是活动的，然后在终端中执行以下命令。我已经使用pip包管理器来安装sqlalchemy在其他烧瓶包中。
PythonVersion3.7.4但是当我试图在终端中执行命令from sqlalchemy import create_engine时，它会抛出错误：ModuleNotFoundError: No模块，名为'sqlalchemy'
任何方向都将不胜感激。
浏览 2提问于2019-12-09得票数 0
我有一个芹菜应用程序，它使用redis作为代理，我可以使用以下命令获取应用程序的统计数据
芹菜-A test.celeryapp检查统计数据
这给了我一些数字如下所示
"total": {
"test.celerytasks._generate_data": 14493666,
"test.celerytasks.cleanup_data": 14493,
}
这些数字描述了这些任务从day1执行了这么多次吗？如何理解这些结果
我应该如何获得在过去1小时/天内处理的芹菜任务的数量？我能得到最后一小时/天的
浏览 4提问于2022-03-23得票数 0
我想要实现的
我想做一个网站，让用户从其他网站刮擦信息。我的目标是实现以下目标：
当刮取过程开始时，用户按下“刮取”，如果用户按下“停止”按钮，则呈现带有加载消息的视图和“停止”按钮，或者如果刮取过程终止，则显示具有刮擦结果的视图。
电流状态
目前，我有一个非常简单的抓取网站与一个可怕的用户体验。用户按下刮键后，我呈现一个类似于以下视图的视图：
def scraping_view(request, scraper_args):
scrape_results = scrape(scraper_args) # Very long function!
return render(re
浏览 2提问于2022-01-08得票数 1
我很熟悉芹菜在任务上的选项--它确保任务不会被重试超过这个次数。
然而，在那个最大值被击中之后会发生什么呢？(例如，如果由于不断抛出错误而命中)，该任务是简单地丢弃了，还是由于错误所致，是否抛出错误并将管理员发送电子邮件(如果CELERY_SEND_TASK_ERROR_EMAILS设置为True)？
浏览 1提问于2016-01-18得票数 0
我们正在运行一个API服务器，用户提交作业进行计算，这需要1秒到1个小时。然后，他们请求检查状态并获得结果，这可能是(很久)以后，甚至永远不会。
当前，作业被添加到发布/子队列中，并由各种工作进程处理。然后，这些工作人员将pub/sub消息发送回侦听器，侦听器将状态/结果存储在postgres数据库中。
我正在寻找使用芹菜来简化事情，并允许更容易的缩放。
使用celery_app.send_task，提交工作和获得结果并不是芹菜中的问题。然而，我不知道如何最好地确保结果存储时，特别是长期运行或可能被放弃的工作。
我考虑过的一些解决办法包括：
允许所有工作人员访问数据库，并让他们处理更新。这方面
浏览 0提问于2021-04-28得票数 1
回答已采纳
2回答
我有一个将数据发送到另一个服务的芹菜任务。我已经在基于RequestSupplyStock类的视图中添加了芹菜任务send_inventory_request。当我发布帖子时，我应该首先从芹菜任务中获得结果，然后继续并返回响应。我想首先等待芹菜任务的结果，然后从post方法返回响应，这是实现这一点的正确方法。
@app.task
def send_inventory_request(payload,token):
auth = {'authorization':token}
HEADERS.update(auth)
url = PROCUREMENT_S
浏览 0提问于2019-01-18得票数 3
1回答
我无法获得任务列表(活动，计划.)在芹菜里。
使用django时，我的web应用程序每次向url询问url时都使用芹菜发送任务：
tasksend = calcul.delay()
如果芹菜已经在进行的话，我不想发射这个魔杖。
所以，我想列出芹菜收到但尚未完成的任务:如果我的“calcul”任务已经在进行中，那么我就可以不再要求calcul.delay()了。
我已经搜索了很多，中的回复对我的芹菜版本也不好。
我使用：- django 2.0.13 - python 3.4.2 -芹菜v4.3.0和redis
我已经试过了
def inspect(method):
app = Cele
浏览 0提问于2019-08-23得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
