Celery -任务Id最大长度？

文章/答案/技术大牛

发布

1回答

celery

我想将芹菜任务id存储在CharField我的Django数据库中的模型中。我需要指定最大长度。芹菜任务id的最大长度是多少？

浏览 27提问于2020-07-30得票数 1

回答已采纳

1回答

如何监控单个芹菜任务的内存使用情况？

celery、python-multiprocessing、celery-task、celeryd

我想知道一个celery任务的最大内存使用率，但从文档中看，没有一个celery监控工具提供内存使用率特性。如何知道一项任务占用了多少内存？我尝试用billiard.current_process获取pid，并在memory_profiler.memory_usage中使用它，但看起来current_process是工作者，而不是任务。

浏览 37提问于2020-04-23得票数 1

2回答

如何在芹菜工人中获取当前任务的撤销标志？

python、celery

我想在芹菜+ RabbitMQ broker上实现带有清理过程的任务取消。如何在芹菜工人中获取当前任务的“已撤销”状态？# tasks.py -- celery workerapp = Celery('tasks', broker='amqp://guest@localhostreturn x + y from tasks import add result

浏览 1提问于2015-03-05得票数 1

1回答

芹菜任务id在重新分发后会发生变化吗？

django、rabbitmq、celery

我有一个Django模型，其中有一个名为celery_task_id的列。我使用RabbitMQ作为代理。有一个名为test_celery的芹菜函数，它接受一个模型对象作为参数。Object') model_obj.save() ---- 现在，在celery函数中，我正在验证任务id</em

浏览 5提问于2017-01-20得票数 0

1回答

url:http://localhost:4000/generate-orders/get-orders : ProxyError: None:最大重试超过了

python、python-requests、celery

下面是用python编写的芹菜任务：def getOrders(): print rvar schedule = require('node-schedule'); var celery/cele

浏览 1提问于2017-03-17得票数 0

1回答

在Celery中从任务内部派生另一个任务

celery

我的需求是从Celery中的一个任务内部创建另一个任务。传递的参数将取决于父任务的输出。是的，我希望这是一种递归，它在某个点上停止(基于一些IF子句)。芹菜能做到这一点吗？我研究了Group/Chord/等子任务原语。然而，它们并不像我想要的那样灵活。有没有办法做到这一点？

浏览 2提问于2014-11-21得票数 0

1回答

如果请求在某一时间内未完成，该怎么办？

python、architecture、fastapi

如果在此期间执行请求，则给出答复，如果没有执行，则在指定时间结束时，提供某种请求ID，以便用户随后向另一个端点发送请求(例如/v5/check_ request )，该端点将使用请求ID提供有关请求的执行问题是如何在与客户端进行会话时实现任务执行和运行时检查。编辑I的想法是，API会将所有传入数据库的请求发送到数据库，然后一些“执行器”将从数据库获取数据，执行请求并更新状态。

浏览 4提问于2021-11-15得票数 0

3回答

从另一个函数内部调用Flask Celery* update_state*

flask、celery、celery-task

我想从另一个函数更新我的芹菜任务的状态。Celery任务-在后台启动some_python_script.handledef outside_function(param1param1, param2): # many, many different thingsdef t

浏览 0提问于2016-10-26得票数 5

2回答

如何从另一个主机上的另一个应用程序获取芹菜任务的结果

django、rabbitmq、celery

我使用django，celery和rabbitmq来处理任务，让我们称它为APP1。在另一台主机上，我使用了APP2，它需要从APP1中处理的任务中获取结果。

浏览 0提问于2014-10-15得票数 1

2回答

如何获取下一个芹菜task_id，或者如何从任务本身获取任务id (Flask)，或者如何为任务设置自定义id？

python、celery

我的flask应用中有一些芹菜：celery = Celery("DockerApp", broker=config['CELERY_BROKER_URL'])celery.conf.update(config)@celery.task some_task.request.id #not working#m

浏览 5提问于2015-02-09得票数 1

1回答

使用add_periodic_task动态设置芹菜(celerybeat)中的周期性任务

python、django、scheduled-tasks、celery、celerybeat

