KeyError: 'user_id' как устранить?

Question

[EVG82]

import sqlite3 as sq


def sql_start():

    global base, cur
    base = sq.connect('db.db', check_same_thread=False)
    cur = base.cursor()
    if base:
        print('Подключился к БД')
    base.execute('CREATE TABLE IF NOT EXISTS test(user_id, user_name, user_surname, username)')
    base.commit()

async def sql_add_command(state):

    async with state.proxy() as data:
        user_id = data['user_id']
        username = data['username']
        user_surname = data['user_surname']
        user_name = data['user_name']
        cur.execute('INSERT or IGNORE into test(user_id, user_name, user_surname, username) VALUES (?, ?, ?, ?)', (user_id, user_name, user_surname, username))
        base.commit()

выдает ошибку

Traceback (most recent call last):
  File "G:\PYTHON\telebot_test\bot\lib\site-packages\aiogram\dispatcher\dispatcher.py", line 415, in _process_polling_updates
    for responses in itertools.chain.from_iterable(await self.process_updates(updates, fast)):
  File "G:\PYTHON\telebot_test\bot\lib\site-packages\aiogram\dispatcher\dispatcher.py", line 235, in process_updates
    return await asyncio.gather(*tasks)
  File "G:\PYTHON\telebot_test\bot\lib\site-packages\aiogram\dispatcher\handler.py", line 116, in notify
    response = await handler_obj.handler(*args, **partial_data)
  File "G:\PYTHON\telebot_test\bot\lib\site-packages\aiogram\dispatcher\dispatcher.py", line 256, in process_update
    return await self.message_handlers.notify(update.message)
  File "G:\PYTHON\telebot_test\bot\lib\site-packages\aiogram\dispatcher\handler.py", line 116, in notify
    response = await handler_obj.handler(*args, **partial_data)
  File "G:\PYTHON\pythonProject123\handlers\partnerbaze1.py", line 38, in get_email
    await sqlite_db.sql_add_command(state)
  File "G:\PYTHON\pythonProject123\data_base\sqlite_db.py", line 17, in sql_add_command
    user_id = data['user_id']
  File "G:\PYTHON\telebot_test\bot\lib\site-packages\aiogram\dispatcher\storage.py", line 439, in __getitem__
    return self._data[item]
KeyError: 'user_id'

Comments

[Алан Гибизов]

Как-то не понятно из кода, что передается в параметр state функции sql_add_command, и что из него возвращает метод proxy(); есть ощущение, что там не то, что ожидается.
Почему там не то, трудно сказать… это может быть, к примеру, сайд-эффектом использования global, или из-за асинхронности обращение к объекту происходит до того, как там появилось ожидаемое… ну, это мои гадания на кофейной гуще.

Что с этим делать? Ну, например, делать проверку до обращения на тип объекта, который возвращает state.proxy(), на наличие у него искомых ключей; или обернуть в try и корректно обработать правильный except.

[EVG82]

Алан Гибизов, смотрите логика такая для FSM

Пользователь на одном из этапов вводит email
email проверяется на валид

FSM финиширует.

Ранее по урокам данные писались как бы в словарь

А сейчас по тем же урокам подрубили Sqlite3

но в уроках примеры с фото описанием ценами

а у меня просто значение Email

и в FSM так

class FSMPartnerbaze1(StatesGroup):
    name = State()# Начало ввода почты
# @dp.message_handler(content_types=['text'], text='Марафон', state=None)
async def cm_start(message: types.Message):
    await FSMPartnerbaze1.name.set()
    await message.answer('Пожалуйста, укажите Вашу почту. Она нужна для корректной работы с Вами!')


print("FSM запущена")


# Ловим ответ и пишем в словарь
# @dp.message_handler(state=FSMPartnerbaze1.name)  #временно для понимания
async def get_email(message: types.Message, state: FSMContext):
    async with state.proxy() as data:
        data['name'] = message.text
        email = message.text
        await state.update_data(
            {'email': email}
        )

        regex = re.compile(r'([A-Za-z0-9]+[.-_])*[A-Za-z0-9]+@[A-Za-z0-9-]+(\.[A-Z|a-z]{2,})+')

        if re.fullmatch(regex, email):
            print("Valid email")

            await sqlite_db.sql_add_command(state)
            await state.finish()

аргумент name принимает любой текст.
В данном случае пусть это будет написанная почта
все что написано проверяется на валид
если это не почта, то
если почта, то

когда юзер зашел в бота, то в таблицу уже записались значения
username
id
user_id
usersername
user_name
user_surname

и еще мое name нужно...

отдельно я пробовал создавать таблицу и записывать значения.
все хорошо. Но там не было FSM

а в это случае ступор...

мне сказали что я не умею ни чего и иди учиться.
А нет времени учиться с ноля.
Мне нужен факт.

пример похожего кода по реализации вставки email в базу
или все что вводит пользователь в поле где сообщение должно писаться в базу.

и на удивление нет ничего толкового.
везде сложно описано.

у меня даже 3 бота есть от других разрабов.
там смотрел как сделано и тоже сложно.

просто должно быть.

[Алан Гибизов]

нет времени учиться с ноля.
Мне нужен факт.

Тогда рекомендую обратиться на freelance.habr.com