aiohttp + sqlalchemy: Nie można się połączyć ponownie, dopóki nie zostanie wycofana nieprawidłowa transakcja

Używam aiohttp i sqlalchemy, a także utworzyłem Singleton, który pomaga mi nawiązać połączenie, gdy potrzebuję instancji SQLAlchemy (poniższy kod) . Niestety, co jakiś czas pojawia się następujący błąd (który ja „rozwiązać” poprzez ponowne uruchomienie serwera):aiohttp + sqlalchemy: Nie można się połączyć ponownie, dopóki nie zostanie wycofana nieprawidłowa transakcja

Dec 11 09:35:29 ip-xxx-xxx-xxx-xxx gunicorn[16513]: sqlalchemy.exc.StatementError: (sqlalchemy.exc.InvalidRequestError) Can't reconnect until invalid transaction is rolled back [SQL: '... \nFROM ...\nWHERE ... = %(username_1)s \n LIMIT %(param_1)s'] [parameters: [{}]]```

Czy istnieje jakiś sposób, aby ustalić aktualny kod? Dzięki :)

CONNECTION_DETAILS = { 
    'driver': 'pymysql', 
    'dialect': 'mysql', 
    'host': os.environ.get('HOST'), 
    'port': 3306, 
    'user': 'master', 
    'password': os.environ.get('PASSWORD'), 
    'database': 'ourdb', 
    'charset': 'utf8' 
} 

_instance = None 

def __new__(cls, *args, **kwargs): 
    if not cls._instance: 
     con_str = '{dialect}+{driver}://{user}:{password}@' \ 
        '{host}:{port}/{database}?charset={charset}'\ 
      .format(**cls.CONNECTION_DETAILS) 
     try: 
      engine = sqlalchemy.create_engine(con_str) 

      Session = scoped_session(sessionmaker(bind=engine)) 
      session = Session() # Create the ORM handle 
     except sqlalchemy.exc.OperationalError: 
      logger.exception('Establishing database connection error.') 

     cls._instance = super().__new__(cls) 
     logger.debug("Returning database's session.") 
     cls._instance.session = session 

     # Initializing tables 
     cls._instance.Users = Users 
     cls._instance.Services = Services 
     cls._instance.APIKeys = APIKeys 

    return cls._instance

Źródło

2016-12-11 Infinity

Nie mam pojęcia o twoim pytaniu, ale dlaczego używasz aiohttp z sqlalchemy? niezsynchronizowany obiekt z asynchroniczną strukturą? – Juggernaut

Wyobrażam sobie, że jest to spowodowane wieloma żądaniami aiohttp uruchomionymi w tym samym wątku, więc 'Sesja' jest wspólna dla wielu zadań z powodu' scopefunc' z 'scoped_session'. Zobacz [to pytanie] (http://stackoverflow.com/questions/34369164/correct-usage-of-sqlalchemy-scoped-session-with-python-asyncio). – univerio

To byłaby dość spóźniona odpowiedź. Oto, co się dzieje: Podczas korzystania z sesji generowany jest błąd sqlalchemy (wszystko, co spowodowałoby błąd, gdy zostanie użyte jako czysty kod SQL: błędy składni, unikalne ograniczenia, kolizje kluczy itp.).

Trzeba znaleźć ten błąd, opakować go w blokadę try/except i wykonać session.rollback().

Po tym można przywrócić sesję.

Źródło

2017-02-22 16:01:15 knitti

aiohttp + sqlalchemy: Nie można się połączyć ponownie, dopóki nie zostanie wycofana nieprawidłowa transakcja

Odpowiedz

Powiązane problemy