Гайд · TNWS AI

Как не повторить AI-действие при повторной доставке события

6 мин—

Используем уникальный event_id и транзакцию SQLite, чтобы повторная доставка AI-команды не создавала вторую запись.

Практическая задача

Не создавать два задания на одно подтверждённое событие при повторе доставки. Повторы запросов возникают при сбое связи и ручном перезапуске; модель не должна решать уникальность действия по тексту. Сервер получает стабильный event_id и сохраняет его в таблице с PRIMARY KEY. INSERT OR IGNORE показывает учебную дедупликацию локальной очереди, но не гарантирует ровно одно внешнее действие. Для необратимых операций нужна отдельная схема подтверждения и обработки неопределённого исхода. Этот сценарий применим, когда у команды есть контроль над входом или выходом AI-приложения и требуется конкретный сигнал о нарушении правила, а не общее впечатление от нескольких ответов. Все входы ниже вымышлены; числовые результаты относятся только к этим примерам.

Документация методов Python и синтаксиса workflow сверена 20.09.2026. Если вы используете другое окружение, проверьте совместимость до копирования команд. Статья не утверждает, что показанный код измеряет качество конкретной модели или заменяет ручную проверку.

Подготовка и проверяемый контракт

Перед запуском запишите, какие данные считаются входом, что является ожидаемым результатом, что именно означает отказ и кому предстоит разбирать расхождение. Для такой проверки храните тестовый вход, ожидаемый результат и фактический исход раздельно: если они смешаны, тест может подтверждать сам себя. Используйте стабильные синтетические ID, чтобы видеть ошибку в журнале, не раскрывая содержимое клиентских обращений.

Сначала прогоните тест на маленьком входе, где правильное поведение известно вручную. Затем внесите одну контролируемую ошибку и убедитесь, что код её замечает. После этого верните корректный набор и только тогда расширяйте проверку до реальных данных. Не переносите демонстрационные численные значения или пороги в производство без отдельного обоснования: они выбраны для наглядности, а не рассчитаны по вашей аудитории.

Вход и ожидаемый результат

evt-demo-1 доставляется дважды; в таблице остаётся одна задача. Скрипт выводит One job stored for repeated event; count равен одному для базы в памяти. Перед тем как применять правило к закрытым данным, обсудите пограничные случаи, которые могут поменять интерпретацию входа. Запись в документации о границах теста не менее важна, чем зелёный check.

Пошаговые действия

  1. Создайте scripts/check.py в корне репозитория и вставьте код из блока ниже. Он использует названия функций стандартной библиотеки, указанные в официальных ссылках в конце статьи.
  2. Выполните python scripts/check.py локально. Не продолжайте, если уже демонстрационная фикстура даёт иной результат: сначала проверьте копирование кода и кодировку файла.
  3. Создавайте event_id на стороне доверенного источника, а не просите модель придумывать новый ID на каждый повтор. Выполните две доставки и проверьте count. Измените payload при том же ID: текущий код молча игнорирует конфликт, а в продукте его надо обнаружить сравнением сохранённого значения или хеша. Транзакция и уникальный ключ защищают локальную запись; для внешней отправки спроектируйте очередь исходящих действий и способ проверки её результата.
  4. Создайте .github/workflows/ai-corpus-check.yml из YAML-шаблона. Событие pull_request полезно для проверки данных до слияния; чтение репозитория ограничено permissions: contents: read. Скрипт не должен получать ключ внешней модели или реальные секреты.
  5. В разделе Actions откройте job check, сопоставьте его код завершения с локальным прогоном и зафиксируйте ссылку на проверенный коммит в PR. Не принимайте зелёный результат на старой ревизии за проверку последнего изменения.
# scripts/check.py
import sqlite3
db=sqlite3.connect(":memory:")
db.execute("CREATE TABLE jobs(event_id TEXT PRIMARY KEY, payload TEXT NOT NULL)")
def accept(event_id,payload):
    if not event_id or not payload: raise ValueError("required fields")
    with db:
        db.execute("INSERT OR IGNORE INTO jobs VALUES (?,?)",(event_id,payload))
accept("evt-demo-1","проверить заявку")
accept("evt-demo-1","проверить заявку")
assert db.execute("SELECT count(*) FROM jobs").fetchone()[0]==1
print("One job stored for repeated event")
name: AI corpus checks
on:
  pull_request:
