Skip to content

bbossgroups/bboss-elastic-tran

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

506 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

bboss-datatran简介

Bboss is a Elasticsearch Java rest client ,a Etl engine ,a Batch/Stream Metrics tool,a bboss-jobflow.

https://esdoc.bbossgroups.com/#/README

bboss-datatran由 bboss 开源的数据采集同步ETL工具,提供数据采集、数据清洗转换处理和数据入库以及数据指标统计计算流批一体化处理功能。

bboss-datatran 数据同步作业直接采用java语言开发,小巧而精致,同时又可以采用java提供的所有功能和现有组件框架,随心所欲地处理和加工海量存量数据、实时增量数据,实现流批一体数据处理功能;可以根据数据规模及同步性能要求,按需配置和调整数据采集同步作业所需内存、工作线程、线程队列大小;可以将作业独立运行,亦可以将作业嵌入基于java开发的各种应用一起运行;提供了作业任务控制API、作业监控api,支持作业启动、暂停(pause)、继续(resume)、停止控制机制,可轻松定制一款属于自己的ETL管理工具。

工具可以灵活定制具备各种功能的数据采集统计作业

  1. 只采集和处理数据作业

  2. 采集和处理数据、指标统计计算混合作业

  3. 采集数据只做指标统计计算作业

指标计算特点

  1. 支持时间维度和非时间维度指标计算

  2. 时间维度指标计算:支持指定统计时间窗口,单位到分钟级别

  3. 一个指标支持多个维度和多个度量字段计算,多个维度字段值构造成指标的唯一指标key,支持有限基数key和无限基数key指标计算

  4. 一个作业可以支持多种类型的指标,每种类型指标支持多个指标计算

使用文档:https://esdoc.bbossgroups.com/#/db-es-tool

Environment requirements

JDK requirement: JDK 1.8+

Elasticsearch version requirements: 1.X,2.X,5.X,6.X,7.x,8.x,9.x,+

Spring booter 1.x,2.x,3.x,+

Build from source code

First Get source code from

https://gitee.com/bboss/bboss-elastic

https://gitee.com/bboss/bboss-elastic-tran

Then change to cmd window under directory bboss-elastic-tran and run gradle build command:

gradle publishToMavenLocal

Build from source code guide:

https://esdoc.bbossgroups.com/#/bboss-build

How to use Elasticsearch BBoss.

Add the maven dependency of BBoss to your pom.xml:

       <dependency>
            <groupId>com.bbossgroups.plugins</groupId>
            <artifactId>bboss-datatran-jdbc</artifactId>
            <version>7.5.5</version>
        </dependency>

bboss-jobflowgraph

jobflow 提供通用轻量级、高性能流程、有限循环图编排模型,可将各种各样、不同类型的任务编排成工作流和有向循环图,进行统一调度执行,譬如数据采集作业任务、流批处理作业任务、业务办理任务、充值缴费任务以及多模态多智能体大模型推理任务等按顺序编排成工作流。

有向循环图

说明:

  • 基于有向循环图的智能体协同、自主规划、迭代执行、结果评估和优化机制;可灵活设置最大循环次数,避免流程陷入无限循环
  • 基于串行、并行、条件类型流程节点,实现多智能体协同流程编排和执行
  • 基于流程上下文、复合节点上下文、节点上下文三层上下文环境,实现智能体长短期记忆分层管理
  • 任务调度:提供一次性和周期性两种任务调度策略,灵活调度智能体协同工作流

jobflow使用参考文档:https://esdoc.bbossgroups.com/#/jobworkflow

蓝图规划

  1. 增加oracle cdc、postgresql cdc、sql server cdc插件
  2. 增加redis插件

联系我们

QQ交流群:21220580,166471282,3625720,154752521,166471103,166470856

微信交流群:

交流社区:

支持我们

如果您正在使用bboss,或是想支持我们继续开发,您可以通过如下方式支持我们:

1.Star并向您的朋友推荐或分享

bboss elasticsearch client🚀

数据采集&流批一体化处理🚀

2.通过爱发电 直接捐赠,或者扫描下面二维码进行一次性捐款赞助,请作者喝一杯咖啡☕️

非常感谢您对开源精神的支持!❤您的捐赠将用于bboss社区建设、QQ群年费、网站云服务器租赁费用。

License

The BBoss Framework is released under version 2.0 of the Apache License.

Star History

Star History Chart

About

bboss-datatran 由 bboss 开源的数据采集&流批一体化工具,提供数据采集、清洗转换处理以及流批一体化计算功能; 同时也是一个高性能Elasticsearch orm 客户端,100%兼容es各个版本 ,兼容spring boot1.x,2.x,3.x;jobflow 通用数据交换、AI以及业务办理工作流编排引擎

Topics

Resources

License

Stars

Watchers

Forks

Packages

 
 
 

Contributors

Languages