AIKraft/AI/Войти
AIKraft/Skills/developing-applications-on-managed-service-for-apache-flink

developing-applications-on-managed-service-for-apache-flink

Обязательный навык для вопросов по Amazon MSF for Apache Flink. Учитывает специфические ограничения: модель KPU, запреты на чекпоинты/параллелизм в коде, разделение v1/v2 (kinesisanalyticsv2 для CLI/SDK, kinesisanalytics для IAM/CloudWatch), миграцию 1.x→2.x.

aws official Разработка ★ 2.8k

Что делает навык

Навык предоставляет экспертные знания для разработки, управления ресурсами (KPU), мониторинга и миграции приложений Apache Flink в Amazon Managed Service for Apache Flink (MSF). Он решает задачи создания, развертывания и поддержки потоковой обработки данных с учетом специфических ограничений управляемой службы.

Когда применять

  • Разработка приложений Flink с использованием DataStream API или Table API в среде MSF.
  • Управление ресурсами вычислений (KPU) и настройка параллелизма без использования жестко заданных значений в коде.
  • Миграция приложений с версии 1.x на 2.x с учетом изменений в API и IAM.
  • Настройка мониторинга и управления состоянием (state management) через AWS CLI или SDK.

Как работает

  1. Определить уровень подготовки пользователя (новичок в Flink или MSF) и сложность бизнес-логики для выбора между DataStream API и Table API.
  2. Использовать AWS MCP server для выполнения команд с аудитом и логированием; при его отсутствииFallback на AWS CLI или shell.
  3. Учитывать разделение API: использовать kinesisanalyticsv2 для CLI/SDK и kinesisanalytics для IAM/CloudWatch.
  4. Соблюдать ограничения MSF: избегать чекпоинтов и жесткого параллелизма в коде, управляя ресурсами через KPU.
  5. Применять лучшие практики для управления состоянием, коннекторами и развертывания через IaC.

Примеры запросов агенту

Как развернуть приложение Flink на MSF версии 2.x с использованием DataStream API?
Какие ограничения накладываются на параллелизм и чекпоинты в Amazon Managed Service for Apache Flink?
Как выполнить миграцию приложения Flink с версии 1.x на 2.x?

Что понадобится

  • Доступ к AWS MCP server (предпочтительно) или AWS CLI.
  • Знание Java и основ работы с Apache Flink.
  • Понимание различий между API v1 (kinesisanalytics) и v2 (kinesisanalyticsv2).

Описание составлено по SKILL.md навыка, сверено 07.10.2026.

Как подключить

1Скачать навык
# возьмите папку навыка «developing-applications-on-managed-service-for-apache-flink» из репозитория: # https://github.com/aws/agent-toolkit-for-aws
2Положить папку с SKILL.md к навыкам ассистента
# положите папку навыка туда, где ассистент ищет skills: cp -r developing-applications-on-managed-service-for-apache-flink/ ~/.claude/skills/developing-applications-on-managed-service-for-apache-flink/

Навык — папка с файлом SKILL.md (описание + инструкции) и опциональными скриптами. Ассистент (Claude, Claude Code и совместимые) подхватывает его по описанию и следует шагам.