MagicStack / MagicStack/asyncpg

LOG: could not receive data from client: Connection reset by peer

Abierto
#736 2 comentarios 3 reacciones 0 asignados Ver en GitHub

Nadie ha tomado este issue todavía.

Lenguaje dominante
Python
Estrellas
8.1k
Forks
468
Métricas de merge de PR
Sin PR fusionados en 30 d

Descripción

  • asyncpg version: 0.22.0
  • PostgreSQL version: 12
  • Do you use a PostgreSQL SaaS? If so, which? Can you reproduce
    the issue with a local PostgreSQL install?
    : AWS Aurora . Cannot reproduce with a local PostgreSQL.
  • Python version: v3.7.6+
  • Platform:
  • Do you use pgbouncer?: No
  • Did you install asyncpg with pip?: Yes
  • If you built asyncpg locally, which version of Cython did you use?: N/A
  • Can the issue be reproduced under both asyncio and
    uvloop?
    : just uvloop

It seems like asyncpg's connection pooler is not gracefully terminating connections. This seems to happen only with AWS Aurora version, but not the locally installed Postgres version.

Aurora Postgre has idle_in_transaction_session_timeout set to 86400000.

Here is the code to help reproduce this issue. .

from sanic import Sanic, Blueprint
from sanic.exceptions import NotFound
from sanic.response import json
from sanic.handlers import ErrorHandler
import asyncpg

app = Sanic(name="asyncpg-errors")
bp = Blueprint("info", url_prefix="/info")


DB_CONFIG = {
    'host':<url>,
    'user': <user>,
    'password': <password>,
    'port': 5432,
    'database': 'postgres'
}

def log_listener(connection, message):
    print(message)

@app.listener('before_server_start')
async def init(app, loop):
    app.pool = await asyncpg.create_pool(
        **DB_CONFIG, loop=loop,
        max_size=10, max_inactive_connection_lifetime=1
    )

@bp.route('/', methods=['GET'])
async def info(request):
    async with request.app.pool.acquire() as conn:
        conn.add_log_listener(log_listener)
        d = await conn.fetchrow('''SELECT * FROM mmrtest limit 1''')
        return json(dict(d))




group = Blueprint.group(bp)
app.blueprint(group)

app.run(port=9091, access_log=True, debug=True)

Guía de contribución

No hay ninguna guía de contribución indexada para este repositorio

Primeros pasos

  1. Lee el issue completo y luego la guía de contribución del proyecto.
  2. Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
  3. Haz un fork del repositorio y trabaja en una rama.
  4. Abre un pull request que haga referencia al número del issue.

Línea de trabajo

Comienza con la reproducción de Sanic proporcionada, centrándote en asyncpg.create_pool, max_inactive_connection_lifetime y el flujo de adquisición/liberación de la conexión. Ejecútala en AWS Aurora y compara su comportamiento con PostgreSQL local bajo uvloop. Se considerará terminado cuando el comportamiento de restablecimiento de la conexión esté explicado y se haya documentado una solución verificada o un siguiente paso de alcance limitado.

Escrito por el modelo de indexación a partir del texto del issue.

Evaluación

Stack tecnológico
postgresql, python
Área
backend, databases
Tipo de issue
Error
Dificultad
4/5
Tiempo estimado
3-5 días
Estado de actividad
Estancado
Claridad
Necesita aclaración
Aptitud para principiantes
25/100

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.