1回答
我一直在与多处理模块一起工作，试图并行一个只需27分钟就能在单个核上运行的for循环。我有12个CPU核可供我使用。import multiprocessing as mp
# Filter basis val to make a dataframe and do some work on it "CompanyB",
浏览 2提问于2020-02-07得票数 0
1回答
是否可以查找名为(delay()、apply_async()、apply_async()等)的代码？任务代码中的任务？弦乐就行了。理想情况下，我希望得到调用者的堆栈跟踪。
浏览 0提问于2015-04-29得票数 0
回答已采纳
apply(&self, datum: String) -> String { return f(datum);
fn apply_async
浏览 16提问于2020-02-02得票数 3
很多文档写道：“apply”用于同步，而“apply_async”用于异步。_state == RUNdef apply_async(self, func, argsreturn result所以我的问题是：
同步和异步的真正区别是什么？为什么？
浏览 2提问于2013-11-08得票数 3
回答已采纳
2回答
我有一个工作链，但是当我添加apply_async()时，它只执行第一个任务。returnret = chain( run_b.s(**kwargs),).apply_async()
如果没有apply_async，它将(同步地)按预期工作。
浏览 2提问于2016-04-09得票数 5
我一直在使用抽象任务并覆盖__call__方法，以便在每个任务执行之前处理一些事情，如下所示： abstract = True但是__call__方法是在worker上执行的，我需要一些重写来在每次任务“延迟”时在main上执行，而不是在worker上执行。
浏览 2提问于2014-02-05得票数 2
我正在开发一个使用REST API的Django应用程序。API请求执行一个长时间运行的Celery画布任务(任务链-将输入保存到数据库，执行计算，然后将计算结果保存到数据库)。这个长时间运行的任务依赖于用户的输入。现在，我想添加一个功能，方便用户在自己给定的特定时间执行这个长时间运行的任务，那么我该怎么做呢？ 也就是说，假设有2个用户使用自己的一组输入参数发出相同的API请求，并且用户1希望将其任务安排在上午5:00执行，用户2在上午7:30执行我如何才能做到这一点？ 前端:角度 后端: MySQL，Python (Django，Celery) 在这方面的任何帮助都将受到高度的感谢。
浏览 11提问于2020-06-23得票数 0
回答已采纳
2回答
芹菜，倒计时呼叫延迟
、、、
我使用以下代码调用此任务：在这个my_task中有一个条件，这个任务应该再次启动--，但是在延迟1分钟之后，
我发现有一些用于任务的，但它们的示例仅限于apply_async
浏览 1提问于2018-02-21得票数 22
回答已采纳
1回答
我必须在特定的时间执行一个由用户指定的任务。这不是固定的时间..。它将根据用户..。为了达到这个目的，我尝试使用django-cron，也尝试使用django-crontab.我还检查了姜戈芹菜(我对芹菜不太了解)。我可能错了)。有人能帮我做这件事吗..。
浏览 1提问于2017-12-04得票数 2
2回答
我想用池对象的close()方法来优雅地停止池工作人员，但是terminate()那些10秒内没有完成执行的工作人员。p.close() # this is blocking p.terminate()我还考虑过向线程发送SIGTERM，但是它们共享相同的pid，所以我不能这样做。
浏览 0提问于2017-03-16得票数 0
回答已采纳
在小的"< 1m“行表中更新一行时，我遇到了Django和Postgres的间歇性性能问题。 APM在更新行上报告问题，即： Model.objects.filter(id=model_id).update(field=True) filter子句使用表的主键，django执行的查询是： 'UPDATE "model" SET "field" = true WHERE "model"."id" = 12345' 因为执行时间超过5s，所以会引发错误。 这段代码运行在一个celery任务中，该任务接收
浏览 18提问于2020-09-09得票数 0
回答已采纳
1回答
我想解析一个有多个页面的网站。 next_button=soup.find_all('a',{'class':"btn-page_nav right"}) link=next_button[0]['href'] soup=BeautifulSoup(resp.content)
浏览 0提问于2017-10-19得票数 0
将共享值对象传递给apply_async参数不会运行该对象(可能无法识别) from Multiprocessing import Value,Pool,apply_asyncpool.close()p1.start()p1.join(
浏览 92提问于2019-09-11得票数 0
这是我的问题:知道“当一组特定的任务完成时，能够根据刚刚完成的组启动其他任务”的最好和更聪明的方法是什么？ A H B C F D - Starting A - Starting instance 2 o
浏览 4提问于2013-01-14得票数 0
我已经编写了一些Python代码，这些代码从大型数据库中提取信息，对数据库中的每一项执行一些最大似然建模，然后存储结果。代码连续运行良好，每个项目需要1-2秒。问题是，我的数据库中有几百万个项目，所以连续运行代码将需要数周时间。我可以访问具有16个cpus的集群，并且我编写了一个函数，该函数将初始输入目录分解为“块”，在每个块上运行建模代码，然后组织结果。由于代码建模部分的复杂性和对第三方python软件的依赖，我一直在尝试使用多处理来并行化这段代码，以便输入目录的每个块都在单独的cpu上运行。目前，由我的尝试产生的进程仅在单个cpu上运行。有人知道怎么解决这个问题吗？我是一个自学成才的科学程
浏览 0提问于2016-05-13得票数 1
问题背景另一个文件"parse.py"，第798行主要文件"parse.py"，第769行另一文件"parse.py"，第524行，produce_output_files
附属印刷(re
浏览 2提问于2014-08-14得票数 1
回答已采纳
2回答
我有一个包含1000行的csv文件，我使用它来进行api调用来创建用户。该脚本确实会产生新的进程，但这些进程在主线程完成所有工作时处于空闲状态。 下面是我尝试过的： from multiprocessing import Poolimport multiprocessingimport csv
def create_user(m
浏览 16提问于2020-06-17得票数 0
回答已采纳
1回答
我继承了一个解析器，这个解析器可以解析10个文件，每个文件大约4M行。有一个多处理逻辑，我似乎不能让它工作。import glob
# read line by line, parse and insert to postgres database.
def pro
浏览 8提问于2019-11-12得票数 0
回答已采纳
根据中的文档，我可以将queue参数传递给apply_async，以便将任务路由到特定队列。但是，在使用TaskSet时，我会得到apply_async() got an unexpected keyword argument 'queue'在给定TaskSet类中的以下代码的情况下，这是不可接受的 pu
浏览 3提问于2012-03-01得票数 1
回答已采纳
我正在使用apply_async开发并行GET功能，如中所描述的。我的问题是，我需要为每个GET请求提供头，但我没有弄清楚如何做到这一点。
浏览 3提问于2017-09-04得票数 2
回答已采纳
云服务器
ICP备案
即时通信 IM
云直播
实时音视频
腾讯云开发者
