alibabacloud-flink-python-coding

阿里云VVR上PyFlink作业的AI编码助手

开发流程 写Python代码准备PyFlink作业部署编写业务代码 通用 ★ 55 更新于 2026-08-02

安装使用

复制下面这段提示词发给你的 AI(Claude / Cursor / TRAE / Codex / WorkBuddy 等),它会自动帮你完成安装:

帮我安装这个 AI Skill:alibabacloud-flink-python-coding。
它的用途是:阿里云VVR上PyFlink作业的AI编码助手
完整的 Skill 内容见:https://321skill.com/skills/alibabacloud-flink-python-coding/raw/index.md
请读取该页面内容,如果是 SKILL.md 格式直接安装,如果是 README 提炼核心 prompt 后安装。

提示词包含完整的 Skill 内容链接,AI 读取后即可完成安装。你也可以 查看完整内容 确认无误。

使用示例

'帮我写一个从Kafka读取JSON数据,经过过滤和窗口聚合后写入RDS的PyFlink作业,使用DataFrame API,目标VVR 11.8,Kafka topic为input,RDS表为output',它会自动生成完整的Python脚本、requirements.txt、ververica-flink依赖配置,以及部署说明。

介绍

这个Skill解决了在阿里云实时计算Flink版(VVR)上编写PyFlink作业时的痛点问题。开发者经常遇到API选择混乱、版本兼容性、依赖管理复杂等难题,尤其是需要同时考虑ververica-flink包版本、DataFrame API与Table API的取舍,以及部署工件的准备。

使用方式很简单,你只需要用自然语言描述需求,比如“帮我写一个从Kafka消费数据、过滤后写入RDS的PyFlink作业,使用DataFrame API,目标VVR 11.8”。Skill会遵循DataFrame-first工作流,自动读取仓库说明和官方文档,解析目标版本、源/目标类型和依赖,生成完整的Python代码、配置文件、依赖列表和部署工件。所有示例都标记为“替换前”,确保安全。

它非常适合需要将PyFlink作业部署到阿里云实时计算Flink版的数据工程师、后端开发者和数据分析师。尤其是那些已经熟悉Flink但希望减少环境配置错误、快速获得可运行代码的团队或个人。

建议在统一使用VVR 11.8及以上版本时使用此工具。需要注意的是,它主要聚焦于代码生成、本地验证和部署工件准备,不会自动上传文件、创建或停止部署,也不调用阿里云API。如果用户需要执行部署操作,需单独说明。

常见问题

是否支持SQL或Table API?

支持,但默认优先使用DataFrame API,除非用户明确要求非DataFrame API或SQL。

如何安装这个Skill?

通过ClawHub CLI安装:claw install alibabacloud-flink-python-coding

给 AI 助手的安装指引

如果你的 AI 编程助手(Claude Code、Cursor、TRAE 等)能看到这个页面,把下面这段发给它即可自动完成安装:

请访问 https://321skill.com/skills/alibabacloud-flink-python-coding/raw/index.md 读取 alibabacloud-flink-python-coding 的原始 Skill 定义(Markdown 格式),按其中说明在我的环境里完成安装和配置。