火山引擎流式计算 Flink 版支持将模型推理接入 SQL 数据处理流程,并通过 AI 工具辅助作业开发与运维。本文介绍主要能力及对应的使用指南。
在 Flink SQL 作业中调用外部模型服务,将文本、图片等数据转换为表达语义特征的向量,并与业务字段一同输出。您可以将向量接入后续 SQL 处理或下游系统,为语义检索、以图搜图和多模态检索准备数据。例如,持续为新到达的商品图片生成向量,并保留商品标识,供下游检索系统关联原始商品。
详情请参见Flink SQL 多模态 Embedding 使用指南。
提供文件内容读取、文件类型识别、对象访问地址生成和模型输入构造等函数,为模型调用及后续数据处理准备输入。处理火山引擎对象存储 TOS(Torch Object Storage)中的文件时,您可以根据业务需要生成临时访问地址,供模型服务读取私有图片;也可以在 SQL 作业中读取文件内容,交给后续处理。
详情请参见 Flink SQL AI 函数。
volc-flink 是火山引擎流式计算 Flink 版的官方命令行工具,支持查询项目、资源池和表元数据,管理作业草稿,以及执行发布、运维和日志查询等操作。您可以在本地终端完成作业开发与管理,也可以利用结构化输出将平台能力接入自动化脚本和 AI 工具,为任务编排与结果分析提供基础。
详情请参见Flink Cli 工具。
通过 Flink Skill 在 AI 工具中以自然语言调用 Flink CLI,辅助完成作业开发、运维、故障诊断、性能分析和资源池分析。Skill 根据任务意图组织命令调用,并将平台返回的信息整理为结果和建议。例如,创建并校验 SQL 草稿,或结合日志、指标和事件分析作业异常。涉及发布、启停、扩缩容等变更时,需先确认目标与影响,再执行操作。
详情请参见Flink Skill & AI 工具集成。