草庐IT

async_wait

全部标签

Python async/await 下载 url 列表

我正在尝试从FTP服务器下载30,000多个文件,经过谷歌搜索后,使用异步IO似乎是个好主意。但是,下面的代码无法下载任何文件并返回超时错误。我真的很感激任何帮助!谢谢!classpdb:def__init__(self):self.ids=[]self.dl_id=[]self.err_id=[]asyncdefdownload_file(self,session,url):try:withasync_timeout.timeout(10):asyncwithsession.get(url)asremotefile:ifremotefile.status==200:data=awai

Python 子进程 : wait for command to finish before starting next one?

我已经编写了一个Python脚本来下载和转换许多图像,使用wget然后通过链式subprocess调用ImageMagick:forimginimages:convert_str='wget-O./img/merchant/download.jpg%s;'%img['url']convert_str+='convert./img/merchant/download.jpg-resize110x110'convert_str+='-backgroundwhite-gravitycenter-extent110x110'convert_str+='./img/thumbnails/%s.j

python - “wait_window”方法有什么作用?

似乎调用此方法的对象等待作为参数传递的窗口在继续其自己的循环之前被销毁...从Misc类的文档字符串中,我们可以观察到:defwait_window(self,window=None):"""WaituntilaWIDGETisdestroyed.Ifnoparameterisgivenselfisused."""乍一看,这个方法似乎可以制作一个Toplevel模态,但事实并非如此。要创建一个Toplevel模态,我们必须使用grab_set()方法。我看到了其他的解释:wait_windowseemstonotreturnuntilthegivenwidgetpassedaspara

python - 异步 : Wait for event from other thread

我正在用Python设计一个应用程序,它应该访问一台机器来执行一些(冗长的)任务。asyncio模块似乎是所有与网络相关的东西的不错选择,但现在我需要访问一个特定组件的串行端口。我已经为实际的串行端口实现了某种抽象层,但无法弄清楚如何将其与asyncio合理地集成。以下设置:我有一个运行循环的线程,它定期与机器对话并解码响应。使用enqueue_query()方法,我可以将查询字符串放入队列中,然后由另一个线程将其发送到机器并引起响应。通过传入threading.Event(或任何带有set()方法的内容),调用者可以执行阻塞等待响应。这看起来像这样:f=threading.Event

android - 如何解决 "Waiting for Debugger"消息?

我已使用SDK2.2将HTCComet连接到Eclipse。我做了一个调试版本——应用程序没有运行;虽然它确实安装在设备上。在设备上,我在Comet屏幕上看到此消息框等待调试器应用程序HunyDew(进程com.airvine.hunydew)正在等待调试器附加。[强制关闭]而在Eclipse控制台中,我收到了这些消息集[2010-12-0701:42:29-hunydewprj]AndroidLaunch![2010-12-0701:42:29-hunydewprj]adbisrunningnormally.[2010-12-0701:42:29-hunydewprj]Perform

android - 如何解决 "Waiting for Debugger"消息?

我已使用SDK2.2将HTCComet连接到Eclipse。我做了一个调试版本——应用程序没有运行;虽然它确实安装在设备上。在设备上,我在Comet屏幕上看到此消息框等待调试器应用程序HunyDew(进程com.airvine.hunydew)正在等待调试器附加。[强制关闭]而在Eclipse控制台中,我收到了这些消息集[2010-12-0701:42:29-hunydewprj]AndroidLaunch![2010-12-0701:42:29-hunydewprj]adbisrunningnormally.[2010-12-0701:42:29-hunydewprj]Perform

python - 将 yield 与多个 ndb.get_multi_async 一起使用

我正在尝试提高我当前从应用引擎数据存储区查询的效率。目前,我使用的是同步方法:classHospital(ndb.Model):name=ndb.StringProperty()buildings=ndb.KeyProperty(kind=Building,repeated=True)classBuilding(ndb.Model):name=ndb.StringProperty()rooms=ndb.KeyProperty(kind=Room,repeated=True)classRoom(ndb.Model):name=ndb.StringProperty()beds=ndb.Ke

python - selenium.wait_for_condition 等效于 WebDriver 的 Python 绑定(bind)

我正在将一些测试从Selenium转移到WebDriver。我的问题是我找不到selenium.wait_for_condition的等效项。Python绑定(bind)目前是否有此功能,还是仍在计划中? 最佳答案 目前无法将wait_for_condition与WebDriver一起使用。pythonselenium代码确实提供了DrivenSelenium类来访问旧的selenium方法,但它不能执行wait_for_condition。Theseleniumwikihassomeinfoonthat.最好的办法是使用WebDr

带有 map_async 的 python 多处理池

我尝试在python中将多处理包与池一起使用。我有一个由map_async函数调用的函数f:frommultiprocessingimportPooldeff(host,x):printhostprintxhosts=['1.1.1.1','2.2.2.2']pool=Pool(processes=5)pool.map_async(f,hosts,"test")pool.close()pool.join()这段代码有下一个错误:Traceback(mostrecentcalllast):File"pool-test.py",line9,inpool.map_async(f,hosts,

Python namedtuple 作为 apply_async(..) 回调的参数

我正在编写一个简短的程序,我想在其中异步调用一个函数,这样它就不会阻塞调用者。为此,我使用了python的multiprocessing模块中的Pool。在异步调用的函数中,我想返回一个namedtuple以符合我程序其余部分的逻辑,但我发现namedtuple确实似乎不是从派生进程传递到回调的受支持类型(可能是因为它不能被腌制)。这是问题的最小重现。frommultiprocessingimportPoolfromcollectionsimportnamedtuplelogEntry=namedtuple("LogEntry",['logLev','msg'])defdoSometh