草庐IT

celery_tasks

全部标签

python - asyncio.ensure_future vs. BaseEventLoop.create_task vs. 简单协程?

我已经看过几个关于asyncio的基本Python3.5教程,它们以不同的方式执行相同的操作。在这段代码中:importasyncioasyncdefdoit(i):print("Start%d"%i)awaitasyncio.sleep(3)print("End%d"%i)returniif__name__=='__main__':loop=asyncio.get_event_loop()#futures=[asyncio.ensure_future(doit(i),loop=loop)foriinrange(10)]#futures=[loop.create_task(doit(i

python - 分布式任务队列(例如 Celery)与 crontab 脚本

我无法理解“分布式任务队列”的用途。比如python的celerylibrary.我知道在celery(python框架)中,您可以为函数设置定时窗口来执行。但是,这也可以在针对python脚本的linuxcrontab中轻松完成。据我所知,从我自己的django-celerywebapps中可以看出,celery比仅仅设置一个原始的crontab消耗更多的RAM内存。对于一个相对较小的应用程序来说只有几百MB的差异。有人可以帮我解决这个问题吗?或许对任务队列/crontab的一般工作方式进行高级解释也会很好。谢谢。 最佳答案 这取

python - 用 Celery 取消已经执行的任务?

我一直在阅读文档并进行搜索,但似乎找不到直接的答案:你能取消一个已经在执行的任务吗?(因为任务已经开始,需要一段时间,中途需要取消)我是从位于CeleryFAQ的文档中找到的>>>result=add.apply_async(args=[2,2],countdown=120)>>>result.revoke()但我不清楚这是否会取消排队的任务,或者是否会杀死工作人员上正在运行的进程。感谢您提供的任何启发! 最佳答案 revoke取消任务执行。如果任务被撤销,工作人员会忽略该任务并且不执行它。如果您不使用持久撤销,您的任务可以在工作人

python - 如何检查 Celery 中的任务状态?

如何检查一项任务是否在celery中运行(具体来说,我使用的是celery-django)?我已经阅读了文档,并在谷歌上搜索过,但我没有看到类似的调用:my_example_task.state()==RUNNING我的用例是我有一个用于转码的外部(java)服务。当我发送要转码的文档时,我想检查运行该服务的任务是否正在运行,如果没有,则(重新)启动它。我相信我正在使用当前的稳定版本-2.4。 最佳答案 返回task_id(由.delay()给出),然后向celery实例询问状态:x=method.delay(1,2)printx.

java - ExecutorService.submit(Runnable task, T result) 中的 'result' 有什么作用?

看看它刚刚说的javadocsFuturesubmit(Runnabletask,Tresult)SubmitsaRunnabletaskforexecutionandreturnsaFuturerepresentingthattask.TheFuture'sgetmethodwillreturnthegivenresultuponsuccessfulcompletion.Parameters:task-thetasktosubmitresult-theresulttoreturn但是它对结果有什么影响呢?它在那里存储任何东西吗?它只是使用结果的类型来指定Future的类型吗??

java - 什么是 Python 的 Celery 项目的 Java 等价物?

我正在尝试为Java环境寻找一个与Celery项目等效的项目,我已经查看了SpringBatch,但是对于分布式任务队列有没有更好的替代方案。谢谢。 最佳答案 Celery所做的非常类似于EIP,和SEDA具有方便的任务调度...(您剩下要做的就是添加一些数据库和异步HTTP网络,您就拥有了完整的企业级质量堆栈)。Java中基本上有Spring方式、JavaEE方式和Hadoop方式:Spring:Spring集成+SpringBatch+RabbitMQJavaEE:Mule+Quartz或EJB调度+HornetMQHadoop

java - Android Studio 转换异常 : Error:Execution failed for task ':app:transformClassesWithDexForDebug'

当我尝试使用AndroidStudio运行应用程序时出现以下异常:Error:Executionfailedfortask':app:transformClassesWithDexForDebug'.com.android.build.api.transform.TransformException:com.android.ide.common.process.ProcessException:org.gradle.process.internal.ExecException:Process'command'C:\ProgramFiles\Java\jdk1.8.0_05\bin\ja

java - 错误 :Execution failed for task ':app:packageRelease' . > 无法计算/../AndroidStudioProjects/../classes.jar 的哈希

我正在尝试在Android应用上进行“发布”构建,但我不断收到以下错误:Unabletocomputehashof/../AndroidStudioProjects/../classes.jar然后,当我查看“classes.jar”的目录时,该文件不存在。我是否必须使用gradle任务自己创建此文件?这里的proguard发生了一些事情,但除了“无法计算哈希......”之外,它没有提供太多有用的信息。这是我的gradle.build文件:applyplugin:'com.android.application'applyplugin:'com.google.gms.google-s

java - org.gradle.api.tasks.TaskExecutionException : Execution failed for task ':app:transformClassesWithDexForDebug'

由于我的项目中出现65K错误,我需要将其迁移到AndroidStudio。运行时./gradlewassembleDebug我收到错误:Executionfailedfortask':app:transformClassesWithDexForDebug'.com.android.build.api.transform.TransformException:com.android.ide.common.process.ProcessException:java.util.concurrent.ExecutionException:com.android.ide.common.proce

firebase - 完成错误 : Gradle task assembleDebug failed with exit code 1

Launchinglib\main.dartonHTCOneM9PLUSindebugmode...Initializinggradle...Resolvingdependencies...Gradletask'assembleDebug'...registerResGeneratingTaskisdeprecated,useregisterGeneratedResFolders(FileCollection)registerResGeneratingTaskisdeprecated,useregisterGeneratedResFolders(FileCollection)regis