Технические модули

AI Agent Book: HTTP-события и прерываемый цикл asyncio Flux

Два исполняемых компонента репозитория: FastAPI agent-with-event-trigger принимает внешние события, а async-agent реализует однопоточное событийное ядро Flux на asyncio.

15.10.2026·26 источников·По описаниям проекта ↗

Концептуальная иллюстрация к обзору: AI Agent Book: HTTP-события и прерываемый цикл asyncio Flux — Концептуальная иллюстрация · создана с помощью ИИ

КЛЮЧЕВЫЕ СВЕДЕНИЯ

Паспорт проекта

По первоисточникам

Тип: Технические модули
Задача: Поддержать агентную работу, которую запускает внешнее событие и можно изменить или прервать до окончания, сохраняя доступ к состоянию долгой операции.
Для кого: Разработчики событийных агентных приложений и читатели, изучающие асинхронное выполнение.
Технологии: Python / API / LLM / JSON
Что потребуется: Общее требование репозитория Python 3.11–3.13 и зависимости соответствующей главы; для модельных путей нужны настроенные учётные данные провайдера, у части…
Основание: 26 первоисточников

СУТЬ

За 30 секунд

01 / Зачем

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

02 / Как

Приём HTTP-событий Web, мессенджеров, GitHub и таймеров; подключение первых трёх групп MCP-инструментов.

03 / Результат

Вызовы инструментов, состояние и отмена задач, автоматическая документация API Swagger UI и фоновое наблюдение. Форматы сохранения результатов и гарантия доставки не установлены.

ПОСЛЕДОВАТЕЛЬНОСТЬ

Как это работает

На входе

LLMJSON

HTTP-события внешних источников и таймеров, сообщения очереди с классом срочности, новые указания во время выполнения; решения LLM поступают как вызовы функций. Точная JSON-схема в сохранённом пакете не представлена.

Механизм

Приём HTTP-событий Web, мессенджеров, GitHub и таймеров; подключение первых трёх групп MCP-инструментов. Flux распределяет события по срочности, запускает асинхронные инструменты параллельно, обрабатывает прерывание, отмену и запрос состояния длительной задачи.

Результат

API

ПОДРОБНОСТИ

Что важно понять

Техническое устройство

FastAPI HTTP-вход с нативно асинхронной загрузкой MCP; Flux использует один поток asyncio, очередь событий и параллельные асинхронные инструменты. Указаны точки AgentRuntime._dispatcher и _handle_interrupt.

Для чего создано

Для кого

Разработчики событийных агентных приложений и читатели, изучающие асинхронное выполнение.

Сценарии использования

Локальный таймер запускает задачу; HTTP-событие GitHub или мессенджера входит в агентный цикл; срочное событие прерывает раунд, а состояние длительной имитируемой задачи можно запросить либо отменить.

Идея решения

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

Какую задачу описывает источник

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

ГОТОВНОСТЬ К ПРОВЕРКЕ

Что известно из описания

Полнота описанияЗапуск не проверялся

МеханизмОписано

ТребованияОписано

ОграниченияОписано

Что потребуется

Общее требование репозитория Python 3.11–3.13 и зависимости соответствующей главы; для модельных путей нужны настроенные учётные данные провайдера, у части экспериментов отдельный .env.
FastAPI, asyncio и MCP указаны для этих компонентов; конкретный список версий пакетов отсутствует.

Что учитывать

Сохранённые описания не содержат исходников event-trigger/Flux или приёмочных трасс этих компонентов.
Запускаемость заявлена таблицей; долгие задачи в русском описании имитируемые.
Гарантии надёжной доставки, рабочей доступности и отмены произвольного внешнего эффекта не установлены.

СМОТРИМ ГЛУБЖЕ

Комментарий NeoBridge

Общая справка

FastAPI и asyncio — Средства Python для HTTP-приложений и кооперативного асинхронного выполнения соответственно.
Очередь и отмена — Очередь хранит ожидающие события. Отмена останавливает поддерживающую её задачу, но сама по себе не откатывает уже совершённые внешние действия.
MCP и function calling — MCP подключает инструменты и ресурсы; function calling передаёт запрос модели на вызов описанной функции.
API — Правила, по которым программы обращаются друг к другу: например, запрашивают данные или передают команду.
JSON — Текстовый формат для передачи данных: значения записываются в виде полей, списков и вложенных объектов.

Что стоит уточнить

Где точные исходники, зависимости и приёмочные трассы 6-1/6-2 для этого снимка? Сведения не установлены сохранёнными описаниями или не проверены выполнением.
Как устроены HTTP-аутентификация, права MCP, сохранение очереди и восстановление после сбоя? Сведения не установлены сохранёнными описаниями или не проверены выполнением.
Какие внешние инструменты действительно поддерживают отмену, и как фиксируются уже совершённые эффекты? Сведения не установлены сохранёнными описаниями или не проверены выполнением.

Основания и справочные материалы

API ↗JSON ↗

↗

ОСНОВАНИЯ

Из первоисточников

26 ссылок

Редакционный обзор NeoBridge Insight по материалам источников ниже. Права на исходные тексты, код и изображения принадлежат их правообладателям. Условия использования указаны в первоисточниках.

Автор документа по источнику: 李博杰

Независимое тестирование проекта не проводилось.

← Вернуться к проектам Продолжить исследование ↗