将boto3.client实例传递给celery任务会引发JSON序列化错误
的原因是boto3.client实例包含了一些不可序列化的对象，无法直接进行JSON序列化。解决这个问题的方法是将boto3.client实例中的不可序列化对象剔除，只保留可序列化的部分进行传递。
在云计算领域中，boto3是AWS（亚马逊云服务）提供的用于Python开发者与AWS服务进行交互的软件开发工具包。它提供了一组用于创建、配置和管理AWS服务的API操作。celery是一个基于分布式消息传递的异步任务队列/作业队列，常用于处理耗时的任务。
解决这个问题的一种方法是在传递boto3.client实例之前，将其转换为可序列化的数据结构，例如字典。这可以通过提取boto3.client实例中的必要信息来实现，例如AWS服务的访问密钥、区域等。然后，将这些信息传递给celery任务，并在任务中重新创建boto3.client实例。
以下是一个示例代码，展示了如何解决这个问题：
import boto3
from celery import Celery
app = Celery('tasks', broker='redis://localhost:6379/0')
def extract_serializable_data(client):
# 从boto3.client实例中提取可序列化的数据
serialized_data = {
'access_key': client._request_signer._credentials.access_key,
'secret_key': client._request_signer._credentials.secret_key,
'region_name': client._client_config.region_name
}
return serialized_data
@app.task
def process_task(serialized_data):
# 根据提取的数据重新创建boto3.client实例
client = boto3.client(
's3',
aws_access_key_id=serialized_data['access_key'],
aws_secret_access_key=serialized_data['secret_key'],
region_name=serialized_data['region_name']
)
# 在这里执行需要使用boto3.client实例的任务逻辑
# ...
# 创建boto3.client实例
s3_client = boto3.client('s3')
# 提取可序列化的数据
serialized_data = extract_serializable_data(s3_client)
# 将数据传递给celery任务
process_task.delay(serialized_data)在上述示例中，我们通过extract_serializable_data函数从boto3.client实例中提取了可序列化的数据，然后将这些数据传递给celery任务process_task。在process_task任务中，我们根据提取的数据重新创建了boto3.client实例，并在任务中执行需要使用该实例的逻辑。
需要注意的是，上述示例中使用的是AWS的S3服务作为示例，你可以根据具体的业务需求和使用的AWS服务进行相应的修改。
腾讯云提供了类似的云计算服务，你可以参考腾讯云的文档和产品介绍来选择适合的产品和服务。以下是腾讯云相关产品和产品介绍链接地址：
请注意，以上链接仅供参考，具体的产品选择和推荐应根据实际需求进行评估。
相关·内容
我有django 1.11.5和celery 4.1.0的应用程序，我一直收到：
kombu.exceptions.EncodeError: <User: testuser> is not JSON serializable
我的settings.py：
CELERY_BROKER_URL = 'amqp://localhost'
CELERY_RESULT_BACKEND = 'amqp://localhost'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_RESULT_S
浏览 0提问于2018-03-20得票数 15
回答已采纳
1回答
今天，我正在研究Amazon，作为在EC2实例上安装自己的EC2的替代方法。
我遵循了描述的文档
在一段中，它说：
SQS还不支持事件，因此不能用于芹菜事件、celerymon或Django管理监视器。
我有点搞不懂events在这里是什么意思。例如，在下面的场景中，我每分钟都有一个周期性的任务来异步调用sendEmail.delay(event)。
例如：
@celery.task(name='tasks.check_for_events')
@periodic_task(run_every=datetime.timedelta(minutes=1))
def c
浏览 4提问于2013-01-26得票数 3
回答已采纳
1回答
我试图通过Django芹菜发送电子邮件，但这些任务并没有被芹菜接收。
settings.py
CELERY_BROKER_URL = 'redis://127.0.0.1:6379'
CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TASK_SERIALIZER = 'json'
CELERY_T
浏览 5提问于2021-10-27得票数 1
回答已采纳
在执行时，我试图添加一个芹菜任务，但是我得到了以下错误：
Traceback (most recent call last):
File "/Users/amrullahzunzunia/virtualenvs/flyrobe_new/bin/celery", line 11, in <module>
sys.exit(main())
File "/Users/amrullahzunzunia/virtualenvs/flyrobe_new/lib/python3.5/site-packages/celery/__main__.py"
浏览 1提问于2016-03-07得票数 15
回答已采纳
我试图用芹菜和RabbitMQ异步发送电子邮件。这是我第一次使用芹菜，所以我不太熟悉其中的一些错误。我意识到追溯来自一个名为kombu的包，我知道它是对芹菜的依赖。我只是无法调试这个。
每当我尝试发送电子邮件时，跟踪就会发生。
回溯：
[2017-05-14 12:35:08,093] ERROR in app: Exception on /home [POST]
Traceback (most recent call last):
File "/Users/kai/github-projects/Ticket-System/venv/lib/python3.5/site-pack
浏览 2提问于2017-05-14得票数 4
回答已采纳
1回答
我创建了一个芹菜任务如下
import os
import time
from celery import Celery
from dotenv import load_dotenv
load_dotenv()
celery = Celery(__name__)
celery.conf.broker_url = os.environ.get("CELERY_BROKER_URL")
celery.conf.result_backend = os.environ.get("CELERY_RESULT_BACKEND")
@celery.task(name
浏览 4提问于2022-08-08得票数 0
回答已采纳
我正在用 v3.1.25运行Python中的芹菜工人，用 v0.2.7运行node.js中的芹菜客户端(不是最新版本)。
使用Python芹菜客户端发送作业时，Python芹菜工人工作正常。
问题：当使用node-celery客户端向芹菜后端发送任务时，我们在JS控制台中得到一个错误：
(STDERR)芹菜应配置json序列化器
Python芹菜工人配置如下：
app = Celery('tasks',
broker='amqp://test:test@192.168.1.26:5672//',
backend='amqp://
浏览 4提问于2017-05-01得票数 2
1回答
我使用芹菜和姜戈-芹菜-结果在我的Django应用程序。我的芹菜结果存储在后端，这就是celery.py的样子。
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "shoonya_backend.settings")
# Define celery app and settings
celery_app = Celery(
"shoonya_backend",
result_backend="django-db",
accept_content=["
浏览 2提问于2022-06-23得票数 1
回答已采纳
当我试图将一个任务传递给一个芹菜工人时，我得到了这个错误。这是回溯
Traceback:
File "/home/vivek/xpython/lib/python2.6/site-packages/Django-1.3-py2.6.egg/django/core/handlers/base.py" in get_response
111. response = callback(request, *callback_args, **callback_kwargs)
File "/home/vivek/projects/e
浏览 0提问于2011-07-03得票数 1
回答已采纳
我正在尝试将对我们API的POST请求调用卸载到Celery，因为我们很快就会每秒向我们的API发送多达10个请求，每个请求都将在我们的DB中创建超过100个对象。我想我可以把它们添加到一个队列中，然后让Redis + Celery来处理，然后再从那里开始工作。
不过，我遇到了一些问题。
首先，我的芹菜设置：
########## CELERY
import djcelery
djcelery.setup_loader()
INSTALLED_APPS += ['expert.taskapp.celery.CeleryConfig']
CELERY_ACCEPT_CONTEN
浏览 2提问于2018-02-12得票数 1
我有一个芹菜应用程序，它必须被另一个应用程序点击。另一个应用程序使用json来序列化芹菜任务参数，但是我的应用程序有一个自定义的序列化协议。当另一个应用程序试图平平我的应用程序(app.control.ping)时，它会抛出以下错误：
"Celery ping failed: Refusing to deserialize untrusted content of type application/x-stjson (application/x-stjson)"
我的整个代码库依赖于这个自定义编码，所以我想知道是否有一种方法可以配置json序列化，但只用于这个ping，并继续
浏览 2提问于2021-08-23得票数 1
回答已采纳
我希望在Windows7和Python3.3上使用Celery / RabbitMQ在Flask应用程序中运行regualr间隔任务。Pip安装：
billiard==3.3.0.10
celery==3.1.6
代码：
### celeryapp.py ###
from celery import Celery
from twend import config, app
def make_celery(app):
celery = Celery(app.import_name, broker=app.config['CELERY_BROKER_URL'])
浏览 1提问于2013-12-03得票数 3
1回答
使用芹菜任务将文件上载到s3
、、、、
我正在尝试上传视频文件到s3，但后放入任务队列与芹菜。当视频被上传时，用户可以做其他的事情。
My views.py称芹菜任务为
def upload_blob(request, iterator, interview_id, candidate_id, question_id):
try:
interview_obj = Interview.objects.get(id=interview_id)
except ObjectDoesNotExist:
interview_obj = None
current_interview = in
浏览 0提问于2018-09-28得票数 5
1回答
我试图在Django 1.6.2应用程序中发送异步电子邮件，使用django- Celery -email和Celery 3.1.17，我的消息代理和结果后端是RabbitMQ 3.5.0。电子邮件被发送和接收，但我也得到错误“django.core.mail.不是JSON串行化”在我的芹菜日志中，当电子邮件发送。我在芹菜中使用JSON来序列化，因为泡菜是不推荐的。有什么方法可以改变我的配置来防止这个错误的发生吗？顺便说一句，当我不使用芹菜的延迟方法时，我可以发送电子邮件。
谢谢。
# Stacktrace
Task app.tasks.send_email with id 7ac1eb8e-
浏览 6提问于2015-04-03得票数 1
回答已采纳
2回答
我有一个Django REST框架的序列化程序，一个重写的方法。
在这个process_children，中，由于用户可以发送大量的子级，所以update有一个异步芹菜任务来处理这些孩子。
class MyModelSerializer(serializers.ModelSerializer):
....
@transaction.atomic
def update(self, mymodel, validated_data):
try:
children_data = validated_data.pop('child
浏览 0提问于2018-11-06得票数 2
2回答
所以问题是，当我试图从Django lpr.views.py页面调用main任务时，显示了加载图标，仅此而已，其他任何事情都不会发生。Django或芹菜控制台没有输出。当我尝试从python运行任务时，它没有问题地运行，并将结果保存在db中。我为测试目的添加了add任务，当我运行add任务时，它会返回一个错误，因为缺少'y‘参数，这是正常的。但是主要的任务是什么呢？
这是我的代码以防万一。
项目结构：
Project
├── acpvs
│ ├── celery.py
│ ├── __init__.py
│ ├── settings.py
│ ├── urls.py
│
浏览 0提问于2018-04-02得票数 0
回答已采纳
1回答
将芹菜画布序列化为json很容易，如下所示：
import json
from celery import Celery
from celery import chain
app = Celery()
@app.task
def add(a, b):
return a + b
@app.task
def mult(a, b):
return a * b
def main():
canvas = chain(add.s(1, 2), mult.s(2), mult.s(2))
print json.dumps(canvas)
if __name__ == '
浏览 0提问于2016-10-15得票数 2
2回答
我已经通过以下方式配置了celery来使用json：
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
但是，当worker收到任务时，它会生成以下错误：
ContentDisallowed: Refusing to deserialize untrusted content of type pickle (application/x-python-serialize)
是不是我遗漏了什么，可能是没有
浏览 0提问于2016-04-28得票数 7
2回答
我想将一个文件保存到AWS S3，我使用芹菜，因为我不想等到函数编写完该文件。问题是，当我将它发送到芹菜函数时，我可以看到，与实际的文件大小相比，AWS文件存储中的大小并不相同。
这是我把它送到芹菜的时候：
file_to_put = str(file_to_put) # because you can't send an object to celery fun
write_file_aws.delay(file_full_name, file_to_put)
芹菜本身的功能：
@celery.task(name="write_file_to_aws")
def wr
浏览 1提问于2020-05-17得票数 1
回答已采纳
我使用了feedparser模块来解析RSS。我需要将feedparser对象传递给一个celery任务。
在尝试传递该对象时，我收到一个错误，提示为time.struct_time(tm_year=2015, tm_mon=2, tm_mday=12, tm_hour=8, tm_min=19, tm_sec=11, tm_wday=3, tm_yday=43, tm_isdst=0) is not JSON serializable
如何将feedparser对象传递给celery任务？
以下是我的代码：
rss_content = feedparser.parse(rss_link)
c
浏览 0提问于2015-02-12得票数 1
有什么方法可以使用芹菜“撤销”任务？我需要能够手动重新启动以前撤销的任务。如果不可能，是否有一种方法可以复制已撤销的任务并启动一个具有完全相同参数的新任务？
下面是一个小小的例子：
app = Celery('tests', broker='redis://localhost:6379/0')
app.conf.update(
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0',
CELERY_TASK_SERIALIZER='json',
CELERY_A
浏览 2提问于2014-12-19得票数 0
回答已采纳
1回答
我有一个对象model_test_api，它是新的，如下所示。
import test_script
model_test_api = test_script.TestAPI(api)
需要新的api的TestAPI也是一个对象。
import model_api
api = model_api.Model_API()
我正在尝试下面的将model_test_api传递给celery任务。
1. another_function.apply_async(model_test_api)
2. another_function.apply_async(lambda: test_script.Te
浏览 11提问于2021-12-31得票数 0
我正在尝试用django构建Instagram机器人。我想实现django芹菜在后台运行任务。在这里我遇到了一些问题。
task.py
from celery import shared_task
from projects.services.instagram_bot import InstagramBot
@shared_task
def lazy_post_link_1_task(post_url, current_user, bot_id, email, password, time_interval, comments):
instagram_bot = Instagra
浏览 3提问于2020-01-24得票数 1
如何将django请求对象传递给celery worker。当尝试传递请求对象时，它抛出一个错误
Can't Pickle Input Objects
看起来芹菜序列化了传递给worker的任何参数。我尝试使用其他序列化方法，如JSON。
CELERY_TASK_SERIALIZER = "JSON"
但它不起作用。
有没有可能将celery配置为不序列化数据。或者，我是否可以在传递给worker之前将请求对象转换为字符串，然后再次转换回worker中的对象。
先谢谢你...
浏览 1提问于2012-07-11得票数 6
回答已采纳
在tasks.py方面，我这样做：
app = Celery(
main='tasks',
backend='rpc://',
broker='pyamqp://USERNAME:PASSWORD@localhost',
)
app.conf.task_serializer = 'pickle'
app.conf.result_serializer = 'pickle'
app.conf.event_serializer = 'pickle&#
浏览 5提问于2021-10-11得票数 0
基本上，我在celery上运行两个工作进程，不同的模块和不同的队列，但是相同的rabbitmq
celery worker -l info -A module_name.main.tasks -Q queue_one
celery worker -l info -A module_name.sub.sub_task -Q queue_two
当我尝试对1个模块上的第一个任务进行速率限制时，我从运行另一个模块的第二个工人那里得到了这个错误。
app.control.rate_limit('module_name.main.tasks.method', '30/m'
浏览 1提问于2015-01-28得票数 1
1回答
在django设置中有以下设置：
CELERY_TASK_RESULT_EXPIRES = timedelta(minutes=30)
CELERY_CHORD_PROPAGATES = True
CELERY_ACCEPT_CONTENT = ['json', 'msgpack', 'yaml']
CELERY_ALWAYS_EAGER = True
CELERY_EAGER_PROPAGATES_EXCEPTIONS = True
BROKER_URL = 'django://'
CELERY_RESULT_BACKEND=&
浏览 4提问于2014-06-19得票数 1
回答已采纳
1回答
如果我正确理解本教程，芹菜子任务支持与任务几乎相同的API，但它还有一个额外的优势，即它可以传递给其他函数或进程。
显然，如果是这样的话，芹菜只会用子任务代替任务，而不是两者都保留(例如，@app.task装饰师会将函数转换为子任务，而不是任务，等等)。所以我一定是误会了什么。
子任务所不能完成的任务能做什么呢？
芹菜API变化很大；我的问题是针对3.1版的(目前是最新的)。
编辑：
我知道医生说子任务是从其他任务中调用的。我的问题是，什么能阻止芹菜完全摆脱任务，到处使用子任务？它们似乎严格地比任务更灵活/更有力：
# tasks.py
from celery import Celery
ap
浏览 6提问于2016-10-02得票数 8
1回答
我正在尝试建立Django &芹菜和兔子，这是第一次遵循这个。我在Windows上使用Django 2.0芹菜4.2.0和兔子
我收到了错误: celery.exceptions.NotRegistered：'GeneratePDF‘
我已设置如下：
在我的init.py：
from __future__ import absolute_import, unicode_literals
import celery
from .celery import app as celery_app
__all__ = ['celery_app']
在我的celery.p
浏览 1提问于2018-11-02得票数 0
回答已采纳
升级后我会得到ERROR EncodeError(TypeError('6JQAKHNMG9 is not JSON serializable',),)。
成功安装：
amqp-2.1.4
billiard-3.5.0.2
celery-4.0.2
kombu-4.0.2
pytz-2017.2
(最初用于安装花卉0.9.1 )
正在奔跑：
amqp==1.4.9
billiard==3.3.0.23
celery==3.1.23
kombu==3.0.35
pytz==2016.10
现在我明白了：
05/10/2017
浏览 2提问于2017-05-10得票数 0
回答已采纳
2回答
技术堆栈如下所示：
Django前端和后端
用于异步处理耗时任务的芹菜工人队列
在过去的一两天里，我注意到许多这样的堆栈跟踪在本地和生产中都是这样的：
[2012-07-05 20:31:01,583: CRITICAL/MainProcess] Task site_endpoint.tasks.async_inbound_message[a950736c-ff93-420c-9fbf-6deb2b88ff4d] INTERNAL ERROR: TypeError('__init__() takes at least 3 arguments (1 given)'
浏览 0提问于2012-07-06得票数 1
回答已采纳
如何跨不同的Celery任务持久化API对象？我有一个API对象，每个用户都有一个经过身份验证的会话(python请求)来进行API调用。随每个请求一起发送user_id、csrftoken等。
我需要在Celery中调度不同的任务来执行API请求，而不需要为每个任务重新进行身份验证。
我该怎么做呢？
浏览 9提问于2017-02-24得票数 1
回答已采纳
1回答
我正试着用芹菜来执行一项任务。我需要在用户按下send按钮时向远程服务器发送post请求，因此我尝试在设置文件中使用带有Redis的芹菜配置：
BROKER_URL = os.environ.get("REDIS_URL")
CELERY_RESULT_BACKEND = os.environ.get("REDIS_URL")
CELERY_ACCEPT_CONTENT = ["application/json"]
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER =
浏览 5提问于2021-12-17得票数 1
回答已采纳
1回答
芹菜任务状态显示待定
、、、
我正在与芹菜工作，我得到的任务状态是待定的，可能是执行问题。请检查我的密码。
我试图在mongodb数据库中保存任务信息，如id、name、status，为此，我使用任务调用的函数来保存mongodb中的数据。
因为函数调用发生在任务返回语句之前，所以我的任务挂起了吗？？
settings.py
CELERY_BROKER_URL = 'mongodb://localhost:27017/jobs'
CELERY_RESULT_BACKEND = "mongodb"
CELERY_IGNORE_RESULT = False
CELERY_TRACK_STARTE
浏览 0提问于2018-12-31得票数 1
回答已采纳
我有一个快速的API，在这里我使用芹菜来预测任务队列。每当我进行预测并试图返回一个响应时，我就会得到500 Undocumented Error: Internal Server Error，并从docker日志中收到一个错误。
[2022-04-18 10:49:51,965: INFO/MainProcess] Connected to redis://redis:6379/0
[2022-04-18 10:49:51,969: INFO/MainProcess] mingle: searching for neighbors
[2022-04-18 10:49:52,980: INFO/
浏览 24提问于2022-04-18得票数 1
2回答
芹菜工人有时只会接任务。
、、、、
我正在构建一个可以在线访问的领先一代门户网站。请不要介意代码的冗长，我现在正在做大量的调试。
我的芹菜工人没有始终如一地承担分配给它的任务，我不知道为什么。
奇怪的是，有时候它是100%完美的:终端中从来没有任何明显的错误。
我目前处于DEBUG = TRUE和REDIS作为代理！
芹菜启动工人终端命令和响应
celery -A mysite worker -l info --pool=solo
-------------- celery@DESKTOP-OG8ENRQ v5.0.2 (singularity)
--- ***** -----
-- ******* ---- Windows-
浏览 10提问于2020-11-09得票数 1
回答已采纳
我的工作和任务在我的实施中。作业基本上是带有参数的函数，它们返回Signature (1个任务)或_chain (2个或多个被链接的任务)，其中一些任务是可变的，有些任务是不可变的。
我通过创建每个作业返回的Signature或_chain链来组合多个作业。
应用程序要求：
经纪人: RabbitMQ
结果后端: PostgreSQL
套餐：
celery==4.3.0
kombu==4.6.7
示例：
def example_job_1(arg_1, arg_2, **kwargs):
example_task_1_s = task_1.si(arg_1)
example_t
浏览 0提问于2020-04-22得票数 1
1回答
我想用芹菜在时间延迟后发送一些信息。用户收到消息后，其触发的新状态。为此，我需要将telebot.types.Message对象作为参数发送到芹菜任务中。我怎么才能正确地做这件事？
我的过渡职能是启动芹菜任务：
def delay_message(self, event):
celery_utils.delay_message.apply_async(kwargs={'response': self.response}, countdown=1) # self.response is telebot.types.Message
芹菜任务：
@celery.ta
浏览 6提问于2019-11-04得票数 1
回答已采纳
有没有一种方法可以将请求复制到Flask中的celery任务中，使任务在发起任务的请求上下文中执行？
我需要在一个celery任务中访问flask安全性当前用户，但是由于该任务在请求上下文之外，所以我不能这样做。我需要来自请求的额外信息，因此仅将当前用户转发到任务不会起到作用。
我的任务在数据库上执行插入操作。它需要当前用户保存创建行的用户的id。将user对象传递给任务就可以解决问题。然而，应用程序的逻辑是这样的:每次插入/删除/更新都通过刷新前事件进行记录，该事件记录进行修改的用户、他的IP、原始url、它插入的数据...)
日志事件就像我在刷新之前所说的那样，它在99%的情况下都有效。但
浏览 0提问于2015-07-13得票数 7
2回答
我在学芹菜。在我的网站上，我让人们注册一个帐户。一旦他们创建了一个新的帐户，它将自动发送激活电子邮件到他们的用户电子邮件地址。
一切正常，但现在我想用芹菜异步发送电子邮件。
我使用RabbitMQ作为代理，版本3.1.5和芹菜3.1.7 (最新版本)，因为他们说这个版本不需要djcelery。所以我只需要安装芹菜。
我遵循了芹菜网站Configurate my django的指示。
proj
--proj/celery.py
这是我的celery.py
from __future__ import absolute_import
import os
from celery import
浏览 3提问于2013-12-29得票数 16
回答已采纳
2回答
芹菜不执行任务
、、
请帮帮我，让我明白我做错了什么。芹菜不能完成我的任务。
Settings.py
CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE
浏览 0提问于2018-09-21得票数 2
堆叠：
Python v2.7
Django v1.11
Celery v4.3.0
Gunicorn v19.7.1
Nginx v1.10
当我尝试运行django服务器和芹菜时，手动执行异步任务。
当我使用django + Nginx部署Gunicorn项目时，问题就出现了。我试着使用Celery运行supervisor，但没有帮助。
views.py
def _functionA():
_functionB.delay() #where _functionB is registered async task.
settings.py
# Celery settin
浏览 0提问于2019-07-05得票数 0
回答已采纳
1回答
我刚刚设置了芹菜的第一个实例，并收到警告，要禁用泡菜作为安全问题的序列化程序。关掉它会带来什么后果？芹菜要做什么？
如果您依赖泡菜，那么您应该设置一个设置来禁用此警告，并确保升级到芹菜3.2:：
CELERY_ACCEPT_CONTENT = ['pickle', 'json', 'msgpack', 'yaml']
浏览 1提问于2014-04-06得票数 6
回答已采纳
我遵循教程，我在示例(add, mul)中看到的任务非常适合我。当我做res = add.delay(1,2); res.get()时，我得到了正确的反应。
但是，当我尝试执行另一个任务时，我得到了*** NotRegistered: u'pipeline.tasks.sayhello'，res = sayhello.delay('trex')。
如果我做了res = sayhello('trex')，那么只需输入res就可以得到结果。但以这种方式，我不使用芹菜就能很好地执行这个功能。
只有在Django shell ./manage shell
浏览 0提问于2016-11-11得票数 15
回答已采纳
1回答
我在celery中调用了一些任务一次，但是celery执行了三次。这是芹菜的预期行为还是配置错误？
我使用的是Django 1.5.11，Celery 3.1.23和Redis 3.0.6。
浏览 0提问于2017-05-22得票数 0
3回答
芹菜-金字塔马勒
、、
因此，我有一些简单的python代码，它们在普通python shell中运行得很好：
from pyramid_mailer.mailer import Mailer
from pyramid_mailer.message import Message
from pyramid_mailer.message import Attachment
mailer = Mailer(
host="172.10.10.240",
port="25")
message = Message(
subject="Orders with invalid
浏览 0提问于2015-07-22得票数 2
回答已采纳
1回答
我有一个简单的test_celery.py文件，包含以下内容，不会重新运行失败的任务：
from celery import Celery
import time
app = Celery(
'test_celery',
broker='amqp://',
backend='amqp'
)
@app.task(retries=4)
def my_fail():
try:
raise Exception()
except Exception as e:
print('T
浏览 0提问于2017-10-10得票数 0
我正在尝试获得一个进度条，以加载根据说明。
目前，这是我的观点。
def progress_view(request):
count_pag = 200
result = hello.tasks.my_task(8,request).delay(1)
context = {'task_id': result.task_id}
return render(request, 'display_progress.html', context={'task_id': result})
这是我的tasks.py
@shared_task(bind=True
浏览 14提问于2020-02-19得票数 0
回答已采纳
3回答
Django模型和芹菜周期任务
、、、、
我正在和Django.I一起做一个IoT项目，我不喜欢做繁琐的coding.The问题，因为我有一个模型名称句点，就像这样：
class Period(models.Model):
number = models.PositiveIntegerField(primary_key=True)
start_time = models.TimeField()
end_time = models.TimeField()
此外，我希望我的芹菜节拍在Period.end_time上做一些事情，我添加了这段代码。mysite/app/tasks.py中的代码。
@app.
浏览 10提问于2018-09-12得票数 0
1回答
我有一个类似Instagram的Django应用程序，用户可以上传照片或迷因，然后他们的粉丝就会收到这张照片的通知。
目前，为了发送通知，只要用户上传了照片，我就遍历上传者拥有的每个风扇，将通知附加到列表中，然后对对象进行bulk_create。如：
fans = UserFan.objects.filter(star=user).values_list('fan',flat=True)
fan_list = []
for fan in fans:
fan_list.append(PhotoObjectSubscription(viewe
浏览 3提问于2016-05-30得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
