Замки в SQLAlchemy

Question

Я использую SQLAlchemy для выполнения транзакций в db PosgreSQL с использованием приложения Python. Я не знаю, как использовать блокировки в SQLAlchemy.

Любой может помочь мне использовать блокировки в SQLAlchemy.

Я столкнулся с проблемой, как следует,

Во время работы два экземпляра приложение, параллельно, он пытается вставить строки в одной таблице. Иногда я получаю ошибку дублирующего первичного ключа. Могу ли я решить эту проблему с помощью концепции блокировки?

С наилучшими пожеланиями, Suji

Answer 1

Для того, чтобы явно использовать замки вы можете использовать engine или connection выпустить сырой SQL к базе данных:

engine.execute('LOCK TABLES tablename WRITE') 
# do your stuff.... 
engine.execute('UNLOCK TABLES')