P#
Ты лоад сейв хочешь внутри контекста поставить?
Я хотел делать всё в одном контексте
Size: a a a
2020 April 21
P#
Чтобы лишний раз не гулять в прокси
G
В общем ещё раз скажу, что использовать state.get/set/update_data внутри блока async proxy() as data нельзя
P#
В общем ещё раз скажу, что использовать state.get/set/update_data внутри блока async proxy() as data нельзя
Ну это я использовал когда мне @martin_winks посоветовал
P#
Судя по всему, ты хочешь понять, что не так и тебе нужно немного подробнее
Так вот, есть хендлер вроде такого:
И как только я пересылаю сообщения (т.е. отправляю их очень быстро), оно сохраняет так, как я показал выше.
Так вот, есть хендлер вроде такого:
@dp.message_handler(content_types=[ContentType.ALL], state=MyState.state)
async def record_msgs(m: Message, s: FSMContext):
async with state.proxy() as data:
item_id = data['id']
id_: int = await put_into_db(m, item_id) # не важно что оно делает
data['new_data'].append(id_)
return
И как только я пересылаю сообщения (т.е. отправляю их очень быстро), оно сохраняет так, как я показал выше.
До этого было ровно вот так
G
Вот что бывает, когда нарушаешь дзен питона
P#
а чо я нарушил? О.о :D
G
Да мы все нарушили, зачем прокси, когда есть аналогичные методы у state, и эти два аналогичных способа (прокси и методы) ещё и нельзя смешивать
G
Я в своих проектах отказался от прокси, всем рекомендую
P#
Понимаю
P#
Теперь так
@dp.message_handler(content_types=[ContentType.ALL], state=MyState.state)
async def record_msgs(m: Message, s: FSMContext):
item_id = (await s.get_data())['id']
id_: int = await put_into_db(m, item_id)
new_data = (await s.get_data())['new_data']
new_data.append(id_)
await s.update_data(new_data=data)
P#
Уже капельку лучше
Было:
Стало:
Было:
b'{"id": 1, "new_data": [41, 45, 46, 47]}'Стало:
b'{"id": 1, "new_data": [41, 45, 46, 47, 49]}'
b'{"id": 1, "new_data": [41, 45, 46, 47, 49, 51]}'
b'{"id": 1, "new_data": [41, 45, 46, 47, 49, 50]}'s
Ну это я использовал когда мне @martin_winks посоветовал
только во время рекомендации я смотрел имплементацию
FSMContext.s
Уже капельку лучше
Было:
Стало:
Было:
b'{"id": 1, "new_data": [41, 45, 46, 47]}'Стало:
b'{"id": 1, "new_data": [41, 45, 46, 47, 49]}'
b'{"id": 1, "new_data": [41, 45, 46, 47, 49, 51]}'
b'{"id": 1, "new_data": [41, 45, 46, 47, 49, 50]}'попробуй первый редис сторедж. там вроде лок используется при записи. вообще не пойму почему у тебя так с синхронизацией
P#
попробуй первый редис сторедж. там вроде лок используется при записи. вообще не пойму почему у тебя так с синхронизацией
Не сработало
Короче, решил проблему чуть-чуть топорно
Короче, решил проблему чуть-чуть топорно
async with _lock:
на весь хендлерs
гы, можешь сделать
acquire потом release, чтобы не было лишних индентов.s
или декорировать. но чот говно, что лок самого стореджа не синхронизирует.
P#
гы, можешь сделать
acquire потом release, чтобы не было лишних индентов.Как-то пофиг
P#
или декорировать. но чот говно, что лок самого стореджа не синхронизирует.
Там лок на запись. И я понял, что за ошибка
P#
data = await get_data() # 1Потом контекст переключается
new_data = data.update_somehow_sync() # тут другая `data`Потом возвращается:
await set_data(new_data) # 0
new_data = data.update_somehow_sync()
await set_data(new_data) # 1