celery 相关问题

Celery是Python的分布式任务队列框架，用于异步和并行执行。

计划的 Celery 任务从 Redis 中丢失

我在 Django 中使用 Celery，并以 Redis 作为代理。使用 apply_async 中的 eta 参数为将来安排任务。安排任务后，我可以运行 celery -A MyAppspect

django redis celery

回答 1 投票 0

Python：在 docker 容器上调试和自动重新加载

我的情况是：我正在开发一些docker容器。其中一个容器是 celery 应用程序，它从另一个应用程序获取一些任务并处理这些任务。当我在容器中工作时...

python docker debugging celery watchdog

回答 2 投票 0

在celery任务中访问request或request.user

我正在尝试在 django celery 任务函数中访问 request.user 但由于该函数不接受任何请求实例而无法访问，那么我该如何访问它？ @共享任务 def run_ever...

python django cron celery django-celery

回答 1 投票 0

celery 在 get_scheduler 上击败了 TypeError

尝试使用 Supervisor 设置运行 Python3.5、Django==1.10.2 和 celery==4.0.2 的 Celery，但在 site-packages/celery/beat 上收到此错误回溯（最近一次调用最后一次）：文件“/home/

python django celery

回答 2 投票 0

尝试使用 Celery+RabbitMQ 设置优先级队列时出现“PreconditionFailed - 队列的不等价参数‘x-max-priority’”错误

我有 RabbitMQ 设置，有两个队列：低和高。我希望我的芹菜工作人员在消耗低优先级队列的任务之前先消耗高优先级队列的任务。我得到以下信息...

python-3.x rabbitmq celery amqp priority-queue

回答 1 投票 0

使用 Celery 和 RabbitMQ 对 Django 项目进行 docker 化时出现问题

我正在尝试使用 Celery 和 RabbitMQ 来 dockerize 我的 Django 项目。我有一个 Docker Compose 文件，但无法使其正常工作。这是我的 Docker Compose 文件：服务：兔子MQ： ...

django docker docker-compose rabbitmq celery

回答 1 投票 0

Django Pytest 使用rabbitmq 和 celery 给出 Kombu 连接被拒绝[111]

目前我正在使用 pytest、django 和rabbitmq-server 以及 celery 来执行后台任务然而，我确实注意到，当我运行 pytest 而不在本地计算机上运行服务器时，它会导致很长的

django rabbitmq continuous-integration celery pytest

回答 1 投票 0

用 Celery 取消已经执行的任务？

我一直在阅读文档并进行搜索，但似乎找不到直接的答案：您可以取消已经执行的任务吗？（就像任务已经开始，需要一段时间，完成一半......

python django celery message-passing

回答 9 投票 0

芹菜陷入循环 - 为什么？

我是 celery 和 redis 的新手，我试图理解为什么 celery 有时会陷入循环并不断为一项小工作创建任务。请查看日志。我不确定这是否正常？我正在使用...

flask heroku redis celery

回答 1 投票 0

Scrapy Spider 错误：无法腌制本地对象 'Crawler.__init__.<locals>.<lambda>'

我想在 Celery（版本 5.3.4）任务中运行 Scrapy 蜘蛛（版本 2.10）。此外，我希望我的蜘蛛能够使用多重处理来工作。我已经定义了一个 CrawlerProcess 类...

python scrapy celery

回答 1 投票 0

如何从`django_celery_results`中的`TaskResult`模型加载`task_kwargs`？

我正在使用 django_celery_results 来保存一些 celery 任务的结果。每个任务都获取 kwargs 作为输入，最后保存在 TaskResult 的 task_kwargs 字段中。我无法加载这些...

django celery celerybeat

回答 2 投票 0

如何从另一个模块接收celery任务

我可以成功从我的主应用程序接收芹菜任务 - 但是，我的系统无法从另一个模块接收任务。我在远程 Ubuntu 服务器上使用 celery 的主管。草稿1是我的...

python django celery supervisord

回答 2 投票 0

如何在Django中使用Celery根据模型字段来调度任务并动态更新？

我在使用 Django 开发应用程序并使用 Celery 根据模型字段安排任务时遇到了挑战。我想分享我的解决方案并寻求有关潜在改进的建议......

django celery task scheduling

回答 1 投票 0

我们可以用Beanie进行同步查询吗？

我正在使用 FastAPI、Beanie 和 Celery 开发一个网络服务器。 ODM 的异步特性在编写路由器时很有用，但有些地方不需要它。例如，在

python-3.x mongodb celery fastapi odm

回答 1 投票 0

如何序列化ndarray列表？

我有一个脚本，可以逐帧读取视频并将它们累积在双端队列中。 labelled_frame_dequeue = [numpy.ndarray, numpy.ndarray,numpy.ndarray, numpy.ndarray] 我正在尝试通过这个列表...

python celery numpy-ndarray celery-task

回答 2 投票 0

使用 Celery 在 Redis 中缓存昂贵的结果（用于 Flask 应用程序）

我的问题：我的主页在初始化时有一个特别昂贵的过程（需要 10-15 秒才能完成，包含各种 SQL 查询并返回 JSON 对象）。我想要这个过程...

python docker flask redis celery

回答 1 投票 0

如何为scrapy项目设置celerybeat？

我有一个 scrapy 项目，我想每天运行我的蜘蛛，所以我使用 celery 来做到这一点。这是我的tasks.py 文件：从芹菜导入芹菜，shared_task 从 scrapy.crawler 导入 CrawlerProcess ...

scrapy celery django-celery celerybeat django-celery-beat

回答 1 投票 0

使用 --pool gevent 启动时 Celery 抛出错误，但其他情况下工作正常

我有一个芹菜任务，如下所示：从芹菜进口芹菜从 asgiref.sync 导入 async_to_sync 从 celery_app.celery_commands 导入 some_async_command 导入操作系统 redis_connection_string = os.envi...

python celery gevent

回答 1 投票 0

在 Django 中当 celery 任务正确结束时运行函数

我正在使用 Django 和 Celery，并且我正在正确执行 Celery 任务 @shared_task(绑定=True) def start_serial_acquisition(self, idObj, porta_COM): 和 start_serial_acquisition.delay（实例....

django celery

回答 1 投票 0

将自定义弹性beanstalk日志获取到cloudwatch组

遇到问题并且无法从 .ebextentions/logs.config 创建自定义 cloudwatch 日志组这是我尝试过的不同文件。 1 --- 文件： /opt/elasticbeanstalk/tasks/bundlelogs.d/

logging amazon-elastic-beanstalk celery amazon-cloudwatch

回答 2 投票 0

celery 相关问题

最新问题