Pub/Sub встроил вызов ИИ-модели прямо в поток данных

10 сентября Google сделала общедоступным AI Inference SMT. Pub/Sub теперь может отправить каждое входящее сообщение модели из Gemini Enterprise Agent Platform и добавить её ответ к исходным данным перед дальнейшей обработкой.

Так можно выполнять классификацию, поиск аномалий, анализ тональности или построение эмбеддингов без отдельного сервиса между брокером и моделью. Pub/Sub также регулирует частоту запросов, чтобы не перегружать модель.

Инженерам рекомендуют применять преобразование на подписке: при сбое модели Pub/Sub повторит доставку или отправит сообщение в отдельную тему для ошибок. Если поставить его на тему, недоступность модели приведёт к ошибке публикации. Есть и ограничения: один запрос к модели на сообщение, без пакетной обработки, с тайм-аутом 60 секунд; закрытые сетевые адреса моделей пока не поддерживаются.

Пруфы:
🔜 анонс Google Cloud от 10 сентября 2026 года
🔜 техническая документация

#googlecloud #pubsub #streamprocessing #realtime #datapipeline #machinelearning #dataengineering

@data_engi