Как многопоточность сессии? - PullRequest
0 голосов
/ 23 апреля 2019

Я пытаюсь многопоточность моего скрипта Python, который работает с MySQL через sqlalchemy с модулем "Threading"

from threading import Thread

Но множественные вызовы разрушают MySQL.

Если я правильно понял, причиной этого является тот факт, что объект сеанса предназначен для обработки только одного вызова за раз, поэтому я привязан к реализации подхода к сеансу с заданной областью с помощью следующего кода:

from sqlalchemy.orm import scoped_session
from sqlalchemy.orm import sessionmaker


s_session = scoped_session(sessionmaker(bind=engine))
session = s_session()

Теперь я получаю следующую ошибку:

«Потерянное соединение с сервером MySQL во время запроса») sqlalchemy.exc.OperationalError: (pymysql.err.OperationalError) (2013,> 'Потерянное соединение с сервером MySQL во время запроса')

Как решить проблему?

  • Может быть, мне нужно несколько движков для реализации scoped_session?
  • Может быть, мне нужно закрыть сессию?

Спасибо!

...