Всем привет. Подскажите как бороться с race condition: Ситуация следующая: - инлайн

Question

Всем привет. Подскажите как бороться с race condition: Ситуация следующая: - инлайн

кнопка в боте выполняет функцию, которая включает в себя изменение базы данных. а именно - модель меняет значение is_active и прибавляет значение value к другому значению в другой таблице
- если путем спама отправить несколько нажатий на эту кнопку, value прибавится к другому значению несколько раз, даже если в начале есть проверка на is_active (sqlalchemy асинхронная, бот тг также асинхронный)
Подскажите как можно разрешить проблему?

0

04.09.2023

8 ответов

22 просмотра

addlyy Автор вопроса

statement = select(model, for_update=True).where(...) result = await self.session.execute(statement).one() result.is_active = False other_model_obj.value_sum += result.value await self.session.commit() Что-то на подобии этого будет?

0

04.09.2023

Tishka17

addlyy
statement = select(model, for_update=True).where(....

Да можно и session.get тоже юзать

0

04.09.2023

addlyy Автор вопроса

Tishka17
Да можно и session.get тоже юзать

Я правильно понимаю что пока не будет закомичена первая сессия с транзакциями, которые вовлекают в себя model, эту model нельзя будет достать из бд, будет ошибку выплевывать?

0

04.09.2023

Tishka17

addlyy
Я правильно понимаю что пока не будет закомичена п...

Будет висеть в ожидании, но не более какого-то таймаута

0

04.09.2023

addlyy Автор вопроса

Tishka17
Будет висеть в ожидании, но не более какого-то тай...

то есть следующие селекты следующие будут ждать комита, и уже вернут мне модель где is_active изменен перевой сессией.

0

04.09.2023