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?

El issue no indica archivos, pruebas ni puntos de entrada que inspeccionar. Empieza revisando la documentación de asyncpg sobre consultas, cursores, pooling y transacciones, y luego define un patrón compatible para consumir filas de consultas, realizar acciones de red y escribir resultados con conexiones agrupadas.