芹菜后端连接如何添加重试？
芹菜后端连接添加重试的方法是通过使用重试策略来处理连接失败的情况。重试策略可以在连接失败后自动尝试重新连接，以提高连接的可靠性和稳定性。
在芹菜后端连接中，可以使用以下方法来添加重试：
- 设置最大重试次数：可以通过设置最大重试次数来限制重试的次数。当连接失败时，系统会自动尝试重新连接，直到达到最大重试次数为止。
- 设置重试间隔：可以设置重试间隔，即每次重试之间的等待时间。通过设置适当的重试间隔，可以避免频繁地进行连接重试，减轻服务器负载。
- 使用指数退避策略：指数退避策略是一种常用的重试策略，它会在每次重试时增加等待时间，以避免同时发起大量的连接请求。可以根据具体情况设置初始等待时间和增长因子。
- 异常处理：在连接过程中，可能会出现各种异常情况，如网络超时、连接被拒绝等。可以通过捕获这些异常并进行相应的处理，例如记录日志、发送通知等。
- 监控和报警：可以通过监控系统来实时监测连接状态，并设置相应的报警机制。当连接失败时，系统可以及时发送报警通知，以便及时处理。
推荐的腾讯云相关产品：腾讯云云服务器（CVM）、腾讯云负载均衡（CLB）、腾讯云弹性伸缩（AS）等。
腾讯云产品介绍链接地址：
- 腾讯云云服务器（CVM）：https://cloud.tencent.com/product/cvm
- 腾讯云负载均衡（CLB）：https://cloud.tencent.com/product/clb
- 腾讯云弹性伸缩（AS）：https://cloud.tencent.com/product/as
相关·内容
2回答
当启动芹菜时，它会重试连接到我的rabbitmq代理，这给了它必要的时间加载。这很好，因为我使用的是docker，我不能保证服务启动的顺序，也不能保证什么时候服务会启动。
然而，在试图连接到我设置为结果后端的本地mysql服务器时，芹菜并没有使用相同的怜悯措施，而是立即死亡，并合理地抱怨它无法锁定mysqld套接字：
OperationalError: (2002, "Can't connect to local MySQL server through socket '/var/run/mysqld/mysqld.sock' (2)")
我想在放弃之前
浏览 3提问于2017-08-21得票数 6
回答已采纳
我使用Redis broker和数据库结果后端( Postgres DB )运行Django芹菜，这与我在主应用程序中使用的相同。
最近，我遇到了这样一种情况: Postgres服务器被重新启动，而工作进程失去了它们的DB连接。在这种情况下，即使DB返回并且主Django站点正常响应，也没有芹菜任务再次成功。在进行任何处理之前，我需要重新启动celeryd进程。所有芹菜任务都报告了相同的错误：
DatabaseError: terminating connection due to administrator command
SSL connection has been closed une
浏览 2提问于2013-08-14得票数 3
回答已采纳
1回答
在我们的环境中，我们在AWS上使用RabbitMQ和芹菜在多个节点上并行运行任务。
最近，我们将RabbitMQ转换为一个由3个节点组成的集群，配置了一个ha策略，并在所有3个节点中添加了一个用于端口5672的AWS弹性负载平衡器(ELB)。我们的芹菜工人和客户代码都使用ELB DNS作为代理URL。
我们注意到，自该更改以来，等待异步任务完成将引发异常IOError: Socket closed。
ELB将在60秒后关闭所有空闲连接。我们有几个小时才能完成的任务。
在员工端将BROKER_HEARTBEAT设置为低于60个已解决连接下降值。但是我们似乎找不到任何能保持客户端连接活动的设置。
浏览 2提问于2016-12-08得票数 15
我正在使用芹菜节拍和工人来检索最新的新闻每30分钟。到了晚上，当我的电脑睡着的时候，互联网连接就断了。然后，在早上，相同的任务想要运行几次，以弥补失败的尝试。在连接中断的情况下，如何不堆积这些任务？
在Django的Admin部分，有一个名为"Expires timedelta with seem“的选项，但它似乎不能满足我的需要。有什么建议吗？
浏览 1提问于2021-03-04得票数 2
1回答
芹菜挂好()
、、
几乎完全复制了，但答案对我没有帮助。我安装了Erlang，芹菜和RabbitMQ，并设置了芹菜，以AMQP作为后端和代理。我一直遵循 (创建一个将两个数字相加在一起的任务)，但是当我发出result.ready()命令时，芹菜进程就挂起了。
这不是一个auth问题(四次检查和测试无效登录)
它不是一个磁盘空间外的错误，根据前面的所以问题(>800 It免费)
工作人员正在启动和运行(“使用者:准备接受任务！”)
MQ已启动并正在运行(“代理运行”)
我可以看到芹菜连接到RabbitMQ (“接受->连接(ip -> ip)")
我认为这是我的P
浏览 2提问于2013-10-09得票数 1
1回答
当出现错误时，我如何从代码中停止芹菜？例如，redis或数据库已关闭。 例如，如果init函数出现异常，我可以停止连接 @stop_if_error
@signals.worker_process_init.connect
def init_method(*_, **_):
#some init code 但是，如果worker作业正在进行并且出现异常，如何停止呢？
浏览 8提问于2019-10-03得票数 1
我正在使用django + redis +芹菜。它起作用了:任务是排队并执行的。
无法连接到redis:// localhost:6379 //: Error 111，连接到本地主机:6379。连接被拒绝
如果我检查我的redis-server进程的正常运行时间，我会发现它是从错误开始之前开始的，所以它从未崩溃或其他任何事情。
知道怎么回事吗？我能查些什么看看发生了什么？
谢谢!
浏览 2提问于2017-06-12得票数 1
我的任务是：
@celery.task(name='request_task',default_retry_delay=2,acks_late=True)
def request_task(data):
try:
if some_condition:
request_task.retry()
except Exception as e:
request_task.retry()
我在mongodb和mongodb结果后端启用时使用芹菜。
当任务的ret
浏览 4提问于2012-08-10得票数 12
我正在使用rabbitmq和celery来执行后端任务，我想使用相同的rabbitmq来进行dev/test，但不希望出现有人意外地将celery工人用于生产队列并将其用于dev/test的情况。如何保护芹菜队列不被任何也可以访问同一rabbitmq后端的芹菜工人访问，如果这是可能的话。
浏览 2提问于2017-11-01得票数 0
我正在编写一些软件，它将通过间歇的 (或类似的)连接来管理“字段”中的几百个。
家庭基地需要将作业发送到该领域的系统(例如，“关于您的状态的报告”、“更新您的软件”等)，并且该领域中的系统需要将作业发送回服务器(例如，“检测到了故障”、“这里有一些数据”等)。
我花了一些时间研究，这似乎非常合适:在本地运行的celeryd可以为该领域的系统收集作业，在外地系统上运行的celeryd可以为服务器收集作业，这些作业可以在客户端可用时进行交换。
那么，芹菜适合这个问题吗？具体地说：
大部分任务将被分配给单个员工(例如，“将‘get_status’作业发送到‘system51’)--这会是一个问题
浏览 3提问于2010-10-03得票数 6
回答已采纳
1回答
目前，我有一组任务并行运行，当发生错误时，芹菜将重试任务发送回队列并继续执行队列中的下一个任务，但是下一个任务也将面临同样的错误并导致重试。我只在第三次重试时解决了问题，因为大多数情况下，只要重试任务就能完成任务，所以队列中的每个任务都不必要地经过这个重试阶段3次，在解决问题之前，如果我可以强制芹菜在本地执行重试任务，这是可以避免的。所以无论如何都要告诉芹菜在本地重试任务？
浏览 2提问于2022-06-22得票数 0
1回答
我有一个使用WSGI的烧瓶应用程序。对于一些任务，我计划在RabbitMQ中使用芹菜。但正如标题所说，我面临的问题是芹菜的任务持续了几分钟，然后经过很长一段时间的不活动，它就会消失。
芹菜配置：
CELERY_BROKER_URL='amqp://guest:guest@localhost:5672//'
BROKER_HEARTBEAT = 10
BROKER_HEARTBEAT_CHECKRATE = 2.0
BROKER_POOL_LIMIT = None
在问题中，我添加了BROKER_HEARTBEAT和BROKER_HEARTBEAT_CHECKRATE。
我在v
浏览 0提问于2018-08-29得票数 1
回答已采纳
如何将使用AMQP后端的芹菜4配置升级到芹菜5，它已经放弃了这种支持，现在要求您使用RPC后端？
升级到芹菜5.1.2之后，我收到了以下错误：
ModuleNotFoundError: No module named 'celery.backends.amqp'
我料到的。但是，尚不清楚rpc后端是如何替换它的。
我的CELERY_BROKER_URL看起来像amqp://guest:guest@127.0.0.1:5672/myvhost，它访问RabbitMQ。
我尝试将其更改为rpc://guest:guest@127.0.0.1:5672/myvhost，并将CELER
浏览 3提问于2021-10-06得票数 0
我已经在Azure API Management中创建了一个API来从后端API获取数据。 来自后端API的结果被分页，在响应中包括必须用于下一个请求的' next‘url。 如何处理这个“下一个”url，以便通过Azure APIM连接所有分页响应并将所有分页响应的总和作为一个响应返回？
浏览 9提问于2019-03-18得票数 1
我有一个芹菜队列，我想要根据某些触发器等以编程方式从队列中拉出下一项。
如果我有一个任务定义为
@task
def my_task():
do_stuff()
，然后通过以下方式将项放入队列
my_task.apply_async()
芹菜将尽可能快地遍历队列中的项目。但我希望能够做到的是：
my_task.process_next()
有没有办法控制芹菜何时从队列中取出东西？
浏览 0提问于2015-10-09得票数 1
1回答
芹菜如何进行蓝绿调配？
、、、
我在担心芹菜的部署。
所以我正在寻找安全的部署，比如芹菜的蓝绿色部署。
但是对芹菜来说这是可能的吗？如果芹菜工人在执行任务的过程中被杀死(分离)，该任务可能会失败。或者另一个工人试图捕获失败的任务，检测到芹菜工人被杀死(分离)？
有没有人尝试安全地部署celery worker代码？
浏览 0提问于2015-08-24得票数 0
1回答
我有许多耗时的任务需要由几台机器来分担。我现在有一台主机器，用芹菜工人来做这项工作。我使用RabbitMQ作为代理，使用redis作为本地运行在该机器中的后端。主计算机还负责部署任务和返回结果。
我想知道是否有可能让从机器远程连接到代理，并在主计算机中产生后端以获取作业，以便所有机器一起工作。我想我只需要配置RabbitMQ和redis设置，然后启动奴隶机器中的芹菜工人。非常感谢。
浏览 0提问于2015-07-16得票数 0
回答已采纳
我们使用带有rabbitMQ后端的芹菜，而我们的一些服务器挂错了："Errno 113没有主机路径“(这可能是我们一半的服务器在美国，一半在欧洲)。
我需要确保每个任务都已交付，不幸的是，我不知道如何重试使用send_task/string标识符发送的任务(发送任务的服务器没有访问远程工作人员代码的权限)如下：
send_task("remote1.tasks.add_data", args=[...], kwargs={}, queue="remote1")
是否有可能重新尝试这样的任务？
浏览 4提问于2011-07-26得票数 2
回答已采纳
1回答
学习芹菜，阅读，还有一个关于芹菜数据库使用的简单问题。
Deni Bertovic说：
不应该将数据库对象(例如，用户模型)传递给后台任务，因为序列化的对象可能包含陈旧的数据。
因此，如果我想连接到工作人员中的数据库，那么正确的选择是：
@app.task
def add(x, y, collection):
client = MongoClient('mongodb://localhost:27017/')
db = client.wakawaka
db[collection].insert_one({'sum':x+y})
浏览 10提问于2017-12-19得票数 4
回答已采纳
因此，我只是开始使用芹菜，并尝试做一些简单的测试来感受一下它。我正在尝试设置一个芹菜来使用postgres作为我的后端。在此页面上：
我看到了这个例子
celery = Celery('tasks', backend='redis://localhost', broker='amqp://')
因此在我的代码中，我尝试
celery = Celery('tasks',
backend='sqla+postgresql://celery_exp:celery_exp@myhost/celery
浏览 1提问于2013-02-01得票数 6
1回答
TL:博士，我想在后端找到结果。
我有一个酒瓶/芹菜项目，我对芹菜很陌生。用户发送一批用于芹菜工作的任务。芹菜将结果保存到后端SQL数据库(由芹菜自动创建的表，名为celery_taskmeta)。
我想让用户看到他的批处理的状态，并从后端请求结果。
我的问题是，所有的结果都在一张桌子上。我有哪些选项可以将这个批处理，这样用户就可以区分批处理了？
我的想法：
我能为每一项任务添加一个lable吗？“Bob的批次编号12”然后查询celery_taskmeta的结果如何？
我能把每一批批次放在命名的后端表中吗?所以请芹菜将结果保存到一个名为task_12的表中。
与团体一起尝试
浏览 4提问于2020-12-16得票数 0
我有以下芹菜任务(简化)，它与Twitter交互。
@app.task
def get_followers(screen_name, **kwargs):
cursor = kwargs.get('cursor', -1)
followers = kwargs.get('followers', [])
while True:
response = twitter_api.call('followers', 'ids', screen_name=screen_name, cursor=curs
浏览 3提问于2016-11-30得票数 1
回答已采纳
我有一个旧的WinForm应用程序，它使用连接到SQL的SQLClient。它过去在通过电线连接到办公室网络的桌面上工作得很好。现在，该应用程序已安装在通过WiFi DirectAccess连接到网络的笔记本电脑上。连接故障成为常见的问题。通常，连接错误发生在ADO.Net语句中，如Myconnection.Open()、MyDataTable.Load等。
我正在考虑将数据层移动到restful后端，并在WinForm前端使用WinForm获取数据。不过，我不知道这种做法会带来甚麽好处。请您建议哪种方法在对连接错误、性能和其他标准的弹性方面更好？
开发Web后端或
将ADO.Net代
浏览 3提问于2017-11-27得票数 0
回答已采纳
是否可能只将芹菜结果保存在特定参数上，例如失败的任务？
我一直在寻找，但唯一的办法，我可以管理的是回到芹菜的结果后端和解析数据以外的芹菜。
有更好的办法吗？
(注意:我使用mongodb作为芹菜结果后端。)
浏览 3提问于2020-08-12得票数 0
回答已采纳
1回答
有没有可能在高吞吐量的情况下，Task.delay会默默地被杀死？我正在使用芹菜与RabbitMQ作为后端。不完全了解芹菜的内部结构以及芹菜是如何控制行为的。
浏览 1提问于2017-01-27得票数 0
回答已采纳
我在Heroku上运行芹菜工人，其中一项任务达到了超时限制。当我手动重试时，一切正常，所以可能是连接问题。我使用RabbitMQ作为代理，并将Celery配置为执行任务的后期确认(CELERY_ACKS_LATE=True)。我希望任务返回到RabbitMQ队列并由另一个worker再次处理，但这并没有发生。当worker超时时，您还需要为任务配置其他内容以返回到RabbitMQ队列吗？
以下是日志：
Traceback (most recent call last):
File "/app/.heroku/python/lib/python3.4/site-packages/b
浏览 0提问于2015-09-04得票数 6
1回答
我有一个芹菜节拍任务，那就是运行其他抓取任务。当这些任务不被处理时，队列开始增长。
我知道芹菜使用后端db，但只有: id，task_id，status，result，date_done，traceback。
我的想法是从芹菜节拍切换到他们自己重新安排任务，但一些任务是不连接的或可能会丢失，所以芹菜节拍在这些情况下是有用的。
第二个想法是添加我的日志，比如我的表，我可以在其中保存task-id和任务上下文，通过它们我将能够发现任务是否已经存在。
也许你有更好的方法？谢谢
浏览 0提问于2018-09-12得票数 0
1回答
我在试着弄清楚芹菜是如何和什么时候清理任务的。通过查看，我发现：
根据CELERY_TASK_RESULT_EXPIRES设置，将自动清除旧结果。默认情况下，这将在1天后到期:如果您有一个非常繁忙的集群，您应该降低此值。
但是这个引用来自于RabbitMQ结果后端部分，我在数据库后端部分中没有看到任何类似的文本。因此，我的问题是:是否有一个后端不可知论的方法，我可以采取旧的任务清理芹菜，如果没有，是否有一个DB后端特定的方法，我应该采取？以防万一我用的是姜戈芹菜。谢谢。
浏览 3提问于2012-10-30得票数 11
回答已采纳
1回答
我有一个与芹菜图书馆集成的django项目。我怎样才能清除我的芹菜后端结果数据？
我正在使用django-db作为我的芹菜工人后端。
CELERY_RESULT_BACKEND = 'django-db'
浏览 1提问于2018-04-02得票数 1
回答已采纳
我使用芹菜和RabbitMQ作为代理，使用redis作为结果后端。我现在正在手动将任务分派给工作人员。一旦我发送了任务，我就可以获得任务I。但实际上芹菜工人并没有在他们身上工作。我在我的磁盘上看不到结果文件。稍后，当我想使用AsyncResult检查结果时，我当然得到了AttributeError: 'DisabledBackend' object has no attribute '_get_task_meta_for'
我检查了RabbitMQ和redis，它们都在工作(redis-cli ping)。日志中还写着Connected to amqp://my
浏览 0提问于2016-02-23得票数 0
我正在建设一个任务的网站，需要相当长的时间来处理，并需要大量的计算。我编写了代码，以便任务能够提供部分输出(产生结果)。我使用芹菜工人在另一台机器上运行任务，并设置使用update_state()发送更新的任务。
我的celery_tasks.py文件是这样的
@celery.task(name="my_task")
def my_task():
final_output = []
for output_part in long_process():
my_task.update_state(state="PROGRESS", m
浏览 4提问于2021-11-01得票数 1
1回答
我是Python和芹菜的新手--Redis，所以如果我的理解不正确，请纠正我。
我一直在调试一个代码库，它的结构类似-
TaskClass ->芹菜任务
HandlerClass1, HandlerClass2 -> --这些是扩展对象类的python类
应用程序创建TaskClass say dumyTask实例，dumyTask通过获取处理程序的签名创建芹菜子任务(我相信这些子任务是唯一的)，dumySubTask1, dumySubTask2。
我不明白的是什么？
1)芹菜如何管理dumySubTask1, dumySubTask2和dumyTask的结果？我的意思是，dum
浏览 2提问于2017-06-16得票数 0
我们正在使用芹菜eta任务来安排未来(就像几个月)的任务。现在使用rabbitMQ后端，因为mongo后端在工人重新启动时确实释放了这些任务。
实际上，带有rabbitMQ后端的任务在芹菜和rabbitMQ重新启动时似乎是持久的，但是撤销消息似乎在rabbitMQ重新启动时丢失了。我想，如果撤消消息丢失了，那些应该被终止的eta任务无论如何都会执行。
浏览 2提问于2014-04-09得票数 2
回答已采纳
2回答
我把芹菜分成以下几个部分
芹菜
芹菜工
芹菜守护进程
经纪人: Rabbimq或SQS
队列
结果后端
芹菜监测器(花卉)
我的理解
当我在django e执行芹菜任务时，g tasks.add(1,2)。然后芹菜把这个任务添加到队列中。我很困惑上面列出的是4还是5
WHen任务进入队列，然后worker获取该任务并从队列中删除
该任务的结果保存在结果后端。
我的困惑
芹菜守护进程和芹菜工人之间有什么区别？
是Rabbitmq在做队列的工作。这是否意味着任务保存在Rabitmq或SQS中？
花是做什么的。它是否监视工作人员、任
浏览 5提问于2016-04-26得票数 1
我一直在从事芹菜和AMQP的后端存储工作。我不喜欢它为每个任务/响应创建一个新的队列，我找到了新的RPC结果后端，它可以正常工作。
但是，这个在描述RPC后端时说：
新RPC结果后端这个新的实验版本的amqp结果后端是一个很好的替代方案，可以在经典RPC场景中使用，在中，启动任务的过程总是检索结果的过程。
这是什么意思？芹菜是否支持访问不同进程启动的任务的过程？这听起来很有趣，有什么关于我如何实现这一点的建议吗？
非常感谢,
浏览 1提问于2014-07-18得票数 1
2回答
在我的场景中，我们的后端希望对任何请求都获得唯一的ID，但我读到"OkHttp可能会在缓慢/不可靠的连接上‘积极’重复您的请求，直到它成功。“来自和一些OkHttp问题。我知道我可以用retryOnConnectionFailure(false)禁用重试机制，但我想启用它来处理连接问题。这正是我想要的，在静默重试之前修改请求。是否可以在发送静默请求之前进行拦截？
浏览 3提问于2020-12-18得票数 2
我有一个关于的后续/澄清问题。
我有两个服务器(目前)。1服务器运行django web应用程序。另一台服务器运行纯粹的python脚本，这些脚本是CRON计划的web应用程序的数据采集和处理作业。
在一个用例中，web应用程序中的用户活动(更新某个字段)应该触发后端服务器的一系列操作。我可以和克伦呆在一起，但随着我们规模的扩大，我可以想象会遇到麻烦。芹菜似乎是一个很好的解决方案，但我不清楚如何实现它。(是的，我看了入门指南)。
我希望web应用程序将任务发送到特定队列，但后端服务器实际执行工作。
假设两个服务器都使用相同的代理URL，
我需要在Djando中定义存根任务，还是只使用celer
浏览 2提问于2014-07-11得票数 1
回答已采纳
2回答
现在我有一些同步作业，它们是有状态的，所以如果任务失败，我必须取消确认消息，然后让它们转到RabbitMQ前面。但当我试图提出一个错误，我发现芹菜仍然承认这条信息，队列已被清除。
@celery.task(bind=True)
def my_task(self, *args, **kwargs):
raise ValueError
我发现芹菜任务有一个名为retry的方法，但是它会将任务添加到队列的后面。这不是我想要的。
@celery.task(bind=True)
def my_task(self, *args, **kwargs):
try:
raise
浏览 5提问于2020-06-12得票数 4
回答已采纳
1回答
我正在努力实现以下行为：
用芹菜拍打开始芹菜任务
工人被杀
一名新工人开始
任务又重新开始了
为此，我设置了acks_late=True标志和'visibility_timeout': 30
这意味着，如果任务在30秒内没有中断，则应该将一个新任务添加到队列中。
由于某种原因，这种情况不会发生。
浏览 0提问于2018-08-10得票数 0
1回答
我刚刚开始在一个有Redis代理和后端的Flask应用中使用芹菜。Redis实例在AWS上。我如何读取我的应用程序发送到redis，然后被芹菜工人接收的消息？ 即使我已经让它工作了-我对实际发生的事情并不是特别舒服。我在哪里可以了解到更多关于如何将消息发布到redis，以及芹菜工人如何阅读消息的信息。
浏览 11提问于2019-03-14得票数 0
1回答
在芹菜中查询结果后端的所有结果的最简单方法是什么？我使用一个MySQL数据存储作为我的结果后端。
芹菜将结果存储为BLOB类型，因此我无法以纯文本的形式检索结果。
如果您想知道我为什么要这样做，用例是查询所有由芹菜执行的任务的结果。
浏览 0提问于2019-04-28得票数 1
回答已采纳
我刚接触芹菜。我有一个芹菜任务，需要在满足条件时执行。否则，请在几分钟后重试。从下面的代码中，我被困在如何在else条件下重试相同的任务？感谢你的帮助。
@app.task(bind=True,soft_time_limit=4 * 3600)
def task_message_queue(id, name=None, tid=None, src=None, dest=None, queue="MessageQueue"):
ThreadLocalStore().set_data({"id": id, "tid": tid, "na
浏览 18提问于2017-06-19得票数 1
回答已采纳
2回答
我有一个带有RabbitMQ代理的芹菜服务器。我使用它在我的Django项目中运行后台任务。
在我的一个视图中，一个信号被触发，然后调用一个芹菜任务，如下所示：
create_something.delay(pk)
任务定义如下：
@task
def create_something(donation_pk):
# do something
一切都很好，但是：
如果在调用任务时RabbitMQ关闭，则在create_something.delay(pk)调用期间不会抛出任何错误。但是视图抛出了这个错误：
[Errno 111] Connection refused
(堆栈跟踪有点没用，
浏览 0提问于2015-09-23得票数 1
我有一个Django项目，需要发送大约600封电子邮件。我已经准备好芹菜了，而且大部分都很管用。我有Django项目设置使用我的谷歌应用程序(商业版本--即:付费)电子邮件帐户作为发送帐户。为了测试的目的，我把每一封电子邮件都发给了我，而不是给客户。
我现在面临的问题是芹菜似乎随机地跳过了名单上的人。当我开始发送所有600封电子邮件的过程时，芹菜工作，发送电子邮件(我可以看到它们出现在我的收件箱中)，但我总共只收到了420封电子邮件。当芹菜吃完后，仍有大约180人需要电子邮件。如果我再次点击“发送电子邮件”，只有剩下的180人，它将完成这项工作，并在两次尝试结束后，将向所有600人发送电子邮件
浏览 2提问于2012-01-12得票数 1
回答已采纳
我的环境由django、芹菜和mongodb作为后端组成。
我成功地使用djcelery管理界面创建了一个周期性任务，在启动celery节拍之后，我可以看到它正在运行。这个任务很简单:它只是添加了芹菜教程中提出的两个整数。
我使用以下命令行启动celeryd
python manage.py celeryd -E -l INFO -设置=设置
使用以下命令行击败：
python manage.py celery节拍--设置=设置
最后，celerycam拍摄我的任务的快照：
python manage.py celerycam -设置=设置
当我试图在djcelery管理员中显示芹
浏览 0提问于2012-01-23得票数 1
回答已采纳
在我的Django应用程序中，我使用芹菜处理运行时间很长的任务。其中一项任务必须在最后将一条记录写入数据库，以确认该过程已完成。由于某种原因，如果任务持续这么长时间(在这里谈论4个小时或更长时间)，我就会得到以下结果：
ConnectionResetError: Errno 104连接由对等方重置
当我在任务结束时触发对数据库的写操作，就会发生这种情况，例如：
Files.objects.filter(pk=files_obj).update
... etc
很想知道为什么对等方重置连接(在我的例子中是MariaDB)。Django不是用连接池为我管理数据库连接吗？我还检查了Djang
浏览 2提问于2022-06-02得票数 0
回答已采纳
2回答
我有芹菜任务，100输入数据在队列中，需要执行使用5名工人。
如何获得哪个工作人员正在执行哪个输入？
每个工人执行多少输入和它的状态？
如果任何任务失败，如何单独获得失败的输入数据并与可用的工作人员一起重新执行？
是否有任何可能的方法来定制芹菜根据工人的具体情况。
我们可以把芹菜工人限制和花结合起来。
我没有使用任何框架。
浏览 3提问于2016-01-12得票数 3
2回答
我已经设置了一个芹菜任务，它使用RabbitMQ作为代理，使用Redis作为后端。运行之后，我注意到我的Redis服务器仍在使用大量内存。经过检查，我发现创建的每个任务仍然有密钥。
只有在收到回复后，才有办法让芹菜清理这些钥匙吗？我知道有些MessageBrokers用的是ack，在芹菜中有相当于红色后端的东西吗？
浏览 3提问于2017-11-08得票数 0
回答已采纳
我试着测试一些我在芹菜里运行的周期性任务，这些任务应该在每个月的第一天午夜运行。为了测试这些功能，我每隔几分钟运行一次cron任务，这会使系统的时间在这个月的最后一天午夜前几分钟出现颠簸。当时钟敲响午夜时(每隔几分钟)，任务就不运行了。
所有的时间都是UTC，芹菜被设置为UTC模式。
芹菜本身工作正常，我可以手动执行任务。这到底是怎么回事？另外，芹菜如何跟踪系统时间的调度，如何处理系统时间更新？难道是芹菜的时间和系统的时间不同步了吗？
这是芹菜3.1.0，带有redis作为代理/后端
浏览 3提问于2014-04-09得票数 1
回答已采纳
我正在使用Azure iot sdk c，有时我的iothub服务可以达到最大配额，我可以看到连接错误或后端无法获得数据，但显然无法检查连接错误是否是由于达到了最大配额。
同时，我可以从SDK中看到下面的日志，但不确定up层是否能得到这些消息：
{true,2,NULL,true,* {* {amqp:resource-limit-exceeded,Total number of messages on the IoT Hub exceeded the allocated quota. Increase units for this hub to increase the quota. For
浏览 12提问于2022-03-12得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
