Spring-Batch for Rust

Spring Batch for Rust提供了强大的灵活框架，用于开发批处理应用程序，解决高效且可靠地处理大规模数据任务的挑战。它为开发者提供了构建企业级批处理应用程序的全面工具包。

特性

路线图

• XML读取器和写入器
• 过滤项目
• Kafka读取器和写入器
• Pulsar读取器和写入器
• 重试/跳过策略
• 将执行数据保存到数据库

入门

确保在Cargo.toml上激活了合适的特性crate

[dependencies]
spring-batch-rs = { version = "<version>", features = ["<full|json|csv|fake|logger>"] }

然后在main.rs中

fn main() -> Result<(), BatchError> {
    let csv = "year,make,model,description
   1948,Porsche,356,Luxury sports car
   1995,Peugeot,205,City car
   2021,Mazda,CX-30,SUV Compact
   1967,Ford,Mustang fastback 1967,American car";

    let reader = CsvItemReaderBuilder::new()
        .delimiter(b',')
        .has_headers(true)
        .from_reader(csv.as_bytes());

    let processor = UpperCaseProcessor::default();

    let writer = JsonItemWriterBuilder::new().from_path(temp_dir().join("cars.json"));

    let step: Step<Car, Car> = StepBuilder::new()
        .reader(&reader) // set csv reader
        .writer(&writer) // set json writer
        .processor(&processor) // set upper case processor
        .chunk(2) // set commit interval
        .skip_limit(2) // set fault tolerance
        .build();

    let job = JobBuilder::new().start(Box::new(&step)).build();
    let result = job.run();

    assert!(result.is_ok());
    assert!(step.get_status() == StepStatus::Success);

    Ok(())
}

示例

• 使用处理器从JSON文件生成CSV文件
• 具有容错性的从CSV字符串生成JSON文件
• 从假人生成JSON文件
• 从假人生成无标题的CSV文件
• 将记录插入Mysql数据库
• 记录Postgres数据库的记录
• 从MongoDb数据库读取记录
• 将记录写入MongoDb数据库

许可证

根据您的选择，许可为以下之一

• Apache许可证第2版 (LICENSE-APACHE 或 http://www.apache.org/licenses/LICENSE-2.0)
• MIT许可证 (LICENSE-MIT 或 http://opensource.org/licenses/MIT)

。

贡献

除非您明确声明，否则根据Apache-2.0许可定义的您有意提交的任何贡献，均应以上述双许可方式授权，不附加任何额外条款或条件