我在Django 1.10中使用Celery 4.0.1，在调度任务时遇到了问题(运行任务很好)。):在views.py中，我想安排此任务： app.add_periodic_task(10, my_task.s(id))sudo systemctl start rabbitmq.

浏览 0提问于2016-12-13得票数 12

回答已采纳

2回答

我是celery的新手，我试图将这个任务队列集成到我的项目中，但我仍然不知道celery如何处理失败的任务，我希望将所有这些任务都保留在amqp死信队列中。根据文档，似乎在启用了acks_late的任务中提高Reject会产生与and消息相同的效果，然后我们就有几句关于死信队列的话。} starting {1.name}[{1.request.id}]'.format(self.kwargs, einfo): logger.error('ta

浏览 1提问于2016-06-30得票数 20

1回答

当定义多个任务时，如何获得芹菜任务类型的任务状态和结果？

asynchronous、celery、task、celery-task

但这要求我知道在同一部署中定义了多个任务时的确切任务类型。当我可以知道任务状态和结果(如果可用的话)而不知道确切的任务时，有什么方法可以避免这种情况呢？#![2, 3]).id 我得到了两个任务。但是在检查任务状态时，我需要知道哪种方法(相加或乘)与该任务id相关联，因为我必须对相应的对象调用方法，如下所示。status: str = add.AsyncResult(task_id=t

浏览 4提问于2022-04-24得票数 0

回答已采纳

1回答

姜戈芹菜AsyncResult AttributeError：'DisabledBackend‘对象没有属性_get_task_meta_for

django、asynchronous、celery

我正在使用django芹菜(4.2)，我将从django视图中添加一些任务，我也希望在一个单独的进程中获得任务结果异步，但是当我试图获得结果时，我得到了一些错误。__all__ = ('celery_app', ) redis_conn.sadd(celery_task_set_key, result.task_id) 在这个步骤中，我将task_<e

浏览 4提问于2019-01-15得票数 1

1回答

Python -从另一个队列重试失败的芹菜任务

python、celery、django-celery

有时，由于互联网关闭，数据不会被发布到web服务中，并且在发布之前，任务会被无限次地重试。重新尝试这个任务是不必要的，因为网络已经关闭，因此它不需要再试一次。我想出了一个更好的解决方案(如果一个任务三次失败(重试3次)，那么它就转移到另一个队列。此队列包含所有失败任务的列表。现在，当互联网启动，数据在网络上发布(即任务已经从正常队列中完成)之后，它就开始处理任务队列中出现失败的任务。这不会浪费CPU内存来一次又一次地重试任务。Settings.py B

浏览 3提问于2014-08-25得票数 5

2回答

如何在django芹菜中传递queryset

django、django-celery

我想实现django芹菜在后台运行任务。在这里我遇到了一些问题。task.pyfrom projects.services.instagram_bot import InstagramBot

浏览 3提问于2020-01-24得票数 1

2回答

如何测量芹菜任务的持续时间

python、rabbitmq、celery、duration

有没有一种简单的方法来衡量芹菜任务被处理并成功完成所需的时间？有一个，但第一个答案很难看，不幸的是，信号并没有像第二个答案所建议的那样为我调用。Flower有一个Runtime列，但是它的应用程序接口不允许获取批量任务。

浏览 10提问于2016-01-01得票数 3

1回答

在Python中对Google Cloud服务使用多进程时出现SSL错误

python、ssl、multiprocessing、google-cloud-datastore、google-cloud-storage

sys.stderr.write('\rdone {0:%}'.format(i/len(self.files_ids))) file = File(file_id) file.process()print("Process finished by {}".format(file_id</em

浏览 36提问于2019-10-05得票数 2

回答已采纳

1回答

芹菜:已登记但未从django发射的任务

django、celery、celery-task

__init__.py__all__ = ['celery_app']from __future__import absolute_importfrom celery.schedules import crontabCEL

浏览 9提问于2022-07-10得票数 0

1回答

芹菜异步任务与周期任务

python、django、asynchronous、django-celery、celerybeat

无法同时运行周期性任务和异步任务。虽然，如果我注释掉周期性任务，异步任务可以很好地执行，但是其他异步任务会被卡住。似乎是一个众所周知的问题周期任务def send_ve

浏览 2提问于2018-02-06得票数 2

点击加载更多