FlowBuilder

🚀 基于 Rust 的异步工作流 / 编排引擎：YAML 驱动 · 并行调度 · 可裁剪特性

✨ 特性概览

🚀 安装

默认启用 core + yaml-runtime：

[dependencies]
flowbuilder = { version = "0.1.1" }
tokio = { version = "1", features = ["rt-multi-thread", "macros"] }

最小（仅 DSL）：

flowbuilder = { version = "0.1.1", default-features = false, features = ["core"] }

🔌 Feature 体系

常用组合：

perf-metrics 默认开启；禁用请自建 runtime-base（规划中）。

🧪 快速示例

use flowbuilder::prelude::*;            // DSL
use flowbuilder::yaml::prelude::*;      // 动态执行器
#[cfg(feature = "runtime")] use flowbuilder::runtime::prelude::*; // 高级执行

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let yaml = std::fs::read_to_string("workflow.yaml")?;
    let config = WorkflowLoader::from_yaml_str(&yaml)?;
    let mut exec = DynamicFlowExecutor::new(config)?;
    let ctx = std::sync::Arc::new(tokio::sync::Mutex::new(flowbuilder_context::FlowContext::default()));
    #[cfg(feature = "runtime")] {
        let result = exec.execute(ctx).await?;
        println!("success={} phases={}", result.success, result.phase_results.len());
        #[cfg(feature = "perf-metrics")] {
            let stats = exec.get_stats();
            println!("tasks={} ok={}", stats.total_tasks, stats.successful_tasks);
        }
    }
    Ok(())
}

提示：生产构建可关闭 detailed-logging，最小体积使用 default-features = false。

🏗️ 架构

┌──────────────┐    ┌────────────────┐    ┌────────────────┐
│  YAML Config │ -> │ Orchestrator   │ -> │   Executor      │
│ (Parser)     │    │ (Plan / Analyze) │ │ (Run / Metrics) │
└──────────────┘    └────────────────┘    └────────────────┘

核心组件：Parser / Orchestrator / Executor / SharedContext

📊 性能要点

零成本抽象 · Tokio 异步 · 并行调度 · 指标统计 · 内存友好

🔧 配置能力

任务定义 · 依赖/条件 · 重试 · 超时 · 变量注入 · 计划复杂度分析

📚 文档 & 示例

• 快速入门
• 架构设计
• API 参考
• Chronetix 集成计划
• 示例：examples/new_architecture_demo.rs

运行：

cargo test
cargo run --example new_architecture_demo

📝 日志与环境变量

FlowBuilder 使用 tracing 作为统一日志框架，建议在应用入口调用统一初始化：

fn main() {
        flowbuilder::logging::init();
        // ...
}

环境变量：

• RUST_LOG：控制日志级别与过滤，默认 info。示例：
  • RUST_LOG=info,flowbuilder=debug,flowbuilder_runtime=debug
• FB_LOG_FORMAT：控制输出格式，默认 pretty。
  • 支持：pretty | compact | json

示例运行：

# 紧凑格式，顶层 info，子 crate 调到 debug
RUST_LOG=info,flowbuilder=debug,flowbuilder_runtime=debug \
FB_LOG_FORMAT=compact \
cargo run --example new_architecture_demo

# JSON 输出，便于采集/分析
FB_LOG_FORMAT=json cargo run --example simple_example

提示：启用 detailed-logging 特性可获得更丰富的调试日志；生产环境建议关闭该特性并根据需要设置过滤规则。

🌟 使用场景

微服务编排 / 数据管道 / CI&CD 自动化 / 业务流程 / API 工作流 / 批处理

🗺️ 路线规划

• runtime-base 精细化子特性
• 分布式执行 (distributed / sharding)
• 扩展指标与可观测性

🤝 贡献

欢迎 Issue / PR 参与改进（参见 CONTRIBUTING.md）。

📄 许可证

Apache-2.0，详见 LICENSE。

用 ❤️ 打造的 Rust 工作流引擎