alibabacloud-flink-instance-manage

Alibaba Cloud Flink 实例管理

通过单个封装脚本，以严格限定的创建/查询范围操作 Alibaba Cloud Flink 资源。

范围与入口

• 始终通过以下方式运行操作：

  python scripts/instance_ops.py <command> [options]
  

• 允许的命令：create、create_namespace、describe、describe_regions、describe_zones、describe_namespaces、list_tags
• 范围之外：更新/删除、Flink SQL/作业运行时操作，以及非 Flink 服务

触发规则

当提示涉及 Flink 实例/命名空间生命周期操作时，使用此技能。

• 正向意图示例：
  • “在 cn-beijing 创建 Flink 实例”
  • “列出 Flink 实例及其状态”
  • “查询实例 f-cn-xxx 的命名空间”
  • “查询 Flink 实例标签”
  • “Flink 可用区有哪些”
• 负向意图示例：
  • ECS/Kafka/OSS/DataWorks 操作
  • 通用问题（天气、翻译等）
  • Flink SQL / Flink 作业编写或运行时调优
• 意图不明确的提示：
  • 询问一个澄清问题：是实例/命名空间管理，还是 SQL/作业操作。

意图到命令的映射

用户意图	命令
查询某个地域中的所有实例	describe --region_id <REGION>
创建实例	create ... --confirm
查询某个实例下的命名空间	describe_namespaces --region_id <REGION> --instance_id <ID>
创建命名空间	create_namespace ... --confirm
查询支持的地域/可用区	describe_regions / describe_zones --region_id <REGION>
查询标签	list_tags --region_id <REGION> --resource_type <TYPE> [--resource_ids ...]

操作规则

1. 创建命令必须经过确认
   • create 和 create_namespace 必须包含 --confirm。
2. 通过回读验证创建结果
   • 不能仅凭创建响应就断定成功。
3. 严格遵守重试策略
   • 同一命令最多尝试 2 次（首次尝试 + 一次修正后重试）。
4. 不得自动切换操作
   • 如果操作失败，未经用户批准不得切换到其他操作。
5. 锁定生命周期目标
   • 在 create -> create_namespace 流程中，命名空间必须指向同一个新创建的 InstanceId，除非用户批准使用备用目标。
6. 创建命名空间前必须预检查
   • 在执行 create_namespace 前，检查实例状态/资源和现有命名空间分配情况。
7. 不得泄露机密
   • 不得输出或索取明文 AK/SK。请遵循默认凭证链指南。
8. 不得臆造参数
   • 不得伪造 VPC/VSwitch/实例 ID。
9. 保留可审计的确认依据
   • 生命周期操作的输出必须包含 SafetyCheckRequired 或明确的 --confirm 依据。
10. 生命周期流程不得宣称部分完成

• 对于需要同时执行 create 和 create_namespace 的流程，只有两个创建操作都成功，整体状态才能为 completed。

11. 不得自动扩容

• 如果 create_namespace 因资源不足而失败，应明确报告，并要求用户在此技能范围之外手动扩容。

执行流程

步骤 1：判定请求

• 属于范围内的 Flink 实例/命名空间/标签/地域/可用区创建或查询请求 -> 继续。
• 超出范围或非 Flink 请求 -> 拒绝或说明原因并转交。

步骤 2：验证参数

• 按照 references/parameter-validation.md 执行。
• 如果缺少必需参数，请询问用户或提供明确的解决办法。

步骤 3：执行命令

• 查询命令：运行一次，除非遇到暂时性查询错误。
• 创建命令：构造最终命令字符串，并在执行前确认其中包含 --confirm。

步骤 4：验证创建结果

• 对于 create：使用 describe --region_id <REGION> 验证。
• 对于 create_namespace：使用 describe_namespaces --region_id <REGION> --instance_id <ID> 验证。
• 最多进行 3 次读取检查，每次间隔较短，然后再判定创建结果尚未反映。
• 对于串联的 create -> create_namespace：
  • 每隔 30 秒对同一个 InstanceId 轮询 describe --region_id <REGION>
  • 最长等待时间：10 分钟
  • 如果仍未处于 RUNNING 状态，则停止并提供后续操作（等待或稍后重试）
  • 未经用户明确批准，不要切换到其他实例
  • 如果命名空间创建失败，将生命周期链标记为 failed/not_ready，而不是 completed
  • 对于 InsufficientResources，请用户手动扩容实例并稍后重试

重要参考资料

• 从这里开始：
  • references/README.md
  • references/quick-start.md
  • references/trigger-recognition-guide.md
  • references/core-execution-flow.md
  • references/command-templates.md

文档	用途
references/parameter-validation.md	执行前验证清单
references/e2e-playbooks.md	完整执行流程
references/common-failures.md	常见错误及修复方法
references/required-confirmation-model.md	确认门控规则
references/instance-state-management.md	实例状态和就绪情况检查
references/output-handling.md	输出解析和重试策略
references/verification-method.md	创建/查询后的验证模式
references/acceptance-criteria.md	常规操作完成清单
references/python-environment-setup.md	Python 依赖项和身份验证设置
references/cli-installation-guide.md	Aliyun CLI 诊断设置
references/ram-policies.md	所需 RAM 权限
references/related-apis.md	API 与命令映射

输出格式

所有命令均返回 JSON：

{
  "success": true,
  "operation": "<command>",
  "confirmation_check": {
    "required_flag": "--confirm",
    "provided": true,
    "status": "passed"
  },
  "data": {},
  "request_id": "..."
}

创建操作会显示 confirmation_check，用于提供可审计的安全证据。

退出代码：0 = 成功，1 = 错误。