首页
/ Roadrunner项目中的TypedSearchAttributes功能解析

Roadrunner项目中的TypedSearchAttributes功能解析

2025-05-28 18:21:23作者:乔或婵

概述

在分布式工作流系统中,搜索属性(Search Attributes)是一个非常重要的功能,它允许用户为工作流实例添加可搜索的元数据。Roadrunner项目近期计划增强其Temporal插件,引入TypedSearchAttributes功能,这将为工作流管理带来更强大的类型安全性和灵活性。

现有问题分析

当前Roadrunner的Temporal插件中,当启动子工作流(Child Workflow)时,可以通过ExecuteChildWorkflow命令传递搜索属性。然而,这些属性是以JSON格式打包到常规数组中的,缺乏类型信息。这种实现方式存在几个局限性:

  1. 类型安全性不足:所有属性值都以无类型方式处理
  2. 功能不完整:无法支持Temporal SDK中已有的TypedSearchAttributes功能
  3. 扩展性受限:难以添加新的属性类型

技术方案设计

Roadrunner团队提出了一个协议级的解决方案,通过新增UpsertWorkflowTypedSearchAttributes命令来实现类型化搜索属性。该方案的核心设计如下:

数据结构

每个搜索属性将采用结构化表示,包含以下字段:

{
  "属性名": {
    "type": "类型标识",
    "operation": "操作类型",
    "value": "属性值"
  }
}

支持的数据类型

系统将支持多种数据类型,以满足不同场景的需求:

  1. 布尔类型(bool):存储true/false值
  2. 浮点类型(float64):存储小数数值
  3. 整型(int64):存储整数数值
  4. 关键词(keyword):存储单个字符串值
  5. 关键词列表(keyword_list):存储字符串数组
  6. 字符串(string):存储任意文本
  7. 日期时间(datetime):存储RFC 3339格式的时间戳

操作类型

每个属性支持两种操作:

  1. 设置(set):设置或更新属性值(默认操作)
  2. 取消设置(unset):移除已设置的属性

实现细节

在实现层面,Roadrunner将采用以下策略:

  1. 错误处理:当遇到类型或值解析错误时,系统会记录警告日志并继续处理后续字段
  2. 向后兼容:新功能将与现有无类型搜索属性系统共存
  3. 性能考虑:采用高效的解析机制处理类型化数据

技术优势

这一改进将为系统带来显著优势:

  1. 类型安全:明确的数据类型减少了运行时错误
  2. 功能完整:与Temporal SDK功能对齐,提供更丰富的搜索能力
  3. 开发体验:更直观的API设计,便于开发者使用
  4. 可扩展性:易于添加新的数据类型支持

应用场景

TypedSearchAttributes功能特别适用于以下场景:

  1. 复杂筛选:基于多种类型条件精确查找工作流
  2. 数据分析:对数值型属性进行范围查询
  3. 时间序列:利用datetime类型进行时间范围筛选
  4. 标签系统:使用keyword_list实现多标签分类

总结

Roadrunner通过引入TypedSearchAttributes功能,显著提升了工作流搜索能力的灵活性和可靠性。这一改进不仅解决了现有系统的局限性,还为未来的功能扩展奠定了坚实基础。对于需要精细化管理工作流元数据的应用场景,这一功能将提供极大的便利和价值。

登录后查看全文

项目优选

收起
kernelkernel
openEuler内核是openEuler操作系统的核心,既是系统性能与稳定性的基石,也是连接处理器、设备与服务的桥梁。
C
471
465
kernelkernel
deepin linux kernel
C
32
16
atomcodeatomcode
Claude Code 的开源替代方案。连接任意大模型,编辑代码,运行命令,自动验证 — 全自动执行。用 Rust 构建,极致性能。 | An open-source alternative to Claude Code. Connect any LLM, edit code, run commands, and verify changes — autonomously. Built in Rust for speed. Get Started
Rust
2.09 K
218
ops-nnops-nn
本项目是CANN提供的神经网络类计算算子库,实现网络在NPU上加速计算。
C++
700
1.4 K
docsdocs
暂无描述
Dockerfile
780
5.08 K
pytorchpytorch
Ascend Extension for PyTorch
Python
758
968
flutter_flutterflutter_flutter
本仓库是 Flutter SDK 与 Flutter Engine 的 OpenHarmony 适配版本,由 CPF-Flutter 团队维护。开发者可使用熟悉的 Flutter 技术栈开发 OpenHarmony 应用,3.35.7 及以后的适配版本可基于本仓库源码构建支持 OpenHarmony 的 Flutter Engine。
Dart
1.04 K
271
ops-transformerops-transformer
本项目是CANN提供的transformer类大模型算子库,实现网络在NPU上加速计算。
C++
880
2.03 K
mindquantummindquantum
MindQuantum is a general software library supporting the development of applications for quantum computation.
Python
183
111
openHiTLSopenHiTLS
旨在打造算法先进、性能卓越、高效敏捷、安全可靠的密码套件,通过轻量级、可剪裁的软件技术架构满足各行业不同场景的多样化要求,让密码技术应用更简单,同时探索后量子等先进算法创新实践,构建密码前沿技术底座!
C
1.11 K
682