如何将参数传递给芹菜的任务？
将参数传递给芹菜的任务可以通过以下几种方式实现：
- 命令行参数：可以在运行芹菜任务时通过命令行参数传递参数。在编写任务代码时，可以使用argparse等工具解析命令行参数。例如，可以通过
python celery_task.py --param1 value1 --param2 value2的方式传递参数。 - 配置文件：可以将参数写入一个配置文件，然后在任务代码中读取配置文件来获取参数值。常见的配置文件格式有INI、JSON、YAML等。在Python中，可以使用ConfigParser、json、pyyaml等库来读取配置文件。
- 数据库：可以将参数存储在数据库中，然后在任务代码中从数据库中读取参数。可以使用关系型数据库如MySQL、PostgreSQL，或者NoSQL数据库如MongoDB、Redis等。
- 环境变量：可以将参数设置为环境变量，然后在任务代码中通过读取环境变量来获取参数值。在Linux系统中，可以使用
export PARAM=value的方式设置环境变量，在Python中可以使用os.environ来读取环境变量。 - API调用：如果参数是从外部系统获取的，可以通过调用API来获取参数值。可以使用requests等库发送HTTP请求，获取参数值后在任务代码中使用。
以上是常见的将参数传递给芹菜任务的方式，具体选择哪种方式取决于实际需求和场景。在腾讯云的云计算平台中，可以使用腾讯云的云数据库、云函数、API网关等产品来实现参数传递和存储。
相关·内容
我在运行一个芹菜的酒瓶应用程序。我有一些休息控制器，它们调用一些与芹菜一起运行的任务。
我是否必须在具有烧瓶应用程序上下文的主python文件中定义任务？我希望在另一个模块中有芹菜，比如"TaskRunner“模块或类似的东西，然后让烧瓶应用程序/控制器使用该服务调用/运行实际任务。如何将应用程序上下文(或芹菜实例)传递给TaskRunner，以便从那
浏览 0提问于2018-09-12得票数 0
回答已采纳
我有一个关于如何从Django运行参数并将参数传递给芹菜任务的问题。1从提交的表单中获取关键字(hashtagName)
2将名称发送到定期任务，以便每30秒在一页上显示它的计数。如果这是正确的方式，我如何将值从Django传递到celery任务？因为任务将在我的第二个命令之后立即开始。PS:我通读了celery文
浏览 0提问于2014-07-22得票数 2
2回答
这是我的芹菜任务我将这个任务命名为如下task_a.apply_async(arg1,我试着编一本字典，改变论点的位置，但都失败了…
浏览 2提问于2018-05-09得票数 8
回答已采纳
1回答
我正在努力学习芹菜是什么&做什么，我已经学习了一些基本教程，如和 one，我还有几个关于芹菜的问题：>>> fromtasks import add所以我的问题是：
这里发生了什么事？add()是我们在任务文件中编写的方法，我们调用add.delay(4,4)。所以我们是在调用方法而不是方法
浏览 0提问于2015-03-30得票数 0
回答已采纳
1回答
今天，我正在研究Amazon，作为在EC2实例上安装自己的EC2的替代方法。我遵循了描述的文档
那么，这是文档中所指出的SQS的限制，还
浏览 4提问于2013-01-26得票数 3
回答已采纳
0回答
对于我的web应用程序，我使用带有redis后端的celery。如果我知道某个任务的ID，则官方会通过以下方式获取该任务的结果。result = my_task.AsyncResult(task_id)我可以很容易地访问任务主体中的参数：def my_task(foo, bar,baz=None): args =
浏览 0提问于2017-06-06得票数 4
回答已采纳
2回答
我想将一个文件保存到AWS S3，我使用芹菜，因为我不想等到函数编写完该文件。问题是，当我将它发送到芹菜函数时，我可以看到，与实际的文件大小相比，AWS文件存储中的大小并不相同。这是我把它送到芹菜的时候：write_file_aws.delay(file_full_name, file_to_put)
芹菜</
浏览 1提问于2020-05-17得票数 1
回答已采纳
使用Django 1.8，我希望在视图中保存表单后触发延迟的芹菜函数 form = TopicForm()但我得到<Topic: Topic object> is not JSON serializable@shared_task
def notif
浏览 1提问于2018-06-21得票数 15
回答已采纳
1回答
如何将位置参数作为列表或元组传递给按拍频调度的任务的。@shared_task ...', 'args': ([1,]),
浏览 0提问于2013-12-28得票数 1
回答已采纳
我正在开发flask应用程序，它使用芹菜在后台启动大量任务，我使用Redis作为消息代理队列，使用SQL炼金术作为芹菜后端。默认情况下，我可以看到"Results“存储在后端的celery_taskmeta表的"results”列中，但我也希望存储传递给任务的参数。谢谢
浏览 2提问于2020-07-22得票数 2
1回答
我试图通过Django芹菜发送电子邮件，但这些任务并没有被芹菜接收。user.errors)获取误差
它没有.delay功能(没有芹菜此外，芹菜终端没有收到任何任务。
浏览 5提问于2021-10-27得票数 1
回答已采纳
2回答
我用芹菜在Hadoop上执行长期运行的任务。每个任务在Hadoop上执行一个Pig脚本，运行时间约为30分钟-2小时。我像这样开始我的芹菜工人。celery -A app.celery worker
我希望在命令行本身中传递一些额外
浏览 0提问于2017-07-07得票数 8
回答已采纳
1回答
我想用芹菜在时间延迟后发送一些信息。用户收到消息后，其触发的新状态。为此，我需要将telebot.types.Message对象作为参数发送到芹菜任务中。我怎么才能正确地做这件事？我的过渡职能是启动芹菜任务： celery_utils.delay_message.apply_async(kwargs={'response': self.response
浏览 6提问于2019-11-04得票数 1
回答已采纳
2回答
我对Python芹菜很陌生，并试图将芹菜用于工作流执行。工作流：
在成功的任务-2，任务-5和任务-6被执行(同时)和任务-7执行，如果任务-2失败。在任务
浏览 0提问于2015-11-06得票数 3
我想将一个pandas dataframe对象作为参数传递给一个芹菜任务。有什么办法可以做到这一点吗？我知道dataframe对象不是JSON可序列化的，因此根据我当前的设置不能用作参数。
浏览 7提问于2018-01-30得票数 5
回答已采纳
我一直在想，我们如何将复杂的ORM对象传递给后台工作人员--在我的例子中，Django模型和芹菜，但这可以适用于任何类似的背景处理框架。 send_email(user.first_name, user.last_name)
相反，同事更喜欢将值直接传递给任务--使用来自单个对象的10+参数，这些任
浏览 0提问于2017-03-03得票数 6
我想在芹菜中移动一些对异步任务的长查询，然后用AJAX检索额外的信息。现在我得到了这样的QuerySet：任务：def brand_countquerystr.annotate(amount_of_products=Count('products'))task_run = brand_count.delay(brand
浏览 0提问于2018-04-20得票数 3
回答已采纳
5回答
我正在尝试使用类的方法作为django-芹菜任务，并使用@任务装饰符对其进行标记。同样的情况被描述为，由Anand询问。，foo至少需要两个参数，这意味着self指针遗漏了。更多信息：
使用@任务装饰符将类标记为任务，使类本身成为一个任务，并且可以使用一些参数作为方法选择的关键创建类<
浏览 5提问于2012-02-12得票数 54
回答已采纳
1回答
将参数传递给自定义芹菜任务
、、、、
我只是想知道将参数传递给自定义任务装饰器的正确方法是什么。some more stuff here并按以下方式使用：def add(x, y):但是，我希望能够将一个参数传递给这个任务，并让它根据参数(或者等效的，基于它正在修饰的函数)的行为有所不同。一种方法是将额外的kwarg传
浏览 1提问于2019-03-22得票数 4
2回答
我已经开始在Django Python项目中使用芹菜4.1，并遇到了签名。在中，它说：
您刚刚学习了如何使用调用指南中的任务延迟方法调用任务，这通常是您所需要的，但有时您可能希望将任务调用的签名传递给另一个进程或作为参数传递给另一个函数。签名()封装单个任务调用的参数、关键字参数和执行选项，这样就可以将其传递给函数，甚至可以序
浏览 8提问于2018-01-04得票数 18
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
