Best way to spread query over multipule asyncio tasks?

I want to the data from a query as data for network actions. I am thinking about the best way to do this.
1> perform a single query and fetch all rows, then divide the result and pa sub part to each task
easy, but not good for large amount of data
2> Use a asyncio Queue. The producer would use a cursor to read that data and each task would be a consumer
difficult, do not know it would work.
3> Use pooled connections. but there would have to be a global "next".for each query
dumb idea

What would be the best and simplest way to query the database and do network actions and then use pooled connections to write a result?

The issue names no files, tests, or entry points to inspect. Start by reviewing asyncpg's query, cursor, pooling, and transaction documentation, then define a supported pattern for consuming query rows, performing network actions, and writing results with pooled connections.