可能是因为异步请求速度过快导致返回的错误码,可以通过加入sleep来延迟请求。可以尝试以下代码示例:
import asyncio
import aiohttp
async def download_file(url):
async with aiohttp.ClientSession() as session:
try:
async with session.get(url) as resp:
if resp.status != 200:
print(f"Error: {resp.status}")
else:
content = await resp.read()
async with aiofiles.open('filename', 'wb') as f:
await f.write(content)
print("File downloaded successfully!")
except Exception as e:
print(f"Error: {e}")
async def main():
url = "http://example.com/file.txt"
await download_file(url)
if __name__ == "__main__":
asyncio.run(main())
这里加入了一个try和except语块对请求的异常进行捕获和处理,同时使用了aiofiles库来管理文件的读取和写入。在async with session.get(url) as resp这一行,将状态码为404的情况加到了错误处理中。
使用asyncio模块运行这个程序,会将文件下载到当前工作目录下。如果依然失败,则需要检查url是否正确。