草庐IT

celery_tasks

全部标签

android - flutter 和 Firebase : Execution failed for task ':firebase_auth:compileDebugJavaWithJavac'

我正在尝试构建我的flutter应用程序以与firebase交互。我已将google-services.json放在正确的位置。但是,每当我尝试构建Android应用程序时,我都会收到以下运行日志:Running"flutterpackagesget"insmart_diet_flutter...2.6sLaunchinglib\main.dartonONEPLUSA6003indebugmode...Initializinggradle...Resolvingdependencies...Gradletask'assembleDebug'...registerResGeneratin

c# - 运算符 '!=' 不能应用于类型 'Task' 和 'int' 的操作数

最近我开始使用Xamarin创建Android应用程序。我尝试使用SQLite创建一个小型本地数据库。我使用了Xamarindocumentationwebsite中的以下教程.不幸的是我得到一个错误:ErrorCS0019:Operator'!='cannotbeappliedtooperandsoftype'Task'and'int'(CS0019)我的代码如下:privatestringcreateDatabase(stringpath){try{varconnection=newSQLiteAsyncConnection(path);{connection.CreateTabl

python celery : Update django model after state change

我设法找到了2个类似的主题来讨论这个问题,但不幸的是我无法从中得到最好的解决方案:UpdateDjangoModelFieldBasedOnCeleryTaskStatusUpdateDjangoModelFieldBasedOnCeleryTaskStatus我使用Django和Celery(+redis作为消息代理),我想在celery任务状态发生变化(从挂起->成功,挂起->失败)等时更新Django模型我的代码:importtimefromceleryimportshared_task@shared_task(name="run_simulation")defrun_simul

django - celery 没有连接到redis服务器

我有一个使用celery==4.2.1、redis==2.10.6、redis-server=4.0.9的django2.0.5应用程序。当我启动celeryworker时,我得到以下输出:--------------celery@octopusv4.2.1(windowlicker)----****--------*****--Linux-4.18.16-surface-linux-surface-x86_64-with-Ubuntu-18.04-bionic2018-10-3117:33:50--*-****----**----------[config]-**----------

Django + Celery 长期定时任务

我正在开发一个严重依赖Celery任务调度的Django应用程序,使用Redis作为后端。任务可以设置为长时间运行,也可以设置为几秒/分钟。我已经阅读了有关Redis可见性超时和时间增量大于可见性超时的调度任务的后果(我也在之前的项目中处理它),所以我很感兴趣是否有比我的解决方案是在需要执行“主”任务之前5分钟运行另一个“助手”任务,安排“主”任务在需要的时间内运行,将任务ID存储在数据库中,然后checkin“主”"task如果存储的任务ID是正在运行的任务。最后一部分(任务ID存储)是必需的,因为多次运行“助手”任务可能会产生很多“主要”任务实例,但使用这种方法每个任务都会有不同的

redis - 如何降低 epoll_wait 调用的 finish_task_switch() 的 CPU 使用率?

我编写了一个简单的epoll驱动的服务器来测试网络/io性能。服务器仅接收请求并立即发送响应。它比redis-server'get'慢,38k/svs40k/s。两者都使用redis-benchmark作为负载运行器,并且都使用了cpu(>99%)。benchredis-server:redis-benchmark-n1000000-c20-tget-p6379benchmyserver:redis-benchmark-n1000000-c20-tget-p6399我已经使用linuxperf对它们进行了分析,消除了myserver中的epoll_ctl(就像redis-server所

django - Celery 限速 : Is it possible to rate-limit a celery task differently based on a run-time parameter?

我想根据运行时确定的某些参数对Celery任务进行速率限制。例如:如果参数为1,则速率限制可能为100。如果参数为2,则速率限制可能为25。此外,我希望能够在运行时修改这些速率限制。celery是否提供了这样做的方法?我可以使用routing_key根据参数将任务发送到不同的队列,但celery似乎不支持队列级速率限制。一个可能的解决方案是在排队任务时使用eta,但我想知道是否有更好的方法来实现这一点。 最佳答案 Celery提供了一个内置的速率限制系统,但它的工作方式与大多数人期望的速率限制系统不同,并且它有几个限制。我在Redi

redis - 安装 Celery/Redis 以在另一台服务器上运行任务的正确方法是什么?

Web服务器本身运行django。我希望网络服务器将实际任务委托(delegate)给另一台服务器。 最佳答案 首先,在远程服务器上设置您的Redis服务器。更改您的django配置以连接到此服务器。部署应用程序时,我建议使用fabric部署到您的网络服务器和工作服务器。它还应该处理重启逻辑。 关于redis-安装Celery/Redis以在另一台服务器上运行任务的正确方法是什么?,我们在StackOverflow上找到一个类似的问题: https://sta

python - django-celery redis 内存错误

我正在使用django+celery和redis作为代理,我的一个任务涉及读取大约25MB大小的大文件并返回结果,通过该结果链接另一个任务来处理结果。由于我对redis不熟悉,所以在这里遇到错误,求助。可能是什么问题?[2013-06-2322:45:41,241:ERROR/MainProcess]Unrecoverableerror:MemoryError()Traceback(mostrecentcalllast):File"/home/property/virtualenv/property_env/lib/python2.6/site-packages/celery/work

python - 使用 redis 和 celery 向所有工作人员广播任务

我试试看:ma​​in.pyimporttasksif__name__=='__main__':result=tasks.add.apply_async(([4,4]),queue='broadcast_tasks')result.ready()value=result.get()print(value)tasks.pyfromceleryimportCeleryfromkombu.commonimportBroadcastapp=Celery('tasks',broker='redis://localhost:6379/0',backend='redis://localhost:63