celery-task 相关问题

celery-task是Celery分布式任务队列系统的构建块

我有以下代码： def create_pipeline( 真实：数据框，预测名称：str， energy_asset_id：int，家庭：str，预测范围：日期范围，方法论：L...

python celery celery-task

回答 1 投票 0

我有一个 psycopg ConnectionPool 扩展了 Flask 应用程序： def init_pool(cfg, connection_class, name) -> ConnectionPool: 池 = 连接池( conninfo=f"postgresql://{cfg['u...

python python-3.x flask celery-task psycopg3

回答 1 投票 0

当在类中定义方法时，Python Django 无法运行 celery

我是 celery 新手，现在我正在使用它在后台计算 Django 任务。我遇到的问题可以使用下面的类方法来演示，我在其中定义了 3 个函数...

python-3.x celery django-celery celery-task

回答 1 投票 0

如何序列化ndarray列表？

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

python celery numpy-ndarray celery-task

回答 2 投票 0

有没有有效的方法来检索特定队列中当前正在执行的 celery 任务的数量？

我想知道当前正在执行的 celery 任务和等待任务的数量。然而，所有的 celery 检查命令都显示不正确的结果，并且使用它们似乎并不容易。我的芹菜信息...

rabbitmq celery django-celery celery-task

回答 1 投票 0

如何在celery中指定SQS队列名称

我需要用 SQS 代理替换我的 Redis 代理，在 google 搜索时我发现了很多页面，告诉我如何将 SQS 与 celery 结合使用。根据我的理解，它创建了自己的SQS队列，我只有......

python asynchronous celery amazon-sqs celery-task

回答 5 投票 0

Python celery - 如何等待和弦中的所有子任务

我正在对 celery 任务进行单元测试。我的连锁任务也有组，所以产生了一个和弦。测试应该如下所示：运行 celery 任务（延迟）等待任务和所有子任务断言我尝试...

python celery celery-task chord

回答 3 投票 0

如何在 celery 中测试 on_failure

我的 celery 任务有一个基类，其中实现了 on_failure 方法。在我的测试中，我修补了任务调用的方法之一，以引发异常，但 on_faliure 从未被调用。

python unit-testing celery celery-task

回答 2 投票 0

Celery 工作人员未正确执行任务（正在从beat 接收任务）

我正在尝试将 celery-redis 组合添加到我的 django 项目中。安装了 celery、django-celery-beat 并进行了其他设置。我编写了一个简单的任务来在电报中向我发送消息（在...

redis scheduled-tasks django-celery celery-task celerybeat

回答 0 投票 0

如何获取属于 Celery Canvas 的所有任务的信息？

我在芹菜中有多个任务。我使用链条、组和和弦的混合搭配来运行它们。但是，我仍然不知道如何访问所有已执行的任务（按执行顺序）...

python celery task-queue celery-task celery-canvas

回答 0 投票 0

Django celery - Django Admin 中的任务结果为空

我已经按照教程设置了celery/redis相关设置。 celery 任务可以成功运行，但 django admin 中的“任务结果”为空，记录为 0。这是我的

django celery django-celery celery-task

回答 0 投票 0

即使我在 task_prerun 上抛出异常，Celery 任务仍在执行

我需要在 celery 任务执行之前对其进行一些基本验证。当任务分配给工人时，我需要执行此验证，因为我需要检查工人是否...

celery fastapi celery-task

回答 0 投票 0

Python异步并发对象问题使用Celery模块，报错

我正在使用 Celery 模块运行异步并发对象，但是当我使用 LetView.delay() 调用该函数时，会报错 Celery 函数代码 ChatGPT 帮助代码是你...

python-3.x celery celery-task celerybeat

回答 0 投票 0

Telnet 连接被 docker 拒绝

我正在尝试在我的 docker flask 项目中使用 telnet 来使用 rdb 调试 celery 任务。为此，我在我的 dockerfile 中安装了 telnet，然后为了测试它我使用：docker-compose exec web bash, web being

docker celery telnet worker celery-task

回答 0 投票 0

重写 Celery 任务类以在任务之间共享变量

我正在尝试实现一个任务，其中全局变量在两个不同的 Celery 任务之间共享。为此，我继承了任务类并使用了属性。根据芹菜文档，基础......

python django django-celery celery-task

回答 2 投票 0

celery postgres 后端不存储重试次数

上下文失败的任务按预期重试 postgresql 后端不存储失败任务的重试次数测试这些返回无， AsyncResult(task_id='some_taskid', app=app).retries 选择...

python-3.x celery celery-task

回答 0 投票 0

类型的对象不是 JSON 可序列化的 Django

Django 项目 - 发送电子邮件。有一个视图函数接收 POST 请求，循环遍历数据库中的所有电子邮件并将请求参数传递给 Celery 任务。赛勒...

django celery django-celery celery-task

回答 0 投票 0

按任务 ID 重试 celery 中的任务

我已经启动了很多任务，但是其中一些还没有完成（763个任务），处于PENDING状态，但是系统没有处理任何东西...... 可以重试这个任务给芹菜...

python distributed celery celery-task

回答 2 投票 0

send_task()和apply_async()之间的区别。

我不清楚Python中Celery库中apply_async()和send_task()的区别，特别是在使用Tasks池的时候。我主要是想在一个集中的服务器上用 ...

python python-3.x celery celery-task

回答 1 投票 1

如何在大型芹菜django-admin中将大型csv转换为json？

我正在尝试通过在后台使用芹菜的django动作将django-admin中的大型csv转换为json。这样用户就不必等待完成使用...

python django celery celery-task

回答 1 投票 0

celery-task 相关问题

最新问题