celery

3热度

1回答

与芹菜气流CFG设置为： broker_url = 'amqp://guest:[email protected]_server:8080' celery_result_backend = db+postgresql://developer:[email protected]_server:5432/db_name 的airflow webserver运行正常，但在运行从气流UI任务我得到

0热度

2回答

期刊任务Django：Celerity vs Javascript/jQuery

我知道有关于“如何在Django中制作定期任务”的问题，如this post。但是我想知道哪个是最好的选择，可以使用该帖子中提到的选项（主要是Celerity或cron），或者使用Javascript/jQuery处理定期任务。我想完成的是在特定时间每天简单地执行一项任务。从“view.py”调用一个函数。该功能将连接到URL，下载文件并在该文件中搜索信息，然后将其存储在数据库中。之后，用新信息

1热度

2回答

如何监控芹菜中的一组任务？

我有一个情况定期每月big_task在这个文件中，其中链接的任务是small_task_1和small_task_2读取每行一个链接任务文件和排队： class BigTask(PeriodicTask): run_every = crontab(hour=00, minute=00, day_of_month=1) def run(self): task_li

4热度

2回答

RuntimeError：从不在任务中调用result.get（）Celery

我正在使用celery将任务发送到远程服务器并尝试获取结果。在远程服务器上使用update_state方法不断更新任务状态。我使用 app.send_task('task_name') 越来越芹菜任务的结果发送任务是一个阻塞调用，我不希望我的Django应用程序等待结果和超时。所以我试着运行另一个芹菜任务获取结果。 @app.task(ignore_result=True) def ca

0热度

1回答

在运行Celery任务时调用settings.py变量

我有一个Django应用程序，并且需要添加一个Celery异步任务。我想从dev.py中调用一个设置变量，例如MY_VARIABLE ='test'。为了简化的例子，假设有我的任务： from django.conf import settings @shared_task def test_task(): return settings.MY_VARIABLE 我celery

0热度

1回答

使用Celery（python）＆RabbitMQ将任务结果保存到特定文件位置？

嘿家伙我正在为我的学校的一个项目的原型（我是一个研究助理，所以这不是一个分级项目）。我在已经安装和运行的服务器集群上运行芹菜（有48个工人/内核）。我的项目的主要内容是我们希望使用芹菜来处理大量的文件/任务。 Because of this it is very important that we save results to an actual file, we have gigs upon

0热度

1回答

Django与多台服务器通话

这里有很多信息，说实话，这有点太过消化，我有点失落。我的网络应用程序必须这样做一些非常耗费资源的任务。标准安装现在在另一台主机上的服务器静态/媒体上应用。我想要做的就是设置芹菜，因此我可以拨打task.delay来完成这些资源密集型任务。我想将整个独立服务器的资源专用于这些资源密集型任务。这里的问题：如何这样做我设置芹菜，这样从我的主服务器（其中应用程序托管）为.delay的调用从应用程序发

0热度

1回答

当使用uwsgi运行django项目时，芹菜不会收到任务

当我使用manage.py运行我的django项目时，芹菜正在工作。但是，在使用uwsgi部署项目时，它不是。命令来运行芹菜： celery --app=project.celery:app worker --loglevel=INFO 开始uwsgi，我使用下面的脚本： #!/bin/bash uwsgi --chdir=~/tender \ --module=project

1热度

1回答

如何将芹菜代码分离到服务器和客户端？

想象一下，我已经写了一个芹菜任务，并将代码放到服务器上，但是，当我想将任务发送到服务器时，我需要重新使用之前编写的代码。所以我的问题是，有没有任何方法来分离服务器和客户端之间的代码。

2热度

1回答

芹菜异常处理

假设我有这样的任务定义： def some_other_foo(input) raise Exception('This is not handled!') return input @app.task( bind=True, max_retries=5, soft_time_limit=20) def some_foo(self, someInput={})