在Celery任务中获取生成文件的URl的最佳方法是什么
在Celery任务中获取生成文件的URL的最佳方法是将生成文件的URL存储在数据库中，并在任务完成后返回该URL。这样可以确保在任务执行期间生成的文件可以被后续的请求访问到。
具体步骤如下：
- 在任务开始执行之前，生成一个唯一的文件名，并将其存储在数据库中。可以使用UUID或时间戳等方式生成唯一的文件名。
- 在任务执行过程中，将生成的文件保存到指定的位置，例如服务器的文件系统或对象存储服务。
- 任务执行完成后，将生成文件的URL更新到数据库中对应的记录中。
- 在需要获取生成文件的URL时，从数据库中查询对应记录，并返回其中存储的URL。
这种方法的优势是可以确保生成文件的URL是可靠的，并且可以在任务执行完成后随时获取。同时，通过将URL存储在数据库中，可以方便地管理和查询生成文件的URL。
对于腾讯云相关产品，可以使用腾讯云对象存储（COS）来保存生成的文件，并将文件的URL存储在腾讯云数据库（TencentDB）中。腾讯云对象存储提供了高可用性、高可靠性的文件存储服务，腾讯云数据库则提供了可扩展的、高性能的数据库服务。
腾讯云对象存储产品介绍链接地址：https://cloud.tencent.com/product/cos
腾讯云数据库产品介绍链接地址：https://cloud.tencent.com/product/tencentdb
相关·内容
我有一个任务是在DB中异步导出几个大表，因为现在记录的数量太大了，需要花费太多的时间。所以我已经成功地将导出的代码移到了芹菜任务中。它导出文件并将其保存在服务器上的文件夹中。但我不能从任务中获得整个文件名，我可以将其传递给其余代码，从而在完成导出过程后下载它，因为芹菜任务唯一可以返回的是执行<
浏览 5提问于2018-02-12得票数 1
1回答
我试图在fastAPI上设计一个API，我的客户端会将响应限制在时间上。例如，对于某些客户端，它可能是几十秒，而对于其他客户端，则可能是毫秒。假设用户发送请求(例如/v5/bla/info)，API检查谁发送该请求并确定该请求的响应时间。如果在此期间执行请求，则给出答复，如果没有执行，则在指定时间结束时，提供某种请求ID，以便用户随后向另一个端点发送请求(例如/v5/check_ request )，该端点将使用请求ID提供有关请求的执行(挂起、完成、错误
浏览 4提问于2021-11-15得票数 0
我使用django，celery和rabbitmq来处理任务，让我们称它为APP1。在另一台主机上，我使用了APP2，它需要从APP1中处理的任务中获取结果。两个应用程序/主机都可以访问rabbitmq，我的第一个方法是简单地尝试从两个应用程序共享一个队列，但没有成功。
实现这一目标的最佳方法是什么？
浏览 0提问于2014-10-15得票数 1
我能够使用以下方法(最低可再生产)使其工作：
app = Celery('tasks', broker=f'sqs://{aws_access}:{问题是，我希望在多个环境中运行这个队列，因此我希望为每个环境指定一个单独的队列。我找到了queue_name_prefix的文档，这似乎是我想要的，但是我无法让它工作。我试过的<
浏览 0提问于2019-07-16得票数 0
import djceleryCELERY_RESULT_BACKEND = 'django://'我尝试的每一个组合都失败了，包括：from celery.task import task
from celery.task.base import task@
浏览 0提问于2013-08-08得票数 5
回答已采纳
B实现了一些功能，并且具有很重的依赖性。以前，我可以愉快地使用send_task按名称调用B。现在，我有了更复杂的逻辑，并希望使用canvas来编排任务。遵循用户指南：signature('tasks.add', args=(2, 2), countdown=10)如何按名称注册任务？
浏览 1提问于2018-08-10得票数 0
2回答
我想知道从Django解耦芹菜的最好方法是什么，以便将这两个部分对接并使用？通常，用户使用引用Django应用程序的命令启动他们的芹菜工人和芹菜节拍：celery beat -A my_app
由此，我相信celery会从设置文件和celery.py文件中提取配置信息，这很容易移动到微服务中。我不完全理解的是这些<
浏览 5提问于2017-01-17得票数 6
2回答
芹菜队列同时获取多条消息
、、、
我正在开发一个基于码头的芹菜支持的Python应用程序，其中一个功能是触发并发送一个给定数字的文本消息。工作流程如下：
用户上传带有一组条目的CSV，每60秒向CSV发送文本消息cron作业轮询数据库，以获取任何新条目并在找到新条目时将它们添加到队列中，将它们放入队列并触发文本消息。目前，如果我上传一个CSV文件与3个条目，每个短信动作是顺序触发，而不是并行(默认芹菜过程bheaviour)。例如，如果调度程序每10秒从队列中获取一个作业，发送3条文本
浏览 2提问于2021-09-15得票数 3
2回答
我想从Python脚本中开始并停止芹菜工人进程。我用Redis做经纪人和后端。我发出一个Popen命令，从计划工人任务的脚本中启动工作人员： cmd = 'celery worker '
cmd += '--app我知道我可以做一些像ps -ef | grep celery | awk '{print $2}' | xargs kill -9这样的<
浏览 0提问于2018-05-12得票数 0
回答已采纳
我想实现django芹菜在后台运行任务。在这里我遇到了一些问题。task.pyfrom projects.services.instagram_bot import InstagramBot
浏览 3提问于2020-01-24得票数 1
以下是任务： from celery import shared_taskimport time
import time
app = Celery("tas
浏览 73提问于2020-09-15得票数 1
1回答
我正在测试芹菜任务，但在这个问题上遇到了问题。如果任务中存在带有请求的代码(通过urllib.urlopen)，那么它就挂起了。可以是什么原因呢？包含任务的文件(run_celery.py)：
...import celery and flask app...cele
浏览 2提问于2015-06-09得票数 1
1回答
我的管道如下：资源输入(基本上是必须解析的URL)不是固定的，这意味着我可以一次引入数千个资源，稍后再引入几十个资源，等等。我的想法是将管道的每一步实现为一个芹菜任务，并将其部署到云上(例如，使用Heroku的工人dynos)。但我对芹菜很陌生，我怀疑如何排好这些任务，让我的员工100%地工作，同时保持系统的完整性
浏览 1提问于2012-07-27得票数 2
回答已采纳
2回答
如何用芹菜拍打开始任务？
、、、、
为什么我不能执行定期任务？proj/settings.pyREDIS_PORT = '6379'BROKER_URL = 'redis://' + REDIS_HOST + ':' + REDIS_PORT
CELERY</
浏览 2提问于2019-11-01得票数 12
1回答
我正在尝试将芹菜集成到我的应用程序中，但是我收到了这样的错误：Received unregistered task of type "".The message has been ignored and discarded.我的芹菜应用实例是这样创建的：
celery = Celery(ap
浏览 0提问于2017-10-02得票数 3
回答已采纳
1回答
我的Python应用程序支持一些长期运行的任务，这些任务是使用API或来自其他系统的CURL调用来调用的。现在，我想为服务器创建一个服务，如果系统重新启动，这个芹菜工人应该自己开始但是，当从服务执行以下命令时，它不会从队列中</em
浏览 0提问于2020-02-17得票数 2
回答已采纳
我的界面必须给用户一个选项来启动一个长时间的网络抓取操作，这可能需要几分钟到几个小时。当此操作运行时，它将将数据持久化到数据库。它是以这种方式编码的： batch = BatchTable.objects.create(user=request.user) # Batch model
浏览 2提问于2020-02-08得票数 1
回答已采纳
当我启动manage.py celerybeat的celerybeat时，我看到了以下内容： . loader -> djcelery.loaders.DjangoLoader
. scheduler -> celery.beat.PersistentScheduler我想知道上面的配置是从哪个文件</
浏览 2提问于2011-07-13得票数 3
我编写了一个简单的应用程序，它可以在线获取股票报价，并发布买卖订单。现在这一切都是通过控制台完成的。我阅读并学习了几本关于Flask网络应用的教程。但我不知道如何在获取信息同时显示在Flask应用程序上的同时运行服务器。
在一个线程中<
浏览 4提问于2017-11-07得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