permissions:
  contents: read
jobs:
  check:
    runs-on: ubuntu-latest
    steps:
      - uses: actions/checkout@v7
      - uses: actions/setup-python@v7
        with:
          python-version: '3.13'
      - run: python scripts/check.py

Ошибки интерпретации и границы

INSERT OR IGNORE скрывает конфликтующее содержимое того же ID. Внешние API и письма не становятся автоматически идемпотентными. В продукте нужна постоянная база вместо :memory:. Если вы расширяете набор случаев, добавляйте не только новые примеры, но и отрицательные случаи, на которых тест обязан упасть. Проверяйте, что изменение expected прошло ревью отдельно от изменения кода: иначе можно незаметно изменить правило под текущий ответ системы. Избегайте вывода полного приватного набора в CI и не сохраняйте в артефактах ответ закрытой модели без решения о доступе и хранении.

Ошибка выполнения самого Python, нераспознанный формат входа и обнаруженный бизнес-дефект — разные ситуации. В сообщении теста указывайте тип проблемы и безопасный ID. Если тест требует внешний сервис, вынесите его из PR с недоверенным кодом и явно ограничьте доступ к токенам; этот пример намеренно работает локально. Перед публикацией каких-либо результатов опишите методику, область применения и происхождение примеров, иначе читатель воспримет демонстрационную арифметику как характеристику продукта.

Практический разбор именно этого контроля

Не создавать два задания на одно подтверждённое событие при повторе доставки. Для самостоятельной проверки сначала выпишите три наблюдаемых состояния: допустимый вход, намеренно недопустимый вход и видимый сигнал отказа. В данной фикстуре это выглядит так: evt-demo-1 доставляется дважды; в таблице остаётся одна задача. При успешном тесте ожидается: Скрипт выводит One job stored for repeated event; count равен одному для базы в памяти. Не превращайте это в числовой KPI: здесь проверяется контракт на конкретных примерах, а не поведение модели на пользовательском трафике.

INSERT OR IGNORE скрывает конфликтующее содержимое того же ID. Внешние API и письма не становятся автоматически идемпотентными. В продукте нужна постоянная база вместо :memory:. Подключая проверку к продукту, расположите её до той операции, ради которой она написана: парсинга, сохранения, отображения или экспорта. Для каждого нового формата добавляйте отдельный негативный пример и письменное решение, почему он отклоняется. Отдельно просмотрите обработку ошибок: система должна отличать невалидный ответ AI от сбоя тестовой инфраструктуры, а пользователь не должен видеть сырой стек или приватное содержимое.

Чек-лист финальной проверки

  • Синтетический вход и ожидаемый исход согласованы предметным владельцем.
  • Команда python scripts/check.py работает локально и в CI на одной версии файлов.
  • Негативный случай обнаруживается, а не только успешный случай проходит.
  • Имена ID и меток уникальны там, где этого требует контракт.
  • В репозитории, логах и артефактах нет реальных секретов и приватных текстов.
  • Понятно, какой дефект тест находит и каких выводов о качестве AI он не даёт.
  • Ссылки на применённые функции и синтаксис workflow перепроверены при переносе.

FAQ

Почему ID не генерирует AI?

Новый ID на каждый повтор помешает распознать повтор.

Это защищает внешнюю отправку?

Нет, только локальную запись.

Если payload разный?

Считать конфликтом и разбирать его.

Зачем PRIMARY KEY?

База обеспечивает уникальность ID.

Что делать после обнаружения сбоя

Сохраните конкретный ID, воспроизведите его на текущей ревизии и отделите ошибку входных данных от ошибки функции. Если неверна контракт, исправьте её после предметного ревью; если неверен код, сначала оставьте проваливающийся тест, затем вносите исправление. После зелёного запуска просмотрите соседние случаи с похожими признаками, чтобы локальная правка не изменила другое согласованное поведение. Сохраните версии кода, набора и параметров запуска рядом с выводом: без них сравнивать результаты в будущем нельзя. Не приводите цифру из синтетического примера как измеренный показатель продукта.

Официальные первоисточники

Проверено 20.09.2026: 1, 2, 3, 4. Описание переписано своими словами; изменяемые версии и поля нужно повторно сверять перед дальнейшим использованием.

Читайте также

Комментарии

Пока тихо. Скажите первое слово