用途:面向阿里云实时计算 Apache Flink 的 SQL 作业全生命周期管理,按用户所处阶段进入同一生命周期流程,仅在目标所需阶段执行,未授权不进行部署、启动、停止或删除。
主要能力:需求与数据契约定义;SQL 编写与静态语义、配置、版本兼容检查;目标环境、身份与元数据确认和云端校验;Draft 与 Deployment 维护,保持 SQL、配置与已部署版本一致;作业启动(含所需恢复行为)与运行状态及验收标准验证;运行实例、状态与支撑资源运维与安全变更回读;性能评估与故障定位并按证据给出建议。另含 Git 同步后处理、产物格式与仓库保护等规则。
使用方式:统一命令为 python3 scripts/flink_sql_manager.py <command> [args...]。云端调用前先读 references/manifest.json,并按 references/configuration.md 初始化 SKILL_SESSION_ID;多步任务前读 references/lifecycle.md。首次 Ververica OpenAPI 调用前按 references/configuration.md 检查配置,可选初始化 Git。任何 Ververica OpenAPI 操作前运行:python3 scripts/flink_sql_manager.py config_doctor;初始化后再次运行,退出码为 0 且显式成功才继续云端操作。仅本地 SQL 设计、编写或解释时不受该门禁阻塞。只读取当前阶段所需参考文档。
限制与安全:CLI 每个变更命令都需 --confirm。只读命令在范围明确且配置检查通过后可直接执行;普通变更需用户明确请求该动作方可确认;stop_、delete_、含停止的重启或部署流程,以及 DROP、TRUNCATE 等破坏性 execute_sql 属高风险,须明确确认影响且解析目标仍在确认范围内。确认仅适用于当前请求的操作与目标,范围变化需重新确认。不得使用占位 ID,缺失 Draft、Deployment 或 Job ID 时通过用户提供信息或只读查询获取。除历史 Metrics 可使用用户提供的 Cookie 外,不接受 AccessKey、token 或密码,不得回显或提交凭据。命令失败后停止依赖步骤,不得编造 ID、工单、状态或成功结果;无法实际执行时须说明缺失前提并给出待执行完整命令。所有结论须来自实际命令输出与回读证据。
评估与测试:代理评估使用 bash evals/run_skill_up.sh(eval.yaml 与用例使用 Skill Up v1alpha1,输出 JSON 与 HTML 报告);获得授权后可用 python3 tests/live_api_e2e.py 跑实时端到端测试,需先设 RUN_LIVE_FLINK_E2E=1,初始化 SKILL_SESSION_ID 并使用测试工作空间。其余配置与定价等细节暂未提供。