小编Gus*_*tav的帖子

我对使用 asyncio/aiohttp 很陌生，但我有一个 Python 脚本，它从 Postgres 表中读取一批 URL:s，下载 URL:s，在每次下载时运行处理函数（与问题无关） ，并将处理结果存回到表中。

简化形式如下所示：

import asyncio
import psycopg2
from aiohttp import ClientSession, TCPConnector

BATCH_SIZE = 100

def _get_pgconn():
    return psycopg2.connect()

def db_conn(func):
    def _db_conn(*args, **kwargs):
        with _get_pgconn() as conn:
            with conn.cursor() as cur:
                return func(cur, *args, **kwargs)
            conn.commit()
    return _db_conn

async def run():
    async with ClientSession(connector=TCPConnector(ssl=False, limit=100)) as session:
        while True:
            count = await run_batch(session)
            if count == 0:
                break

async def run_batch(session):
    tasks = []
    for url in get_batch():
        task = asyncio.ensure_future(process_url(url, …