celery 相关问题

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

Celery:列出所有任务,计划,活动*和*完成

更新赏金我想要一个不涉及监控线程的解决方案,如果可能的话。我知道我可以使用我的应用程序控件的Inspect类查看计划和活动任务。我= myapp ....

回答 2 投票 21

如何使用Celery和Flask实现缓存系统

我正在使用以下方法实现在线服务器:Flask NGINX Celery Celery使用:RabbitMQ作为经纪人Redis作为结果后端。我想知道是否可以使用Redis作为缓存来避免......

回答 1 投票 -1

根据某些型号日期字段运行Django Celery Beat taks

有没有办法将Django芹菜任务与数据库中保存的每条记录联系起来?例如,如果我希望每个用户收到一封电子邮件,具体取决于用户想要的日期。也许我错了......

回答 1 投票 0

任何使@periodic_task只能在通话中运行的方法,它会在项目启动时自动运行吗?

是否有任何方法可以使periodic_task仅在调用时运行,我看到Pingit()在我运行我的django-app python manage.py runserver @periodic_task(run_every = crontab(minute =“* / 1”))时启动,选项= {” ...

回答 1 投票 1

django / celery多个队列不消耗任何任务

我是celery和django的新手。在我的芹菜设置中,当我调用任务而没有任何排队时,它与多个工人完美配合。但是,当我指定队列时,工人不会消耗任何东西......

回答 1 投票 0

使用python / celery /基于可用RAM的任何其他任务队列调度任务

有没有办法让Celery根据可用的RAM为工作人员分配任务?我正在开发一个Web应用程序,它将内存饥饿算法应用于大型内存数据,有没有办法使这个...

回答 1 投票 0

为什么只创建一个周期性任务?

我想通过循环创建多个周期性任务,但只创建了列表的最后一个。例如:@ app.on_after_finalize.connect def setup_periodic_tasks(sender,** kwargs):a = [1,3,4,7 ...

回答 1 投票 2

如何在没有线程或任务队列的情况下在Flask中运行后台作业

我正在使用Flask-restplus构建REST API。我的一个端点从客户端上传文件并运行一些分析。这项工作最多使用30秒。我不希望这项工作阻止主要进程。 ...

回答 2 投票 6

在与Flask应用程序不同的Docker容器中运行芹菜时出现问题

我正在使用Celery运行Flask应用程序,以使用docker-compose提交子流程。但是,当尝试在不同的容器中运行时,我无法使Celery工作。如果我在...中运行芹菜

回答 1 投票 0

气流芹菜乔布斯陷入了运行状态

我正在尝试使用CeleryExecutor设置Airflow。我使用postgres作为数据库,rabbitmq作为消息代理。所有气流预定作业都将进入运行状态,但它们从未运行过。我不 ...

回答 1 投票 0

似乎无法从celery任务修改缓存值

描述:我希望有一个缓存值(让我们称之为标志)来了解芹菜任务何时完成执行。我有一个视图,前端轮询此标志,直到它变为False。代码:...

回答 2 投票 0

Celery Beat运行重复的任务

我有一个芹菜击败任务,即运行其他刮痧任务。当未处理这些任务时,队列开始增长。我知道芹菜使用后端db,但只有:id,task_id,...

回答 1 投票 0

Django模型和Celery定期任务

我正在与Django一起开展IoT项目。我不喜欢做繁琐的编码。这里的问题是我有一个模型名称期间如下:class Period(models.Model):number = models ....

回答 3 投票 0

无法找到名称芹菜

我正在尝试设置芹菜并收到以下错误。 (ENV)E:\ src \ credixo \ test> python celeryexperiments \ driver.py Traceback(最近一次调用最后一次):文件“celeryexperiments \ driver.py”...

回答 1 投票 0

Celery立刻超过了Heroku的内存

我正在向Heroku部署一个Celery进程,每次启动它都会立即开始占用内存使用量,并在超过最大值后崩溃。我只有一个名为“test_task”的任务......

回答 1 投票 2

在Celery任务中调用Google Cloud API永远不会返回

我正在尝试从Celery任务中调用外部Google Cloud Natural Language API(使用google-cloud-python包)。问题是对API的调用永远不会返回(...

回答 1 投票 1

在django应用程序中获取djcelery周期性任务数据,并将数据保存在整个应用程序中而不存储在文件和数据库中?

我通过运行芹菜节拍调度程序和定期任务来获取轮询数据。我喜欢与Django服务器共享此数据。这些数据应该可用于整个Django应用程序服务器。 ...

回答 1 投票 0

'disabledBackend'对象没有属性'_get_task_meta_for'

我收到错误“'DisabledBackend'对象没有属性'_get_task_meta_for'”../这是django settings.py#芹菜设置CELERY_RESULT_BACKEND ='amqp'CELERY_ACCEPT_CONTENT = ['json'] ...

回答 1 投票 0

正确设置多个芹菜工人和线程的Flask-SQLAlchemy

当有多个涉及多个线程的芹菜工作者都查询同一个数据库时,我正在努力使我的Flask,SQLAlchemy(mysql)和Celery设置正常工作。问题 ...

回答 1 投票 7

芹菜在virtualenv与主管

主管安装在Linux Ubuntu中使用python2.7 virtualenv:python3.6 + Django2.0 + celery4.2这是celery.py文件:来自__future__ import absolute_import,unicode_literals从celery导入os ...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.